我是python的新手，所以这可能是一个简单的问题，但是我有一个kafka使用者，可以从中读取消息。每次收到新消息时，它将以前的消息重写为order.json文件，但是我想附加它。另外，我想确保使用某种暂停可能不会以不超过每1秒钟的速度读取消息。任何有关如何执行此操作的提示将不胜感激。这是我当前的代码
for message in consumer:
with open('order.json', 'w') as file:
file.write(message.value.decode('UTF-8'))
append以' w'（写入模式）每次存在时都会截断文件的方式打开文件
for message in consumer:
with open('order.json', 'a') as file:
file.write(message.value.decode('UTF-8'))
本文收集自互联网，转载请注明来源。
如有侵权，请联系[email protected] 删除。
我来说两句