问题描述
- linux shell,将数据流重定向作为下一个程序的输入,由于有缓冲机制,数据流无法实时进行处理
-
上述问题可以简化为以下问题:
python脚本如下:#coding=utf-8 import sys import os import time if __name__ == '__main__': while True: print time.strftime('%Y-%m-%d %H:%M:%S') time.sleep( 5 )
然后通过linux命令行:python produceNmu.py >> xhb.info
这样的话每隔5s会输出一个字符串
如果想让字符串实时写入到xhb.info中,该如何做呢?
谢谢大家
解决方案
你这种机制应该是放到一个MQ等中去,而不是通过数据流来做,python程序把数据不停的插入消息队列,另一个程序从队列中读取数据来处理
时间: 2024-11-30 20:15:48