批量计算使用 MNS 来实现消息通知。您负责主题的创建、管理和订阅,并在创建集群或提交作业时指定相关配置。批量计算会依据配置向指定的主题推送消息,您可在 MNS 控制台配置 URL、队列、邮件和短信四种方式获取消息通知。
目前批量计算支持两类事件,您可以按需配置:
OnClusterDeleted
;OnInstanceCreated
;OnInstanceActive
;OnJobWaiting
;OnJobRunning
;OnJobStopped
;OnJobFinished
;OnJobFailed
;OnTaskWaiting
;OnTaskRunning
;OnTaskStopped
;OnTaskFinished
;OnTaskFailed
;OnInstanceWaiting
;OnInstanceRunning
;OnInstanceStopped
;OnInstanceFinished
;OnInstanceFailed
;OnPriorityChange
。适用于 OnClusterDeleted
。
{
"Category": "Cluster",
"ClusterId": "cls-hr2rbl6qt5gki7392b8001",
"ClusterName": "test-cluster",
"CreationTime": "2016-11-01T15:25:02.837728Z",
"State": "Deleted",
"Event": "OnClusterDeleted"
}
适用于 OnInstanceCreated
、OnInstanceActive
。
{
"Category": "Cluster",
"ClusterId": "cls-hr2rbl6qt5gki7392b8001",
"Group": "group1",
"InstanceId": "i-wz9c51g2s6zsrtnqi4fa",
"InnerIpAddress": "10.45.168.26",
"Hints": "",
"State": "Starting",
"CreationTime": "2016-11-01T15:25:02.837728Z",
"Event": "OnInstanceCreated"
}
适用于 OnJobWaiting
、OnJobRunning
、OnJobStopped
、OnJobFinished
、OnJobFailed
。
{
"Category": "Job",
"JobId": "job-0000000058524720000077E900007257",
"JobName": "test-job",
"Event": "OnJobWaiting",
"State": "Waiting",
"CreationTime": "2016-11-01T15:25:02.837728Z",
"StartTime": "2016-11-01T15:35:02.837728Z",
"EndTime": "2016-11-01T15:45:02.837728Z",
"Message": ""
}
适用于 OnTaskWaiting
、OnTaskRunning
、OnTaskStopped
、OnTaskFinished
、OnTaskFailed
。
{
"Category": "Job",
"JobId": "job-0000000058524720000077E900007257",
"Task": "Echo",
"Event": "OnTaskWaiting",
"State": "Waiting",
"StartTime": "2016-11-01T15:35:02.837728Z",
"EndTime": "2016-11-01T15:45:02.837728Z"
}
适用于 OnInstanceWaiting
、OnInstanceRunning
、OnInstanceStopped
、OnInstanceFinished
、OnInstanceFailed
。
{
"Category": "Job",
"JobId": "job-0000000058524720000077E900007257",
"Task": "Echo",
"InstanceId": "0",
"Event": "OnInstanceWaiting",
"State": "Waiting",
"StartTime": "2016-11-01T15:35:02.837728Z",
"EndTime": "2016-11-01T15:45:02.837728Z",
"RetryCount": "0",
"Progress": "0",
"StdoutRedirectPath": "oss://bucket/tests/a44c0ad8-a003-11e6-8f8e-fefec0a80e06/logs/stderr.job-0000000058184218000008150000000D.task.0",
"StderrRedirectPath": "oss://bucket/tests/a44c0ad8-a003-11e6-8f8e-fefec0a80e06/logs/stdout.job-0000000058184218000008150000000D.task.0",
"ExitCode": "0",
"ErrorCode": "",
"ErrorMessage": "",
"Detail": ""
}
适用于 OnPriorityChange
。
{
"Category": "Job",
"JobId": "job-0000000058524720000077E900007257",
"JobName": "test-job",
"Event": "OnPriorityChange",
"State": "Waiting",
"CreationTime": "2016-11-01T15:45:02.837728Z",
"StartTime": "2016-11-01T15:55:02.837728Z",
"EndTime": "2016-11-01T15:57:02.837728Z",
"Message": "",
"From": "10",
"To": "20"
}
使用消息队列必须同时指定 MNS 主题名称 (Name)、MNS 私网 Endpoint (Endpoint) 和关注的事件 (Events)。
以下我们将展示通过 SDK 展示如何使用 MNS 消息队列,其中 MNS 主题名称为test
,MNS私网 Endpoint 为http://xxx.mns.cn-beijing.aliyuncs.com/
,关注的事件为OnClusterDeleted
、OnInstanceCreated
和OnInstanceActive
。
from batchcompute.resources import (
ClusterDescription, Notification, Topic
)
cluster_desc = ClusterDescription()
notification = Notification()
topic = Topic()
topic.Name = 'test'
topic.Endpoint = 'http://xxx.mns.cn-beijing.aliyuncs.com/'
topic.Events = ["OnClusterDeleted", "OnInstanceCreated", "OnInstanceActive"]
notification.Topic = topic
cluster_desc.Notification = notification
操作场景 本文以 云服务器 的操作系统为“Windows Server 2008 R2 Standard 64bi...
jwEngine 一个跨平台的c++-lua服务器快速解决方案,该框架即可快速响应服务器开...
背景 根据 一篇报道 显示,golang 成为继 python 之后最受黑客欢迎的工具语言。...
10月1日起,《在线旅游经营服务管理暂行规定》(下称《规定》)正式施行。根据新规...
目录 一、前言 二、架构演变 1. 单体架构 2. 应用与数据库分离 3. 使用缓存抗量 ...
公司 邮箱 能在手机上收取吗?可以的。公司邮箱通常指的就是公司 企业邮箱 ,大...
12月14日消息,市场研究机构Gartner指出,基础设施和运营(IO)领导者在未来12至18...
通过云助手,您无需逐一登录ECS实例进行运维操作,只需编写可以查询系统配置的云...
客户简介 WeWork作为全球领先的空间、社区及服务提供商,于2010年创立于纽约,致...
一、自我介绍 我是来自上海某高校的服务器小白,暂且称呼我为小C吧...就读软件工...