2024-06-13

异步定时任务

applications/deal/process_deal.py

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