if '开始分级日志' in message:
#self.process_id_to_bus_seq.clear()
#self.gapslist.clear()
# 记录加到缓存
#self.gapslist.add(message)
date_str = datetime.now().strftime("%Y%m%d")
index_name = 'flink-log-clpf-gaps-' + str(date_str)
id='0'
log_event = LogEvent(id, source, fileTag, fileName, serviceCode, appName, timestamp, offset, message, index_name)
yield log_event.to_dict()
print('aaaaaaaaaaaaaaaaaaaaaa')
var='cccccccccccccc'
print(var+'bbbbbbbbbbbbbbb')
[root@kafka1 pyflink]# python test.py
aaaaaaaaaaaaaaaaaaaaaa
ccccccccccccccbbbbbbbbbbbbbbb
yield 继续往下跑
猜你喜欢
转载自blog.csdn.net/zhaoyangjian724/article/details/131341757
今日推荐
周排行