Oozie操作篇--Oozie Email action 配置Oozie發送郵件

-Advertisement-

Oozie Email Action 配置 Shell Action 可以用來為oozie中的流程任務發送郵件，Email Action 必須配置 to收件人，cc收件人（可選），郵件主題，郵件內容，多個收件人可以使用，分割收件人地址。Email Action是同步執行的，流程任務必須等當前節點的郵 ...

Oozie Email Action 配置

Shell Action 可以用來為oozie中的流程任務發送郵件，Email Action 必須配置 to收件人，cc收件人（可選），郵件主題，郵件內容，多個收件人可以使用，分割收件人地址。
Email Action是同步執行的，流程任務必須等當前節點的郵件發送完成之後才能執行後續節點任務。
Email Action 所有的節點值都可以使用EL表達式

Email Action格式

12345678910111213141516

<workflow-app name="[WF-DEF-NAME]" xmlns="uri:oozie:workflow:0.1">    ...    <action name="[NODE-NAME]">        <email xmlns="uri:oozie:email-action:0.2">            <to>[COMMA-SEPARATED-TO-ADDRESSES]</to>            <cc>[COMMA-SEPARATED-CC-ADDRESSES]</cc> <!-- cc is optional -->            <subject>[SUBJECT]</subject>            <body>[BODY]</body>            <content_type>[CONTENT-TYPE]</content_type> <!-- content_type is optional -->            <attachment>[COMMA-SEPARATED-HDFS-FILE-PATHS]</attachment> <!-- attachment is optional -->        </email>        <ok to="[NODE-NAME]"/>        <error to="[NODE-NAME]"/>    </action>    ...</workflow-app>

to 和 cc 命令都用來指定郵件的收件人，多個收件人地址用逗號分割，to 必須有，cc可選
subject 指定郵件標題，body指定郵件內容可以指定郵件內容格式（content type）為 "text/html"，預設是"text/plain"
attachment 用來指定 hdfs中的文件作為附件，多個文件逗號分割,非完全路徑（不是以hdfs://開頭的路徑）預設為hdfs上的路徑，不能使用本地文件作為附件。

Oozie Email 配置 oozie-site.xml中加入郵件伺服器和發件人信息，如果使用smtp協議必須開通<property> <name>oozie.email.smtp.host</name> <value>smtp.qq.com</value></property><property> <name>oozie.email.smtp.port</name> <value>587</value></property><property> <name>oozie.email.from.address</name> <value>******@qq.com</value></property><property> <name>oozie.email.smtp.auth</name> <value>true</value></property><property> <name>oozie.email.smtp.username</name> <value>******@qq.com</value></property><property> <name>oozie.email.smtp.password</name> <value>******</value></property>Email Action 使用實例一：Oozie自帶案例運行1,新建 job.properties

12345

nameNode=hdfs://hadoop-node1.novalocal:8020jobTracker=hadoop-node1.novalocal:8050queueName=defaultexamplesRoot=xwj_testoozie.wf.application.path=${nameNode}/user/oozie/${examplesRoot}/apps/shell/email/workflow.xml

2,workflow.xml

1234567891011121314151617

<workflow-app xmlns="uri:oozie:workflow:0.4" name="email-wf">    <start to="email-node"/>    <action name="email-node">        <email xmlns="uri:oozie:email-action:0.1">            <to>[email protected]</to>            <cc>[email protected]</cc>            <subject>Email notifications for ${wf:id()}</subject>            <body>The wf ${wf:id()} successfully completed.</body>        </email>        <ok to="end"/>        <error to="fail"/>    </action>    <kill name="fail">        <message>Shell action failed, error message[${wf:errorMessage(wf:lastErrorNode())}]</message>    </kill>   <end name='end' /></workflow-app>

