测试

Controller/DetectControllerV2.py

@@ -135,11 +135,13 @@ class NotificationV2View(View):
                 result['new_device_info_list'])
 
             # # 异步推送消息和保存数据
-            # push_thread = threading.Thread(
-            #     target=push_and_save_data,
-            #     args=(uid_set_push_list, is_sys_msg),
-            #     kwargs=params)
-            # push_thread.start()
+            TIME_LOGGER.info('异步推送参数:{},{},{}'.format(uid_set_push_list, is_sys_msg, params))
+            push_thread = threading.Thread(
+                target=push_and_save_data,
+                args=(uid_set_push_list, is_sys_msg),
+                kwargs=params)
+            push_thread.start()
+
             a, b = 1, 2
             kwargs = {
                 'c': 3,
@@ -168,6 +170,7 @@ class NotificationV2View(View):
 
 
 def push_and_save_data(uid_set_push_list, is_sys_msg, **params):
+    TIME_LOGGER.info('触发异步推送函数')
     TIME_LOGGER.info('{}开始异步推送'.format(params['uid']))
     # 推送消息,生成推送数据列表
     result = DevicePushService.save_msg_push(uid_set_push_list, **params)