@@ -1,11 +1,9 @@
import requests
+
class FeishuBot:
webhook_url = "https://open.feishu.cn/open-apis/bot/v2/hook/842434bd-516b-4e0d-86d5-8e14b5a15346"
- def __init__(self):
- self.webhook_url = self.webhook_url
-
def send_message(self, message_text):
headers = {'Content-Type': 'application/json'}
data = {
@@ -24,7 +24,7 @@ def check_origin_hive(args):
else:
# print('存在 数据 size:', count)
# todo 发送阿里云读取到数据通知开始执行下一步骤
- bot = FeishuBot
+ bot = FeishuBot()
msg = f'读取project:${project},table:${table},分区:dt= ${partitionDt}/hh=${partitionHh},查询数据总量:${count}'
bot.send_message(msg)
print("0")