ils-video-recorder:修改钉钉报错消息提示

ils_common_video/isc_video/recorder.py

@@ -73,7 +73,7 @@ class StreamRecorder:
 
             except Exception as e:
                 log.exception(e)
-                send_alarm_to_developer('recorder_{}'.format(thread_id), e)
+                send_alarm_to_developer('recorder_{}'.format(dynaconf.settings.get('SERVICE_NAME',0)), e)
 
             finally:
                 try:
@@ -287,10 +287,6 @@ class ProcessMessage:
     @staticmethod
     def send_unverified_file(video_file, event_id, video_url,
                              device_code, biz_type, service_type, db_table, detection_region=''):
-        queue_name = 'UNVERIFIED_EVENT_QUEUE'
-        connection = rabbitmq_connect()
-        channel = connection.channel()
-        channel.queue_declare(queue_name, durable=True)
         log.info('添加待处理文件%s，到分析队列，开始时间%s, 结束时间%s', video_file.file_name,
                  video_file.start_time, video_file.end_time)
         log.info('视频文件%s的网络质量为%s, 评级为%s',
@@ -320,11 +316,12 @@ class ProcessMessage:
             'network_quality': video_file.network_quality,
             'network_quality_grade': video_file.network_quality_grade,
         }
-
+        queue_name = 'UNVERIFIED_EVENT_QUEUE'
+        connection = rabbitmq_connect()
+        channel = connection.channel()
+        channel.queue_declare(queue_name, durable=True)
         # 发送mq信息
-        channel.basic_publish(exchange='', routing_key=queue_name,
-                              body=json.dumps(video_data, ensure_ascii=False))
-
+        channel.basic_publish(exchange='', routing_key=queue_name,body=json.dumps(video_data, ensure_ascii=False))
         connection.close()
 
     @staticmethod