擅长:python、mysql、java
<p>下面是我给卡夫卡的制作人的代码。我唯一不同的做法是使用<code>yaml.safe_load</code>加载json内容。它将内容作为字符串而不是unicode返回。以下是片段</p>
<pre><code>with open('smaller_test_prod.txt') as f:
for line in f:
d = yaml.safe_load(line)
jd = json.dumps(d)
producer.send_messages(b'zeus_metrics',jd)
</code></pre>
<p>在这里,每一行都是存储在文件中的json数据。</p>