Ver Fonte

feat:解构任务修改

zhaohaipeng há 1 mês atrás
pai
commit
498ce11b97

+ 1 - 0
monitor/automation_provide_job_monitor.py

@@ -66,6 +66,7 @@ def job_run_state(start_ts: int, end_ts: int):
     log_data = resp.get_body().get('data')
     log_data = resp.get_body().get('data')
 
 
     all_crawler_mode = list(dict.fromkeys([cron_info.crawler_mode for cron_info in AutomationJobCronInfo]))
     all_crawler_mode = list(dict.fromkeys([cron_info.crawler_mode for cron_info in AutomationJobCronInfo]))
+    print(f"all_crawler_mode: {all_crawler_mode}")
     collapsible_limit = 5
     collapsible_limit = 5
     crawler_mode_group = [all_crawler_mode[i:i + collapsible_limit] for i in range(0, len(all_crawler_mode), collapsible_limit)]
     crawler_mode_group = [all_crawler_mode[i:i + collapsible_limit] for i in range(0, len(all_crawler_mode), collapsible_limit)]
     for crawler_mode_partition in crawler_mode_group:
     for crawler_mode_partition in crawler_mode_group:

+ 2 - 2
util/feishu_inform_util.py

@@ -14,8 +14,8 @@ def send_card_msg_to_feishu(webhook, card_json):
         "card": card_json
         "card": card_json
     }
     }
     print(f"推送飞书消息webhook地址 - {webhook},  消息内容: {json.dumps(payload_message, indent=4, ensure_ascii=False)}")
     print(f"推送飞书消息webhook地址 - {webhook},  消息内容: {json.dumps(payload_message, indent=4, ensure_ascii=False)}")
-    response = requests.request('POST', url=webhook, headers=headers, data=json.dumps(payload_message))
-    print(f"推送飞书消息返回结果: {response.text}")
+    # response = requests.request('POST', url=webhook, headers=headers, data=json.dumps(payload_message))
+    # print(f"推送飞书消息返回结果: {response.text}")
 
 
 
 
 def timestamp_format(timestamp: str) -> str:
 def timestamp_format(timestamp: str) -> str: