来自 Zeppelin 笔记本的自动电子邮件警报

【问题标题】：Automatic email alerts from Zeppelin notebook来自 Zeppelin 笔记本的自动电子邮件警报
【发布时间】：2017-06-16 20:20:17
【问题描述】：

我是 Zeppelin 的新手，在发送这篇文章之前，我已经在网上进行了研究，但没有得到与我的要求相关的准确答案。

一旦我们的 Spark SQL 查询结果达到上控制级别或特定阈值，我们需要从 Zeppelin 笔记本发送自动电子邮件警报的要求之一？

我们的流程将在一小时内运行一次。

我们如何在 Zeppelin 中实现这一点，我们非常感谢任何建议或帮助

提前感谢您的时间和帮助！！！..。

【问题讨论】：

标签： apache-zeppelin

【解决方案1】：

我们可以使用 Zeppelin 中的 apache commons email library 使用下面的 SCALA 代码发送电子邮件

import org.apache.commons.mail._;
def Email(msg: String) =
{
 val email = new SimpleEmail();
      email.setHostName("webmail.abc.com"); //Emailbox URL
      email.setAuthenticator(new DefaultAuthenticator("emailalert@abc.com", "XXXXXXX")); //Userid, Password
      email.setFrom("emailalert@abc.com"); //FROM
      email.setSubject("Email Send from Zeppelin"); //SUBJECT
      email.setMsg(msg); //Email Message 
      email.addTo("emailalert@abc.com"); //TO
      email.send()
}            

 Email("Count exceeded above threshold value 1500")

甚至需要包含以下依赖项才能工作

依赖关系

神器：

1) org.apache.commons:commons-email:1.4 2) javax.mail:mail:1.4

排除

1) com.sun.mail:javax.mail:1.5.2

【讨论】：