如何从apache配置单元查询发送电子邮件通知?

r7s23pms  于 2021-05-29  发布在  Hadoop
关注(0)|答案(0)|浏览(238)

我已经创建了外部配置单元表,它是从文本文件加载的。每当表有重复记录时,我就必须向特定的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发送电子邮件哪个更好?
提前谢谢。

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题