Joe 9 mesi fa
parent
commit
98b2c36f11
2 ha cambiato i file con 3 aggiunte e 2 eliminazioni
  1. 1 1
      qiaojialiang/FeishuBot.py
  2. 2 1
      qiaojialiang/checkHiveDataUtil.py

+ 1 - 1
qiaojialiang/FeishuBot.py

@@ -2,7 +2,7 @@ import requests
 
 
 class FeishuBot:
-    webhook_url = "https://open.feishu.cn/open-apis/bot/v2/hook/842434bd-516b-4e0d-86d5-8e14b5a15346"
+    webhook_url = "https://open.feishu.cn/open-apis/bot/v2/hook/926982f5-e7af-40f5-81fd-27d8f42718e4"
 
     def send_message(self, message_text):
         headers = {'Content-Type': 'application/json'}

+ 2 - 1
qiaojialiang/checkHiveDataUtil.py

@@ -25,7 +25,8 @@ def check_origin_hive(args):
         # print('存在 数据 size:', count)
         # todo 发送阿里云读取到数据通知开始执行下一步骤
         bot = FeishuBot()
-        msg = f'读取{project}.{table},分区:dt= {partitionDt}/hh={partitionHh},数据总量:{count}'
+        msg = (f'推荐模型数据更新 \n step1【校验hive数据源】【success】:\n'
+               f'读取{project}.{table},分区:dt= {partitionDt}/hh={partitionHh},数据总量:{count}')
         bot.send_message(msg)
         print("0")