来自 Zeppelin notebook 的自动电子邮件提醒

Question

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

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

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

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

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

Answer 1

我们可以使用 Zeppelin 中的 apache commons 电子邮件库使用以下 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:邮件:1.4

排除

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

来自 Zeppelin notebook 的自动电子邮件提醒

Automatic email alerts from Zeppelin notebook

apache-zeppelin