今天小编就为大家分享一篇python每5分钟从kafka中提取数据的例子，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧
我就废话不多说了，直接上代码吧！
import sys sys.path.append("..") from datetime import datetime from utils.kafka2file import KafkaDownloader import os """ 实现取kafka数据，文件按照取数据的间隔命名 如每5分钟从kafka取数据写入文件中，文件名为当前时间加5 """ TOPIC = "rtz_queue" HOSTS = "ip:9092,ip:9092" GROUP = "2001" def get_end_time(hour,minute,time_step): if (minute+time_step)%60<60: if (minute+time_step)%60<10: return str(hour+int((minute+time_step) <a style="color:transparent">来源gao($daima.com搞@代@#码网</a>60))+":"+"0"+str((minute+time_step)%60) else: 60))+":"+str((minute+time_step)%60) pass def kafkawritefile(time_step,time_num): start=datetime.now() downloader=KafkaDownloader(HOSTS, topic, group) i=1 while(i= str(end_time): break i += 1 if __name__=='__main__': time_step = 15 time_num = 1 kafkawritefile(time_step,time_num)
以上这篇python每5分钟从kafka中提取数据的例子就是小编分享给大家的全部内容了，希望能给大家一个参考，也希望大家多多支持gaodaima搞代码网。
以上就是python每5分钟从kafka中提取数据的例子的详细内容，更多请关注gaodaima搞代码网其它相关文章！
搞代码网（gaodaima.com）提供的所有资源部分来自互联网，如果有侵犯您的版权或其他权益，请说明详细缘由并提供版权或权益证明然后发送到邮箱[email protected]，我们会在看到邮件的第一时间内为您处理，或直接联系QQ：872152909。本网站采用BY-NC-SA协议进行授权
转载请注明原文链接：python每5分钟从kafka中提取数据的例子
转载请注明原文链接：python每5分钟从kafka中提取数据的例子
