获取自动回复卡片任务优化

app/domains/monitor_tasks/auto_reply_cards_monitor/entrance.py

@@ -40,6 +40,7 @@ class AutoReplyCardsMonitor(AutoReplyCardsMonitorConst):
                 contents={
                     "task": "auto_reply_cards_monitor",
                     "status": "fail",
+                    "trace_id": task_id,
                     "message": f"store_card missing page_path, task_id={task_id}",
                 }
             )
@@ -54,6 +55,7 @@ class AutoReplyCardsMonitor(AutoReplyCardsMonitorConst):
                 contents={
                     "task": "auto_reply_cards_monitor",
                     "status": "fail",
+                    "trace_id": task_id,
                     "message": f"store_card missing cover params, task_id={task_id}",
                 }
             )
@@ -65,6 +67,7 @@ class AutoReplyCardsMonitor(AutoReplyCardsMonitorConst):
                 contents={
                     "task": "auto_reply_cards_monitor",
                     "status": "fail",
+                    "trace_id": task_id,
                     "message": f"store_card get_cover_url failed, task_id={task_id}",
                 }
             )
@@ -95,6 +98,7 @@ class AutoReplyCardsMonitor(AutoReplyCardsMonitorConst):
                         contents={
                             "task": "auto_reply_cards_monitor",
                             "status": "fail",
+                            "trace_id": task_id,
                             "message": f"store_card upload_cover failed, task_id={task_id}",
                         }
                     )
@@ -188,6 +192,7 @@ class AutoReplyCardsMonitor(AutoReplyCardsMonitorConst):
                 contents={
                     "task": "auto_reply_cards_monitor",
                     "status": "fail",
+                    "trace_id": task_id,
                     "message": f"store_article fetch failed, task_id={task_id}, reason={fetch_fail_reason}",
                 }
             )
@@ -200,6 +205,7 @@ class AutoReplyCardsMonitor(AutoReplyCardsMonitorConst):
                     contents={
                         "task": "auto_reply_cards_monitor",
                         "status": "fail",
+                        "trace_id": task_id,
                         "message": f"store_article missing data.data, task_id={task_id}",
                     }
                 )
@@ -262,6 +268,7 @@ class AutoReplyCardsMonitor(AutoReplyCardsMonitorConst):
                             contents={
                                 "task": "auto_reply_cards_monitor",
                                 "status": "fail",
+                                "trace_id": task_id,
                                 "message": f"store_article mini_program missing path, task_id={task_id}",
                             }
                         )
@@ -318,6 +325,7 @@ class AutoReplyCardsMonitor(AutoReplyCardsMonitorConst):
                             contents={
                                 "task": "auto_reply_cards_monitor",
                                 "status": "fail",
+                                "trace_id": task_id,
                                 "message": f"store_article mini_program insert failed, task_id={task_id}, card_index={card_index}, error={e}",
                             }
                         )
@@ -408,6 +416,7 @@ class AutoReplyCardsMonitor(AutoReplyCardsMonitorConst):
                     contents={
                         "task": "auto_reply_cards_monitor",
                         "status": "fail",
+                        "trace_id": task_id,
                         "message": f"发布任务至 AIGC 失败, task_id={task_id}, account={account_name}",
                     }
                 )
@@ -420,6 +429,7 @@ class AutoReplyCardsMonitor(AutoReplyCardsMonitorConst):
                 contents={
                     "task": "auto_reply_cards_monitor",
                     "status": "fail",
+                    "trace_id": task_id,
                     "message": f"创建任务至 DB 失败, task_id={task_id}, account={account_name}",
                 }
             )
@@ -563,6 +573,7 @@ class AutoReplyCardsMonitor(AutoReplyCardsMonitorConst):
                     contents={
                         "task": "auto_reply_cards_monitor",
                         "status": "fail",
+                        "trace_id": task_id,
                         "message": f"get_auto_reply_response failed, task_id={task_id}, error={e}",
                     }
                 )
@@ -576,6 +587,7 @@ class AutoReplyCardsMonitor(AutoReplyCardsMonitorConst):
                 contents={
                     "task": "auto_reply_cards_monitor",
                     "status": "fail",
+                    "trace_id": task_id,
                     "message": "extract_single_xml missing task_id or result",
                 }
             )
@@ -600,6 +612,7 @@ class AutoReplyCardsMonitor(AutoReplyCardsMonitorConst):
                     contents={
                         "task": "auto_reply_cards_monitor",
                         "status": "fail",
+                        "trace_id": task_id,
                         "message": f"extract_single_xml result is not a list, task_id={task_id}",
                     }
                 )
@@ -645,6 +658,7 @@ class AutoReplyCardsMonitor(AutoReplyCardsMonitorConst):
                                 contents={
                                     "task": "auto_reply_cards_monitor",
                                     "status": "fail",
+                                    "trace_id": task_id,
                                     "message": f"处理 xml_obj 异常, task_id={task_id}, index={index}, msg_type={msg_type}, error={e}",
                                 }
                             )
@@ -661,6 +675,7 @@ class AutoReplyCardsMonitor(AutoReplyCardsMonitorConst):
                     contents={
                         "task": "auto_reply_cards_monitor",
                         "status": "warn",
+                        "trace_id": task_id,
                         "message": f"任务部分成功, task_id={task_id}, success={success_count}, fail={fail_count}",
                     }
                 )
@@ -671,6 +686,7 @@ class AutoReplyCardsMonitor(AutoReplyCardsMonitorConst):
                     contents={
                         "task": "auto_reply_cards_monitor",
                         "status": "fail",
+                        "trace_id": task_id,
                         "message": f"任务全部失败, task_id={task_id}, fail={fail_count}",
                     }
                 )
@@ -681,6 +697,7 @@ class AutoReplyCardsMonitor(AutoReplyCardsMonitorConst):
                     contents={
                         "task": "auto_reply_cards_monitor",
                         "status": "warn",
+                        "trace_id": task_id,
                         "message": f"任务无数据处理, task_id={task_id}",
                     }
                 )
@@ -695,6 +712,7 @@ class AutoReplyCardsMonitor(AutoReplyCardsMonitorConst):
                 contents={
                     "task": "auto_reply_cards_monitor",
                     "status": "fail",
+                    "trace_id": task_id,
                     "message": f"extract_single_xml failed, task_id={task_id}, error={e}",
                 }
             )