将Oozie作业状态告警从邮件切换至Slack告警的实现方案咨询

Oozie原生没有内置Slack告警Action，需要通过自定义Shell脚本结合Shell Action替代原有的Email Action，具体步骤如下：

1. 编写Slack告警Shell脚本 #

创建一个Shell脚本，通过Slack Incoming Webhook API发送告警消息，脚本可接收作业状态、作业ID、详情等参数。

示例脚本（命名为slack_alert.sh）：

#!/bin/bash
# 替换为你的Slack Incoming Webhook地址
SLACK_WEBHOOK_URL="https://hooks.slack.com/services/XXXXXX/XXXXXX/XXXXXXXXXXXXXXXXXXXXXXXX"

# 接收传入的参数：作业状态、作业ID、告警详情
JOB_STATUS=$1
JOB_ID=$2
ALERT_DETAIL=$3

# 构造Slack消息并发送
curl -X POST \
  -H "Content-Type: application/json" \
  -d "{
        \"text\": \"Oozie作业告警通知\n作业ID: $JOB_ID\n状态: *$JOB_STATUS*\n详情: $ALERT_DETAIL\"
      }" \
  $SLACK_WEBHOOK_URL

2. 上传脚本到HDFS #

将脚本上传到Oozie可访问的HDFS路径，并设置执行权限：

hdfs dfs -put slack_alert.sh /user/oozie/scripts/
hdfs dfs -chmod 755 /user/oozie/scripts/slack_alert.sh

3. 替换Workflow中的Email Action为Shell Action #

将原有的<email>节点替换为<shell>节点，配置调用Slack告警脚本，并传递必要参数。

原Email Action配置示例 #

<email xmlns="uri:oozie:email-action:0.1">
    <to>alerts@example.com</to>
    <subject>Oozie Job ${wf:id()} ${wf:status()}</subject>
    <body>Job ${wf:id()} finished with status ${wf:status()}. Error: ${wf:errorMessage()}</body>
</email>

替换后的Slack Shell Action配置示例 #

<action name="slack-alert">
    <shell xmlns="uri:oozie:shell-action:0.3">
        <job-tracker>${jobTracker}</job-tracker>
        <name-node>${nameNode}</name-node>
        <exec>/user/oozie/scripts/slack_alert.sh</exec>
        <!-- 传递作业状态、作业ID、错误详情参数 -->
        <argument>${wf:status()}</argument>
        <argument>${wf:id()}</argument>
        <argument>${wf:errorMessage()}</argument>
        <!-- 将脚本分发到执行节点 -->
        <file>/user/oozie/scripts/slack_alert.sh#slack_alert.sh</file>
    </shell>
    <ok to="end"/>
    <error to="end"/>
</action>

4. 配置告警触发时机 #

根据业务需求，在作业成功、失败或终止时触发Slack告警，可通过<decision>节点判断作业状态，或在<kill>节点后添加告警动作。

示例：通过决策节点判断状态触发告警

<decision name="check-job-status">
    <switch>
        <case to="slack-alert">${wf:status() eq 'FAILED'}</case>
        <case to="slack-alert">${wf:status() eq 'SUCCEEDED'}</case>
        <default to="end"/>
    </switch>
</decision>

<!-- 主作业执行节点 -->
<action name="main-job">
    <map-reduce>
        <!-- 你的作业配置 -->
    </map-reduce>
    <ok to="check-job-status"/>
    <error to="check-job-status"/>
</action>

<end name="end"/>

注意事项 #

• Slack Webhook配置：需在Slack工作区创建Incoming Webhook集成，获取对应的Webhook URL。
• 网络权限：确保Oozie集群节点能访问Slack的Webhook地址，若集群有网络代理，需在curl命令中添加代理参数（如--proxy http://proxy:port）。
• 脚本权限：HDFS上的脚本需设置可执行权限，保证Oozie能调用执行。

内容的提问来源于stack exchange，提问作者Franklin Rajasekar