提交 b17a8799 authored 作者: zw.wang's avatar zw.wang

fix: 去除中文

上级 8b7a14aa
...@@ -70,7 +70,7 @@ class EventMergerJob: ...@@ -70,7 +70,7 @@ class EventMergerJob:
pre_event = PreEvent(last_check_time.strftime('%Y-%m-%d %H:%M:%S'), pre_event = PreEvent(last_check_time.strftime('%Y-%m-%d %H:%M:%S'),
now_std.strftime('%Y-%m-%d %H:%M:%S')) now_std.strftime('%Y-%m-%d %H:%M:%S'))
alarm_list = pre_event.get_alarm_list(camera['index_code']) alarm_list = pre_event.get_alarm_list(camera['index_code'])
log.info('获取{}-{}的告警消息{}条'.format(last_check_time, now_std, len(alarm_list))) log.info('time: {}-{}, alarm_list: {}'.format(last_check_time, now_std, len(alarm_list)))
connection = None connection = None
# if len(alarm_list) > 0: # if len(alarm_list) > 0:
connection = rabbitmq_connect() connection = rabbitmq_connect()
...@@ -97,7 +97,7 @@ class EventMergerJob: ...@@ -97,7 +97,7 @@ class EventMergerJob:
if connection: if connection:
connection.close() connection.close()
log.info('本轮移动事件视频录制任务结束.') log.info('job end.')
pipe.close() pipe.close()
......
...@@ -34,7 +34,6 @@ class StreamRecorder: ...@@ -34,7 +34,6 @@ class StreamRecorder:
self.channel = self.connection.channel() self.channel = self.connection.channel()
def start(self): def start(self):
log.info('启动分析进程')
log.info('binding to queue {}'.format(self.queue_name)) log.info('binding to queue {}'.format(self.queue_name))
self.channel.queue_declare(queue=self.queue_name, durable=True) self.channel.queue_declare(queue=self.queue_name, durable=True)
......
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论