我已经创建了外部配置单元表,它是从文本文件加载的。每当表有重复记录时,我就必须向特定的dl发送电子邮件通知。是否可以从配置单元查询发送电子邮件?如果不是,我们可以使用python自定义项吗?
我使用了下面的配置单元查询来捕获重复的记录
insert overwrite table table_dup
select col1,col2, count(1) as cnt from main_table
group by col1,col2 having cnt > 1;
下面的python udf将用于抛出错误消息:
for line in sys.stdin:
if line:
raise DuplicateRecError("Duplicate recs found and find details in table_dup")
else:
continue
我使用的是ibmtivolijobscheduler而不是oozie。在这种情况下,从配置单元查询或通过python udf发送电子邮件哪个更好?
提前谢谢。
暂无答案!
目前还没有任何答案,快来回答吧!