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
本文链接：https://my.lmcjl.com/post/2073.html
展开阅读全文
4 评论