Browse Source

feat:修改SLS SQL

zhaohaipeng 2 tháng trước cách đây
mục cha
commit
6ca58995c1
1 tập tin đã thay đổi với 1 bổ sung1 xóa
  1. 1 1
      monitor/automation_provide_job_monitor.py

+ 1 - 1
monitor/automation_provide_job_monitor.py

@@ -12,7 +12,7 @@ access_key = "RfSjdiWwED1sGFlsjXv0DlfTnZTG1P"
 access_key_id = "LTAIWYUujJAm7CbH"
 project = "crawler-scheduler"
 log_store = "aigc-provider"
-state_query_sql = "* | select crawlerMode, result, if(reason='null', '成功', reason) as reason, count(distinct videoId) as videoIdCnt, count(distinct crawlerPlanId) as crawlerPlanIdCnt  from log where reason not in ('该账号已经存在爬取计划,跳过执行', '该视频近期已经处理过', '该Topic已经创建过爬取计划', '该关键词已经创建过爬取计划') group by crawlerMode, result, reason order by crawlerMode, result desc, reason"
+state_query_sql = "* | set session mode = scan; select crawlerMode, result, if(reason='null', '成功', reason) as reason, count(distinct videoId) as videoIdCnt, count(distinct crawlerPlanId) as crawlerPlanIdCnt  from log where reason not in ('该账号已经存在爬取计划,跳过执行', '该视频近期已经处理过', '该Topic已经创建过爬取计划', '该关键词已经创建过爬取计划') group by crawlerMode, result, reason order by crawlerMode, result desc, reason"
 
 client = LogClient(endpoint=endpoint, accessKey=access_key, accessKeyId=access_key_id, auth_version=AUTH_VERSION_4, region='cn-hangzhou')
 webhook = 'https://open.feishu.cn/open-apis/bot/v2/hook/9f5c5cce-5eb2-4731-b368-33926f5549f9'