ils-video-recorder:修改导包

ils_common_video/db/rabbitmq.py

 import dynaconf
 import pika
+import json
 from retrying import retry
 
 
@@ -22,3 +23,4 @@ def send_message_to_queue(queue_name, data):
     channel.queue_declare(queue_name, durable=True)
     # 发送mq信息
     channel.basic_publish(exchange='', routing_key=queue_name, body=json.dumps(data, ensure_ascii=False))
+    connection.close()

ils_common_video/isc_video/recorder.py

@@ -12,7 +12,7 @@ from intelab_python_sdk.logger import log_init, log
 from intelab_python_sdk.ffmpeg.ffmpeg_concat import concat
 from intelab_python_sdk.ffmpeg.ffmpeg_prune import prune as ffmpeg_prune
 
-from ils_common_video.db import rabbitmq_connect, redis_connect, influxdb
+from ils_common_video.db import rabbitmq_connect, redis_connect, influxdb, send_message_to_queue
 from ils_common_video.const import PROCESSING_CAMERA_KEY, CAMERA_CALLBACK_KEY
 from ils_common_video.utils.api_helper import IntelabApiHelper, PlaybackUrlException
 from ils_common_video.utils.isc_client import HikVisionClient