2024-06-13

异步定时任务

applications/deal/process_deal.py

@@ -285,21 +285,21 @@ class ProcessDeal(object):
         :return:
         """
         task_list = await self.get_task()
-        # print(task_list)
-        # task_dict = {}
-        # for task in task_list:
-        #     key = task['content_id']
-        #     task_dict[key] = task
-        # process_list = []
-        # for item in task_dict:
-        #     process_list.append(task_dict[item])
-        # if process_list:
-        #     # for task in task_list:
-        #     #     await self.process_task(task)
-        #     tasks = [self.process_task(params) for params in process_list]
-        #     await asyncio.gather(*tasks)
-        # else:
-        #     logging(
-        #         code="9008",
-        #         info="没有要处理的请求"
-        #     )
+        print(task_list)
+        task_dict = {}
+        for task in task_list:
+            key = task['content_id']
+            task_dict[key] = task
+        process_list = []
+        for item in task_dict:
+            process_list.append(task_dict[item])
+        if process_list:
+            # for task in task_list:
+            #     await self.process_task(task)
+            tasks = [self.process_task(params) for params in process_list]
+            await asyncio.gather(*tasks)
+        else:
+            logging(
+                code="9008",
+                info="没有要处理的请求"
+            )