3，首先在本地的測試節點上創建文件夾 mkdir -p /opt/mydata/user/oozie/xwj_test/apps/shell/email4，在hdfs上創建目錄 hdfs dfs -mkdir -p /user/oozie/xwj_test/apps/shell/email5，將上述文件上傳到新建好的目錄中cd /opt/mydata/user/oozie/xwj_test/apps/shell/email

6，將本地文件上傳到hdfs目錄中hdfs dfs -put ../email/* /user/oozie/xwj_test/apps/shell/email7，查看hdfs上的目錄文件是否存在 hdfs dfs -ls -r /user/oozie/xwj_test/apps/shell/email

8，切換yarn用戶重新提交任務su yarn oozie job -oozie http://hadoop-node0.novalocal:11000/oozie -config /opt/mydata/user/oozie/xwj_test/apps/shell/email/job.properties -run查看郵件結果

您的分享是我們最大的動力!

-Advertisement-

更多相關文章

[HBase Manual]CH5 HBase運行模式：單實例和分散式

HBase運行模式：單實例和分散式 HBase運行模式：單實例和分散式... 1 1.單實例模式... 1 1.1 單實例在HDFS下... 1 2.分散式... 1 2.1 偽分散式... 1 3完全分散式... 1 HBase有2種運行模式，單實例和分散式。 1.單實例模式這個是預設的模式。單 ...
安裝及配置mysql-5.7.21-winx64

恢復內容開始之前在安裝mysql時也遇到了一些問題,再網上找了一些安裝教程,現在把主要步驟記錄下來以防以後用到時忘了! 小白一個,不喜勿噴哦!! 1.到官網下載http://dev.mysql.com/downloads/mysql/(註意別選錯了) 2.直接解壓就可以了(註意:解壓的位置就是你m ...
對oracle資料庫使用的小結

使用資料庫為oracle 因為在將數據從歷史表導入當前表時，因欄位個數不對，導致不能導數據。一、將歷史表的欄位增加一個或者多個的SQL語句。 1、增加一個欄位：（增加欄位時，只能排在已有欄位的後面，不能插到已有欄位之間） Alter Table t_app_si_addr_12 Add CHG_A ...
T-SQL語法學習一（持續更新）

T SQL語法學習（一）第一節不常用語句不常用語句指的是一些不常用的查詢語句，不針對業務數據查詢 SET STATISTICS IO ON（用於查詢邏輯讀取次數，物理讀取次數）圖片 select @@version （查詢當前實例的資料庫版本）第二節操作資料庫管理工具註意事項當我們在 ...
oracle nid修改dbname

修改name的目的只是為了日後管理清晰點，不重覆。我比較懶、記性又差，所以就整理記下1、檢查當前nameSQL> show parameter nameNAME TYPE VALUE db_file_name_convert string db_name string test141db_uniqu ...
(Les14 備份與恢復的概念)[20180425]

目的確定Oracle DB中可能發生的故障類型說明優化實例恢復的方法說明檢查點，重做日誌文件和歸檔日誌文件的重要性配置快速恢復區配置ARCHIVEDLOG模式資料庫管理員的部分職責儘量避免資料庫出現故障延長平均故障間隔時間（MTBF）通過冗餘方式保護關鍵組件 -Real Appli ...
Oozie操作篇--Oozie Spark Action 配置Oozie調用spark程式

Oozie Spark Action 配置 Spark Action 用來運行spark 任務，流程任務必須等當前節點的spark任務執行完成之後才能執行後續節點任務。運行Spark Job，必須在 spark action裡面配置 job-tracer，name-node，master，和一些必要 ...
Oozie操作篇--Oozie Sqoop Action 配置Oozie調用sqoop命令

Oozie Sqoop Action 配置 Sqoop Action 用來運行sqoop 任務，流程任務必須等當前節點的sqoop任務執行完成之後才能執行後續節點任務。Email Action 所有的節點值都可以使用EL表達式運行Sqoop Job，必須在 sqoop action裡面配置 job- ...