|
@@ -25,7 +25,7 @@ def check_origin_hive(args):
|
|
|
# print('存在 数据 size：', count)
|
|
# print('存在 数据 size：', count)
|
|
|
# todo 发送阿里云读取到数据通知开始执行下一步骤
|
|
# todo 发送阿里云读取到数据通知开始执行下一步骤
|
|
|
bot = FeishuBot()
|
|
bot = FeishuBot()
|
|
|
- msg = f'读取project：${project},table：${table},分区：dt= ${partitionDt}/hh=${partitionHh},查询数据总量：${count}'
|
|
|
|
|
|
|
+ msg = f'读取{project}.{table},分区：dt= {partitionDt}/hh={partitionHh},数据总量：{count}'
|
|
|
bot.send_message(msg)
|
|
bot.send_message(msg)
|
|
|
print("0")
|
|
print("0")
|
|
|
|
|
|
Joe