소스 검색

feat:添加自动化供给监控

zhaohaipeng 1 개월 전
부모
커밋
743215032f
1개의 변경된 파일3개의 추가작업 그리고 3개의 파일을 삭제
  1. 3 3
      monitor/automation_provide_job_monitor.py

+ 3 - 3
monitor/automation_provide_job_monitor.py

@@ -57,9 +57,10 @@ def main():
     resp = client.get_log(project=project, logstore=log_store, from_time=start_timestamp, to_time=end_timestamp, query=query_sql)
     log_data = resp.get_body().get('data')
 
-    crawler_mode_set = set()
+    crawler_mode_set = []
     for datum in log_data:
-        crawler_mode_set.add(datum.get('crawlerMode'))
+        if datum.get('crawlerMode') not in crawler_mode_set:
+            crawler_mode_set.append(datum.get('crawlerMode'))
 
     for crawler_mode in crawler_mode_set:
         title = f"【自动化供给】日任务执行情况监控 -- {crawler_mode}"
@@ -74,7 +75,6 @@ def main():
             content += f"| {reason} | {video_id_cnt} | {crawler_plan_id_cnt} |\n"
 
         send_feishu_card_msg(title, content)
-        break
 
 
 if __name__ == "__main__":