閱讀1140 返回首頁    go 小米 go 小米5

消息通知__操作指南_批量計算-阿裏雲

消息通知

批量計算服務（BatchCompute）使用MNS提供的主題模式來實現消息通知。用戶負責主題（Topic）的創建、管理和訂閱，並在使用BatchCompute創建集群或提交作業時指定主題相關的配置。BatchCompute依據配置向指定用戶主題推送消息。用戶可在MNS控製台配置URL、隊列、郵件和短信四種方式獲取消息通知。

1. 前期準備

(1) 開通消息服務

(2) 創建MNS主題

(3) 創建MNS主題訂閱

(4) 授權BatchCompute推送消息

請登錄控製台上進行一鍵授權。如果沒有授權過，控製台導航條下麵會出現這個提示:tu如果已經授權過請忽略本條。

2. 計費相關

消息通知產生的費用統一由消息服務結算，批量計算不再額外收取。

3. 創建BatchCompute集群

使用SDK或控製台創建集群（cluster）時，可以配置如下類型消息事件（AutoCluster類型作業不支持消息通知）。

  1. {
  2.     "Notification": {
  3.         "Topic": {
  4.             "Name": "test-topic",
  5.             "Endpoint": "https://[UserId].mns.[Region].aliyuncs.com/", 
  6.             "Categories": [
  7.                 "OnClusterDeleted",
  8.                 "OnInstanceCreated",
  9.                 "OnInstanceActive"
  10.             ]
  11.         }
  12.     }
  13. }
字段 說明
Name MNS主題名稱
Endpoint MNS私網Endpoint，如何獲取Endpoint。

4. 提交BatchCompute作業

使用SDK或控製台創建作業（job）時，可以配置如下類型消息事件。

  1. {
  2.     "Notification": {
  3.         "Topic": {
  4.             "Name": "test-topic",
  5.             "Endpoint": "https://[UserId].mns.[Region].aliyuncs.com/",
  6.             "Categories": [
  7.                 "OnJobWaiting",
  8.                 "OnJobRunning",
  9.                 "OnJobStopped",
  10.                 "OnJobFinished",
  11.                 "OnJobFailed",
  12.                 "OnTaskWaiting",
  13.                 "OnTaskRunning",
  14.                 "OnTaskStopped",
  15.                 "OnTaskFinished",
  16.                 "OnTaskFailed",
  17.                 "OnInstanceWaiting",
  18.                 "OnInstanceRunning",
  19.                 "OnInstanceStopped",
  20.                 "OnInstanceFinished",
  21.                 "OnInstanceFailed",
  22.                 "OnPriorityChange"
  23.             ]
  24.         }
  25.     }
  26. }
字段 說明
Name MNS主題名稱
Endpoint MNS私網Endpoint，如何獲取Endpoint。

5. 事件消息格式

消息格式目前支持json string。

  • 集群事件

適用於OnClusterDeleted

  1.  {
  2.     "Category": "Cluster",
  3.     "ClusterId": "cls-hr2rbl6qt5gki7392b8001",
  4.     "ClusterName": "test-cluster",
  5.     "CreationTime": "2016-11-01T15:25:02.837728Z",
  6.     "State": "Deleted",
  7.     "Event": "OnClusterDeleted"
  8. }

適用於OnInstanceCreated/OnInstanceActive

  1. {
  2.     "Category": "Cluster",
  3.     "ClusterId": "cls-hr2rbl6qt5gki7392b8001",
  4.     "Group": "group1",
  5.     "InstanceId": "i-wz9c51g2s6zsrtnqi4fa",
  6.     "InnerIpAddress": "10.45.168.26",
  7.     "Hints": "",
  8.     "State": "Starting",
  9.     "CreationTime": "2016-11-01T15:25:02.837728Z",
  10.     "Event": "OnInstanceCreated"
  11. }
  • 作業事件

適用於OnJobWaiting/OnJobRunning/OnJobStopped/OnJobFinished/OnJobFailed

  1. {
  2.     "Category": "Job",
  3.     "JobId": "job-0000000058524720000077E900007257",
  4.     "JobName": "test-job",
  5.     "Event": "OnJobWaiting",
  6.     "State": "Waiting",
  7.     "CreationTime": "2016-11-01T15:25:02.837728Z",
  8.     "StartTime": "2016-11-01T15:35:02.837728Z",
  9.     "EndTime": "2016-11-01T15:45:02.837728Z",
  10.     "Message": ""
  11. }

適用於OnTaskWaiting/OnTaskRunning/OnTaskStopped/OnTaskFinished/OnTaskFailed

  1. {
  2.     "Category": "Job",
  3.     "JobId": "job-0000000058524720000077E900007257",
  4.     "Task": "Echo",
  5.     "Event": "OnTaskWaiting",
  6.     "State": "Waiting",
  7.     "StartTime": "2016-11-01T15:35:02.837728Z",
  8.     "EndTime": "2016-11-01T15:45:02.837728Z"
  9. }

適用於OnInstanceWaiting/OnInstanceRunning/OnInstanceStopped/OnInstanceFinished/OnInstanceFailed

  1. {
  2.     "Category": "Job",
  3.     "JobId": "job-0000000058524720000077E900007257",
  4.     "Task": "Echo",
  5.     "InstanceId": "0",
  6.     "Event": "OnInstanceWaiting",
  7.     "State": "Waiting",
  8.     "StartTime": "2016-11-01T15:35:02.837728Z",
  9.     "EndTime": "2016-11-01T15:45:02.837728Z",
  10.     "RetryCount": "0",
  11.     "Progress": "0",
  12.     "StdoutRedirectPath": "oss://bucket/tests/a44c0ad8-a003-11e6-8f8e-fefec0a80e06/logs/stderr.job-0000000058184218000008150000000D.task.0",
  13.     "StderrRedirectPath": "oss://bucket/tests/a44c0ad8-a003-11e6-8f8e-fefec0a80e06/logs/stdout.job-0000000058184218000008150000000D.task.0",
  14.     "ExitCode": "0",
  15.     "ErrorCode": "",
  16.     "ErrorMessage": "",
  17.     "Detail": ""
  18. }

適用於OnPriorityChange

  1. {
  2.     "Category": "Job",
  3.     "JobId": "job-0000000058524720000077E900007257",
  4.     "JobName": "test-job",
  5.     "Event": "OnPriorityChange",
  6.     "State": "Waiting",
  7.     "CreationTime": "2016-11-01T15:45:02.837728Z",
  8.     "StartTime": "2016-11-01T15:55:02.837728Z",
  9.     "EndTime": "2016-11-01T15:57:02.837728Z",
  10.     "Message": "",
  11.     "From": "10",
  12.     "To": "20"
  13. }

最後更新：2016-12-19 14:11:28

  上一篇：go Docker鏡像製作__Docker_操作指南_批量計算-阿裏雲
  下一篇：go 作業管理__控製台使用指南_批量計算-阿裏雲