提交 93b28d69 authored 作者: lc.zhou's avatar lc.zhou

ils-video-merger:修改rabbitmq queue

上级 cad43c8c
import pytz
import json
import time
import dynaconf
from datetime import datetime, timedelta
......@@ -165,6 +166,10 @@ class EventMergerJob:
log.info('camera[%s] event_duration: %s',
camera['device_code'], event_duration)
if event_duration > 0:
merger_ak = dynaconf.settings.get('MERGER')
for cur in merger_ak:
if body['hik_app_key'] == cur:
self.queue_name = merger_ak[cur]['QUEUE_NAME']
self.send_mq_message(body)
log.info(body)
......
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论