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

feat: 支持关闭移动事件回放任务

上级 95de3aaa
import pytz
import json
import time
import dynaconf
from datetime import datetime, timedelta
from intelab_python_sdk.logger import log
......@@ -78,9 +80,12 @@ class EventMergerJob:
channel = connection.channel()
channel.queue_declare(self.queue_name, durable=True)
# TODO 测试持续获取事件
# events = [{'start_time': last_check_time, 'end_time': now_std}]
events = PreEvent.merge_alarm_to_event(alarm_list)
if dynaconf.settings.get('EVENT_OFF', False):
events = PreEvent.merge_alarm_to_event(alarm_list)
else:
events = [{
'start_time': last_check_time.astimezone(tz), 'end_time': now.astimezone(tz)
}]
for event in events:
body = {
......
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论