批量计算 事件通知和回调 - 用户指南

概要信息

批量计算（Batch）支持将作业和计算环境内产生的事件以消息服务（CMQ）的形式抛出，例如作业运行成功/失败、计算环境节点创建成功/失败/异常等事件发生，可以通过 CMQ 的主题订阅机制来实现通知和回调。

使用指南

下面以监听计算环境相关事件为例，您可以通过以下三个步骤将一个计算环境相关的事件注册。

1. 创建 CMQ 主题

登录 消息服务 CMQ 控制台，新建一个主题。

2. 创建计算环境并关联 CMQ 主题

在提交作业（SubmitJob）或者创建计算环境（Create）时添加 notifications 字段并指定要监听的事件 event_name，支持指定多个事件。

"notifications": [
    {
      "event_configs": [
        {
          "event_name": "JobFailed" // 事件名称
        },
        {
          "event_name": "JobSucceed",
          "event_vars": [           // 自定义事件参数
            {
              "name": "jobSucceed",
              "value": "Success"
            }
          ]
        }
      ],
      "topic_name": "job-message"   // CMQ Topic Name
    }
  ],

• 目前仅支持通过 API 或者 CLI 创建计算环境时关联 CMQ 主题，后续将支持控制台操作。
• event_vars：除了事件产生的固定消息本体外，还支持添加自定义参数。
• topic_name：关联的 CMQ 主题的 Name（注意：不是 ID），所有事件消息将投递给该主题，主题再将消息转发给所有订阅者。

3. 设置订阅者并测试

在 消息服务 CMQ 控制台 为新建的主题添加订阅者，为方便快速查看，可以指定为已经创建的一个消息队列。

消息结构如下，如果订阅者中指定了消息队列，可以通过 消息服务 CMQ 控制台 - 消息接收 快速查看由 Batch 发送到主题内的事件消息（消息接收内消息内容需要 Base64 处理）。

{
    "Events": [{
        "EventVersion": "1.0",
        "EventTime": "2018-06-15T14:43:17Z",
        "Region": "ap-guangzhou",
        "Batch": {
            "ComputeNodeId": "node-0iy7wxyo",
            "EnvId": "env-ptoxdb1t",
            "ComputeNodeState": "CREATED",
            "Mem": 8,
            "ResourceCreatedTime": "2018-06-15T14:43:18Z",
            "EnvName": "batch-env",
            "ComputeNodeInstanceId": "ins-9rikj9kw",
            "Cpu": 4
        },
        "EventName": "COMPUTE_NODE_CREATED",
        "EventVars": []
    }]
}

作业相关事件

最新定义和提交作业 API Demo，请参见 提交作业 >>

计算环境相关事件

最新定义和创建计算环境 API Demo，请参见 创建计算环境 >>。