2024-06-13

异步定时任务

applications/deal/process_deal.py

@@ -269,16 +269,18 @@ class ProcessDeal(object):
         :return:
         """
         task_list = await self.get_task()
-        # 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])
+        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 task_list:
-            tasks = [self.process_task(params) for params in task_list]
-            await asyncio.gather(*tasks)
+            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",