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

app/domains/monitor_tasks/auto_reply_cards_monitor/entrance.py

@@ -39,6 +39,7 @@ class AutoReplyCardsMonitor(AutoReplyCardsMonitorConst):
             await self.log_service.log(
                 contents={
                     "task": "auto_reply_cards_monitor",
+                    "function": "store_card",
                     "status": "fail",
                     "trace_id": task_id,
                     "message": f"store_card missing page_path, task_id={task_id}",
@@ -54,6 +55,7 @@ class AutoReplyCardsMonitor(AutoReplyCardsMonitorConst):
             await self.log_service.log(
                 contents={
                     "task": "auto_reply_cards_monitor",
+                    "function": "store_card",
                     "status": "fail",
                     "trace_id": task_id,
                     "message": f"store_card missing cover params, task_id={task_id}",
@@ -66,6 +68,7 @@ class AutoReplyCardsMonitor(AutoReplyCardsMonitorConst):
             await self.log_service.log(
                 contents={
                     "task": "auto_reply_cards_monitor",
+                    "function": "store_card",
                     "status": "fail",
                     "trace_id": task_id,
                     "message": f"store_card get_cover_url failed, task_id={task_id}",
@@ -97,6 +100,7 @@ class AutoReplyCardsMonitor(AutoReplyCardsMonitorConst):
                     await self.log_service.log(
                         contents={
                             "task": "auto_reply_cards_monitor",
+                            "function": "store_card",
                             "status": "fail",
                             "trace_id": task_id,
                             "message": f"store_card upload_cover failed, task_id={task_id}",
@@ -115,7 +119,9 @@ class AutoReplyCardsMonitor(AutoReplyCardsMonitorConst):
                 await self.log_service.log(
                     contents={
                         "task": "auto_reply_cards_monitor",
+                        "function": "store_card",
                         "status": "fail",
+                        "trace_id": task_id,
                         "message": f"store_card upload_cover failed, task_id={task_id}",
                     }
                 )
@@ -191,6 +197,7 @@ class AutoReplyCardsMonitor(AutoReplyCardsMonitorConst):
             await self.log_service.log(
                 contents={
                     "task": "auto_reply_cards_monitor",
+                    "function": "store_article",
                     "status": "fail",
                     "trace_id": task_id,
                     "message": f"store_article fetch failed, task_id={task_id}, reason={fetch_fail_reason}",
@@ -204,6 +211,7 @@ class AutoReplyCardsMonitor(AutoReplyCardsMonitorConst):
                 await self.log_service.log(
                     contents={
                         "task": "auto_reply_cards_monitor",
+                        "function": "store_article",
                         "status": "fail",
                         "trace_id": task_id,
                         "message": f"store_article missing data.data, task_id={task_id}",
@@ -267,6 +275,7 @@ class AutoReplyCardsMonitor(AutoReplyCardsMonitorConst):
                         await self.log_service.log(
                             contents={
                                 "task": "auto_reply_cards_monitor",
+                                "function": "store_article",
                                 "status": "fail",
                                 "trace_id": task_id,
                                 "message": f"store_article mini_program missing path, task_id={task_id}",
@@ -324,6 +333,7 @@ class AutoReplyCardsMonitor(AutoReplyCardsMonitorConst):
                         await self.log_service.log(
                             contents={
                                 "task": "auto_reply_cards_monitor",
+                                "function": "store_article",
                                 "status": "fail",
                                 "trace_id": task_id,
                                 "message": f"store_article mini_program insert failed, task_id={task_id}, card_index={card_index}, error={e}",
@@ -338,6 +348,7 @@ class AutoReplyCardsMonitor(AutoReplyCardsMonitorConst):
             await self.log_service.log(
                 contents={
                     "task": "auto_reply_cards_monitor",
+                    "function": "create_follow_single_account_task",
                     "status": "fail",
                     "message": f"create_follow_single_account_task response is None, gh_id={gh_id}",
                 }
@@ -358,6 +369,7 @@ class AutoReplyCardsMonitor(AutoReplyCardsMonitorConst):
                     await self.log_service.log(
                         contents={
                             "task": "auto_reply_cards_monitor",
+                            "function": "create_follow_single_account_task",
                             "status": "fail",
                             "message": f"create_follow_single_account_task parse response failed, gh_id={gh_id}, error={e}",
                         }
@@ -368,6 +380,7 @@ class AutoReplyCardsMonitor(AutoReplyCardsMonitorConst):
                     await self.log_service.log(
                         contents={
                             "task": "auto_reply_cards_monitor",
+                            "function": "create_follow_single_account_task",
                             "status": "warn",
                             "message": f"create_follow_single_account_task no recent articles, gh_id={gh_id}",
                         }
@@ -397,6 +410,7 @@ class AutoReplyCardsMonitor(AutoReplyCardsMonitorConst):
                 await self.log_service.log(
                     contents={
                         "task": "auto_reply_cards_monitor",
+                        "function": "create_follow_single_account_task",
                         "status": "warn",
                         "message": f"create_follow_single_account_task unexpected code={code}, gh_id={gh_id}",
                     }
@@ -415,6 +429,7 @@ class AutoReplyCardsMonitor(AutoReplyCardsMonitorConst):
                 await self.log_service.log(
                     contents={
                         "task": "auto_reply_cards_monitor",
+                        "function": "create_auto_reply_single_account_task",
                         "status": "fail",
                         "trace_id": task_id,
                         "message": f"发布任务至 AIGC 失败, task_id={task_id}, account={account_name}",
@@ -428,6 +443,7 @@ class AutoReplyCardsMonitor(AutoReplyCardsMonitorConst):
             await self.log_service.log(
                 contents={
                     "task": "auto_reply_cards_monitor",
+                    "function": "create_auto_reply_single_account_task",
                     "status": "fail",
                     "trace_id": task_id,
                     "message": f"创建任务至 DB 失败, task_id={task_id}, account={account_name}",
@@ -441,6 +457,7 @@ class AutoReplyCardsMonitor(AutoReplyCardsMonitorConst):
             await self.log_service.log(
                 contents={
                     "task": "auto_reply_cards_monitor",
+                    "function": "follow_gzh_task",
                     "status": "fail",
                     "message": f"follow_gzh_task get_monitor_account_list failed, error={e}",
                 }
@@ -451,6 +468,7 @@ class AutoReplyCardsMonitor(AutoReplyCardsMonitorConst):
             await self.log_service.log(
                 contents={
                     "task": "auto_reply_cards_monitor",
+                    "function": "follow_gzh_task",
                     "status": "warn",
                     "message": "follow_gzh_task: no accounts from ODPS",
                 }
@@ -463,6 +481,7 @@ class AutoReplyCardsMonitor(AutoReplyCardsMonitorConst):
                 await self.log_service.log(
                     contents={
                         "task": "auto_reply_cards_monitor",
+                        "function": "follow_gzh_task",
                         "status": "warn",
                         "message": "follow_gzh_task account missing 公众号名, skip",
                     }
@@ -483,6 +502,7 @@ class AutoReplyCardsMonitor(AutoReplyCardsMonitorConst):
                         await self.log_service.log(
                             contents={
                                 "task": "auto_reply_cards_monitor",
+                                "function": "follow_gzh_task",
                                 "status": "warn",
                                 "message": f"系统中无账号，跳过: {account_name}",
                             }
@@ -493,6 +513,7 @@ class AutoReplyCardsMonitor(AutoReplyCardsMonitorConst):
                     await self.log_service.log(
                         contents={
                             "task": "auto_reply_cards_monitor",
+                            "function": "follow_gzh_task",
                             "status": "warn",
                             "message": f"fetch_account_status 返回空, 跳过: {account_name}",
                         }
@@ -505,6 +526,7 @@ class AutoReplyCardsMonitor(AutoReplyCardsMonitorConst):
                     await self.log_service.log(
                         contents={
                             "task": "auto_reply_cards_monitor",
+                            "function": "follow_gzh_task",
                             "status": "warn",
                             "message": f"账号已经迁移或者封禁: {account_name}",
                         }
@@ -516,6 +538,7 @@ class AutoReplyCardsMonitor(AutoReplyCardsMonitorConst):
                     await self.log_service.log(
                         contents={
                             "task": "auto_reply_cards_monitor",
+                            "function": "follow_gzh_task",
                             "status": "fail",
                             "message": f"账号缺少 gh_id: {account_name}",
                         }
@@ -528,6 +551,7 @@ class AutoReplyCardsMonitor(AutoReplyCardsMonitorConst):
                 await self.log_service.log(
                     contents={
                         "task": "auto_reply_cards_monitor",
+                        "function": "follow_gzh_task",
                         "status": "fail",
                         "message": f"处理账号异常 account={account_name}, error={e}",
                     }
@@ -572,6 +596,7 @@ class AutoReplyCardsMonitor(AutoReplyCardsMonitorConst):
                 await self.log_service.log(
                     contents={
                         "task": "auto_reply_cards_monitor",
+                        "function": "get_auto_reply_response",
                         "status": "fail",
                         "trace_id": task_id,
                         "message": f"get_auto_reply_response failed, task_id={task_id}, error={e}",
@@ -586,6 +611,7 @@ class AutoReplyCardsMonitor(AutoReplyCardsMonitorConst):
             await self.log_service.log(
                 contents={
                     "task": "auto_reply_cards_monitor",
+                    "function": "extract_single_xml",
                     "status": "fail",
                     "trace_id": task_id,
                     "message": "extract_single_xml missing task_id or result",
@@ -611,6 +637,7 @@ class AutoReplyCardsMonitor(AutoReplyCardsMonitorConst):
                 await self.log_service.log(
                     contents={
                         "task": "auto_reply_cards_monitor",
+                        "function": "extract_single_xml",
                         "status": "fail",
                         "trace_id": task_id,
                         "message": f"extract_single_xml result is not a list, task_id={task_id}",
@@ -657,6 +684,7 @@ class AutoReplyCardsMonitor(AutoReplyCardsMonitorConst):
                             await self.log_service.log(
                                 contents={
                                     "task": "auto_reply_cards_monitor",
+                                    "function": "extract_single_xml",
                                     "status": "fail",
                                     "trace_id": task_id,
                                     "message": f"处理 xml_obj 异常, task_id={task_id}, index={index}, msg_type={msg_type}, error={e}",
@@ -674,6 +702,7 @@ class AutoReplyCardsMonitor(AutoReplyCardsMonitorConst):
                 await self.log_service.log(
                     contents={
                         "task": "auto_reply_cards_monitor",
+                        "function": "extract_single_xml",
                         "status": "warn",
                         "trace_id": task_id,
                         "message": f"任务部分成功, task_id={task_id}, success={success_count}, fail={fail_count}",
@@ -685,6 +714,7 @@ class AutoReplyCardsMonitor(AutoReplyCardsMonitorConst):
                 await self.log_service.log(
                     contents={
                         "task": "auto_reply_cards_monitor",
+                        "function": "extract_single_xml",
                         "status": "fail",
                         "trace_id": task_id,
                         "message": f"任务全部失败, task_id={task_id}, fail={fail_count}",
@@ -696,6 +726,7 @@ class AutoReplyCardsMonitor(AutoReplyCardsMonitorConst):
                 await self.log_service.log(
                     contents={
                         "task": "auto_reply_cards_monitor",
+                        "function": "extract_single_xml",
                         "status": "warn",
                         "trace_id": task_id,
                         "message": f"任务无数据处理, task_id={task_id}",
@@ -711,6 +742,7 @@ class AutoReplyCardsMonitor(AutoReplyCardsMonitorConst):
             await self.log_service.log(
                 contents={
                     "task": "auto_reply_cards_monitor",
+                    "function": "extract_single_xml",
                     "status": "fail",
                     "trace_id": task_id,
                     "message": f"extract_single_xml failed, task_id={task_id}, error={e}",
@@ -742,6 +774,7 @@ class AutoReplyCardsMonitor(AutoReplyCardsMonitorConst):
                 await self.log_service.log(
                     contents={
                         "task": "auto_reply_cards_monitor",
+                        "function": "deal",
                         "status": "fail",
                         "message": f"unknown task_name: {task_name}",
                     }