|
@@ -23,10 +23,9 @@ def check_origin_hive(args):
|
|
|
exit(1)
|
|
exit(1)
|
|
|
else:
|
|
else:
|
|
|
# print('存在 数据 size：', count)
|
|
# print('存在 数据 size：', count)
|
|
|
- # todo 发送阿里云读取到数据通知开始执行下一步骤
|
|
|
|
|
bot = FeishuBot()
|
|
bot = FeishuBot()
|
|
|
- msg = (f'推荐模型数据更新 \n step1【校验hive数据源】【success】:\n'
|
|
|
|
|
- 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)
|
|
bot.send_message(msg)
|
|
|
print("0")
|
|
print("0")
|
|
|
|
|
|
Joe