本文介紹批次運算作為事件來源發布到事件匯流排EventBridge的事件類型。
事件類型
批次運算支援發布到事件匯流排EventBridge的事件類型如下所示。
事件類型 | type參數值 |
阿里雲平台對資源執行的操作事件 | batchcompute:ActionTrail:AliyunServiceEvent |
API調用 | batchcompute:ActionTrail:ApiCall |
控制台的操作事件 | batchcompute:ActionTrail:ConsoleOperation |
Cluster建立事件 | batchcompute:ClusterStateChange:ClusterCreated |
Cluster刪除事件 | batchcompute:ClusterStateChange:ClusterDeleted |
Cluster錯誤事件 | batchcompute:ClusterStateChange:ClusterError |
Cluster Rolling事件 | batchcompute:ClusterStateChange:ClusterRolling |
Instance Busy事件 | batchcompute:InstanceStateChange:InstanceBusy |
Instance建立事件 | batchcompute:InstanceStateChange:InstanceCreated |
Instance Preparing事件 | batchcompute:InstanceStateChange:InstancePreparing |
Instance已經Ready事件 | batchcompute:InstanceStateChange:InstanceReady |
Instance Released事件 | batchcompute:InstanceStateChange:InstanceReleased |
batchcompute:JobStateChange:JobCanceled | |
Job建立事件 | batchcompute:JobStateChange:JobCreated |
Job刪除事件 | batchcompute:JobStateChange:JobDeleted |
batchcompute:JobStateChange:JobFailed | |
batchcompute:JobStateChange:JobRunning | |
batchcompute:JobStateChange:JobSucceeded | |
batchcompute:JobStateChange:JobWaiting | |
Project建立事件 | batchcompute:ProjectStateChange:ProjectCreated |
Project刪除事件 | batchcompute:ProjectStateChange:ProjectDeleted |
CloudEvents規範中定義的參數解釋,請參見事件概述。
Job已取消事件
通過Job已取消事件,事件匯流排EventBridge接收到的樣本事件如下所示。
{
"datacontenttype": "application/json",
"aliyunaccountid": "123456789098****",
"aliyunpublishtime": "2021-01-08T15:25:03.083Asia/Shanghai",
"data": {
"Status": {
"EnqueueTime": "2021-02-07T18:16:29.081610969+08:00",
"State": "Canceled",
"CreateTime": "2021-02-07T18:16:29.081610969+08:00"
},
"Project": "test48351",
"OwnerId": "123456789098****",
"Definition": {
"MountPoints": [
{
"MountPath": "/home/input/",
"Name": "test"
}
],
"FailStrategy": {
"WaitingTimeout": 999
},
"Type": "Batch",
"Volumes": [
{
"OSS": {
"Bucket": "bcs-test-zb",
"Prefix": "blender-demo/scenes/splash279"
},
"Name": "test"
}
],
"Command": [
"python",
"startclient.py",
"invoke",
"{"action": "Convert", "parameters": "{\\"widthPixel\\": \\"256\\", \\"heightPixel\\": \\"256\\", \\"inputUri\\": \\"oss://bcs-test-zb/daemon_app_fast_test/input/sample2.jpg\\", \\"outputUri\\": \\"oss://bcs-test-zb/daemon_app_fast_test/output/\\"}", "requestid": "e419e112-9795-4f6d-a724-438f54ce****"}"
],
"Envs": {
},
"PackageUri": "oss://bcs-test-zb/daemon_app_fast_test/package/startclient.py",
"Runtimes": {
"JobQueue": "cls-0xQ83wAZvGVKCAaTGSU1V69****"
},
"Labels": {
},
"Resources": {
"memory": "1Gi",
"cpu": "1"
}
},
"JobId": "job-0xQ8VSTpk7HLXyjcdW97EQe****",
"Name": "e2e test"
},
"subject": "acs:batchcompute:cn-hangzhou:123456789098****:test48351/job-0w1JZb8SZ1DEsKbfP99T69t****",
"specversion": "1.0",
"aliyuneventbusname": "default",
"id": "2BF-0w33xE0ZMwZJCh7aat7lEIM****",
"source": "acs.batchcompute",
"time": "2021-01-08T15:25:03Z",
"type": "batchcompute:JobStateChange:JobCancled",
"aliyunpublishaddr": "172.20.XX.XX"
}
data欄位包含的參數解釋如下表所示。
參數 | 類型 | 樣本值 | 描述 |
Status | Struct | 作業狀態資訊。 | |
EnqueueTime | String | 2021-02-07T18:16:29.081610969+08:00 | 作業入隊時間。 |
State | String | Canceled | 作業狀態。 |
CreateTime | String | 2021-02-07T18:16:29.081610969+08:00 | 作業建立時間。 |
Project | String | test48351 | 專案名稱。 |
OwnerId | String | 123456789098**** | 資源擁有者。 |
Definition | Struct | 作業描述資訊。 | |
MountPoints | Struct | 掛載目的點資訊。 | |
MountPath | String | /home/input/ | 掛載後本地的目錄路徑。 |
Name | String | test | 掛載後本地顯示的檔案名稱。 |
FailStrategy | Struct | 失敗策略。 | |
WaitingTimeout | String | 999 | 等待時間。 |
Type | String | Batch | 作業類型。 |
Volumes | Struct | 掛載點資訊。 | |
OSS | Struct | 阿里雲Object Storage Service。 | |
Bucket | String | bcs-test-zb | Bucket名稱。 |
Prefix | String | blender-demo/scenes/splash279 | Bucket下的目錄名。 |
Name | String | test | Bucket下的檔案名稱。 |
Command | String |
| 作業需要啟動並執行Shell命令。 |
Envs | Struct | 作業啟動並執行環境變數。請根據實際情況自訂。 | |
PackageUri | String | oss://bcs-test-zb/daemon_app_fast_test/package/startclient.py | OSS資源的下載連結。 |
Runtimes | Struct | 作業運行過程中的部分資訊。 | |
JobQueue | String | cls-0xQ83wAZvGVKCAaTGSU1V69**** | 作業隊列的名稱。 |
Labels | Struct | 索引值對。請根據實際情況自訂。 | |
Resources | Struct | 作業運行時需要的資源。 | |
memory | String | 1 Gi | CPU記憶體。 |
cpu | String | 1 | CPU個數。 |
JobId | String | job-0xQ8VSTpk7HLXyjcdW97EQe**** | 作業標示符。 |
Name | String | e2e test | 作業名稱。 |
Job失敗事件
通過Job失敗事件,事件匯流排EventBridge接收到的樣本事件如下所示。
{
"datacontenttype": "application/json",
"aliyunaccountid": "123456789098****",
"aliyunpublishtime": "2021-01-08T15:25:03.083Asia/Shanghai",
"data": {
"Status": {
"EnqueueTime": "2021-02-07T18:16:29.081610969+08:00",
"State": "Failed",
"CreateTime": "2021-02-07T18:16:29.081610969+08:00"
},
"Project": "test48351",
"OwnerId": "123456789098****",
"Definition": {
"MountPoints": [
{
"MountPath": "/home/input/",
"Name": "test"
}
],
"FailStrategy": {
"WaitingTimeout": 999
},
"Type": "Batch",
"Volumes": [
{
"OSS": {
"Bucket": "bcs-test-zb",
"Prefix": "blender-demo/scenes/splash279"
},
"Name": "test"
}
],
"Command": [
"python",
"startclient.py",
"invoke",
"{"action": "Convert", "parameters": "{\\"widthPixel\\": \\"256\\", \\"heightPixel\\": \\"256\\", \\"inputUri\\": \\"oss://bcs-test-zb/daemon_app_fast_test/input/sample2.jpg\\", \\"outputUri\\": \\"oss://bcs-test-zb/daemon_app_fast_test/output/\\"}", "requestid": "e419e112-9795-4f6d-a724-438f54ce****"}"
],
"Envs": {
},
"PackageUri": "oss://bcs-test-zb/daemon_app_fast_test/package/startclient.py",
"Runtimes": {
"JobQueue": "cls-0xQ83wAZvGVKCAaTGSU1V69****"
},
"Labels": {
},
"Resources": {
"memory": "1Gi",
"cpu": "1"
}
},
"JobId": "job-0xQ8VSTpk7HLXyjcdW97EQe****",
"Name": "e2e test"
},
"subject": "acs:batchcompute:cn-hangzhou:123456789098****:test48351/job-0w1JZb8SZ1DEsKbfP99T69t****",
"specversion": "1.0",
"aliyuneventbusname": "default",
"id": "2BF-0w33xE0ZMwZJCh7aat7lEIM****",
"source": "acs.batchcompute",
"time": "2021-01-08T15:25:03Z",
"type": "batchcompute:JobStateChange:JobFailed",
"aliyunpublishaddr": "172.20.XX.XX"
}
data欄位包含的參數解釋如下表所示。
參數 | 類型 | 樣本值 | 描述 |
Status | Struct | 作業狀態資訊。 | |
EnqueueTime | String | 2021-02-07T18:16:29.081610969+08:00 | 作業入隊時間。 |
State | String | Failed | 作業狀態。 |
CreateTime | String | 2021-02-07T18:16:29.081610969+08:00 | 作業建立時間。 |
Project | String | test48351 | 專案名稱。 |
OwnerId | String | 123456789098**** | 資源擁有者。 |
Definition | Struct | 作業描述資訊。 | |
MountPoints | Struct | 掛載目的點資訊。 | |
MountPath | String | /home/input/ | 掛載後本地的目錄路徑。 |
Name | String | test | 掛載後本地顯示的檔案名稱。 |
FailStrategy | Struct | 失敗策略。 | |
WaitingTimeout | String | 999 | 等待時間。 |
Type | String | Batch | 作業類型。 |
Volumes | Struct | 掛載點資訊。 | |
OSS | Struct | 阿里雲Object Storage Service。 | |
Bucket | String | bcs-test-zb | Bucket名稱。 |
Prefix | String | blender-demo/scenes/splash279 | Bucket下的目錄名。 |
Name | String | test | Bucket下的檔案名稱。 |
Command | String |
| 作業需要啟動並執行Shell命令。 |
Envs | Struct | 作業啟動並執行環境變數。請根據實際情況自訂。 | |
PackageUri | String | oss://bcs-test-zb/daemon_app_fast_test/package/startclient.py | OSS資源的下載連結。 |
Runtimes | Struct | 作業運行過程中的部分資訊。 | |
JobQueue | String | cls-0xQ83wAZvGVKCAaTGSU1V69**** | 作業隊列的名稱。 |
Labels | Struct | 索引值對。請根據實際情況自訂。 | |
Resources | Struct | 作業運行時需要的資源。 | |
memory | String | 1 Gi | CPU記憶體。 |
cpu | String | 1 | CPU個數。 |
JobId | String | job-0xQ8VSTpk7HLXyjcdW97EQe**** | 作業標示符。 |
Name | String | e2e test | 作業名稱。 |
Job運行中事件
通過Job運行中事件,事件匯流排EventBridge接收到的樣本事件如下所示。
{
"datacontenttype": "application/json",
"aliyunaccountid": "123456789098****",
"aliyunpublishtime": "2021-01-08T15:25:03.083Asia/Shanghai",
"data": {
"Status": {
"EnqueueTime": "2021-02-07T18:16:29.081610969+08:00",
"State": "Running",
"CreateTime": "2021-02-07T18:16:29.081610969+08:00"
},
"Project": "test48351",
"OwnerId": "123456789098****",
"Definition": {
"MountPoints": [
{
"MountPath": "/home/input/",
"Name": "test"
}
],
"FailStrategy": {
"WaitingTimeout": 999
},
"Type": "Batch",
"Volumes": [
{
"OSS": {
"Bucket": "bcs-test-zb",
"Prefix": "blender-demo/scenes/splash279"
},
"Name": "test"
}
],
"Command": [
"python",
"startclient.py",
"invoke",
"{"action": "Convert", "parameters": "{\\"widthPixel\\": \\"256\\", \\"heightPixel\\": \\"256\\", \\"inputUri\\": \\"oss://bcs-test-zb/daemon_app_fast_test/input/sample2.jpg\\", \\"outputUri\\": \\"oss://bcs-test-zb/daemon_app_fast_test/output/\\"}", "requestid": "e419e112-9795-4f6d-a724-438f54ce****"}"
],
"Envs": {
},
"PackageUri": "oss://bcs-test-zb/daemon_app_fast_test/package/startclient.py",
"Runtimes": {
"JobQueue": "cls-0xQ83wAZvGVKCAaTGSU1V69****"
},
"Labels": {
},
"Resources": {
"memory": "1Gi",
"cpu": "1"
}
},
"JobId": "job-0xQ8VSTpk7HLXyjcdW97EQeQ****",
"Name": "e2e test"
},
"subject": "acs:batchcompute:cn-hangzhou:123456789098****:test48351/job-0w1JZb8SZ1DEsKbfP99T69t****",
"specversion": "1.0",
"aliyuneventbusname": "default",
"id": "2BF-0w33xE0ZMwZJCh7aat7lEIMP****",
"source": "acs.batchcompute",
"time": "2021-01-08T15:25:03Z",
"type": "batchcompute:JobStateChange:JobRunning",
"aliyunpublishaddr": "172.20.XX.XX"
}
data欄位包含的參數解釋如下表所示。
參數 | 類型 | 樣本值 | 描述 |
Status | Struct | 作業狀態資訊。 | |
EnqueueTime | String | 2021-02-07T18:16:29.081610969+08:00 | 作業入隊時間。 |
State | String | Running | 作業狀態。 |
CreateTime | String | 2021-02-07T18:16:29.081610969+08:00 | 作業建立時間。 |
Project | String | test48351 | 專案名稱。 |
OwnerId | String | 123456789098**** | 資源擁有者。 |
Definition | Struct | 作業描述資訊。 | |
MountPoints | Struct | 掛載目的點資訊。 | |
MountPath | String | /home/input/ | 掛載後本地的目錄路徑。 |
Name | String | test | 掛載後本地顯示的檔案名稱。 |
FailStrategy | Struct | 失敗策略。 | |
WaitingTimeout | String | 999 | 等待時間。 |
Type | String | Batch | 作業類型。 |
Volumes | Struct | 掛載點資訊。 | |
OSS | Struct | 阿里雲Object Storage Service。 | |
Bucket | String | bcs-test-zb | Bucket名稱。 |
Prefix | String | blender-demo/scenes/splash279 | Bucket下的目錄名。 |
Name | String | test | Bucket下的檔案名稱。 |
Command | String |
| 作業需要啟動並執行Shell命令。 |
Envs | Struct | 作業啟動並執行環境變數。請根據實際情況自訂。 | |
PackageUri | String | oss://bcs-test-zb/daemon_app_fast_test/package/startclient.py | OSS資源的下載連結。 |
Runtimes | Struct | 作業運行過程中的部分資訊。 | |
JobQueue | String | cls-0xQ83wAZvGVKCAaTGSU1V69**** | 作業隊列的名稱。 |
Labels | Struct | 索引值對。請根據實際情況自訂。 | |
Resources | Struct | 作業運行時需要的資源。 | |
memory | String | 1 Gi | CPU記憶體。 |
cpu | String | 1 | CPU個數。 |
JobId | String | job-0xQ8VSTpk7HLXyjcdW97EQe**** | 作業標示符。 |
Name | String | e2e test | 作業名稱。 |
Job完成事件
通過Job完成事件,事件匯流排EventBridge接收到的樣本事件如下所示。
{
"datacontenttype":"application/json",
"aliyunaccountid":"123456789098****",
"aliyunpublishtime":"2021-01-08T15:25:03.083Asia/Shanghai",
"data":{
"Status":{
"EnqueueTime":"2021-02-07T18:16:29.081610969+08:00",
"State":"Succeeded",
"CreateTime":"2021-02-07T18:16:29.081610969+08:00"
},
"Project":"test48351",
"OwnerId":"123456789098****",
"Definition":{
"MountPoints":[
{
"MountPath":"/home/input/",
"Name":"test"
}
],
"FailStrategy":{
"WaitingTimeout":999
},
"Type":"Batch",
"Volumes":[
{
"OSS":{
"Bucket":"bcs-test-zb",
"Prefix":"blender-demo/scenes/splash279"
},
"Name":"test"
}
],
"Command":[
"python",
"startclient.py",
"invoke",
"{"action": "Convert", "parameters": "{\"widthPixel\": \"256\", \"heightPixel\": \"256\", \"inputUri\": \"oss://bcs-test-zb/daemon_app_fast_test/input/sample2.jpg\", \"outputUri\": \"oss://bcs-test-zb/daemon_app_fast_test/output/\"}", "requestid": "e419e112-9795-4f6d-a724-438f54ce****"}"
],
"Envs":{
},
"PackageUri":"oss://bcs-test-zb/daemon_app_fast_test/package/startclient.py",
"Runtimes":{
"JobQueue":"cls-0xQ83wAZvGVKCAaTGSU1V69****"
},
"Labels":{
},
"Resources":{
"memory":"1Gi",
"cpu":"1"
}
},
"JobId":"job-0xQ8VSTpk7HLXyjcdW97EQe****",
"Name":"e2e test"
},
"subject":"acs:batchcompute:cn-hangzhou:123456789098****:test48351/job-0w1JZb8SZ1DEsKbfP99T69t****",
"specversion":"1.0",
"aliyuneventbusname":"default",
"id":"2BF-0w33xE0ZMwZJCh7aat7lEIM****",
"source":"acs.batchcompute",
"time":"2021-01-08T15:25:03Z",
"type":"batchcompute:JobStateChange:JobSucceeded",
"aliyunpublishaddr":"172.20.XX.XX"
}
data欄位包含的參數解釋如下表所示。
參數 | 類型 | 樣本值 | 描述 |
Status | Struct | 作業狀態資訊。 | |
EnqueueTime | String | 2021-02-07T18:16:29.081610969+08:00 | 作業入隊時間。 |
State | String | Succeeded | 作業狀態。 |
CreateTime | String | 2021-02-07T18:16:29.081610969+08:00 | 作業建立時間。 |
Project | String | test48351 | 專案名稱。 |
OwnerId | String | 123456789098**** | 資源擁有者。 |
Definition | Struct | 作業描述資訊。 | |
MountPoints | Struct | 掛載目的點資訊。 | |
MountPath | String | /home/input/ | 掛載後本地的目錄路徑。 |
Name | String | test | 掛載後本地顯示的檔案名稱。 |
FailStrategy | Struct | 失敗策略。 | |
WaitingTimeout | String | 999 | 等待時間。 |
Type | String | Batch | 作業類型。 |
Volumes | Struct | 掛載點資訊。 | |
OSS | Struct | 阿里雲Object Storage Service。 | |
Bucket | String | bcs-test-zb | Bucket名稱。 |
Prefix | String | blender-demo/scenes/splash279 | Bucket下的目錄名。 |
Name | String | test | Bucket下的檔案名稱。 |
Command | String |
| 作業需要啟動並執行Shell命令。 |
Envs | Struct | 作業啟動並執行環境變數。請根據實際情況自訂。 | |
PackageUri | String | oss://bcs-test-zb/daemon_app_fast_test/package/startclient.py | OSS資源的下載連結。 |
Runtimes | Struct | 作業運行過程中的部分資訊。 | |
JobQueue | String | cls-0xQ83wAZvGVKCAaTGSU1V69**** | 作業隊列的名稱。 |
Labels | Struct | 索引值對。請根據實際情況自訂。 | |
Resources | Struct | 作業運行時需要的資源。 | |
memory | String | 1 Gi | CPU記憶體。 |
cpu | String | 1 | CPU個數。 |
JobId | String | job-0xQ8VSTpk7HLXyjcdW97EQe**** | 作業標示符。 |
Name | String | e2e test | 作業名稱。 |
Job等待事件
通過Job等待事件,事件匯流排EventBridge接收到的樣本事件如下所示。
{
"datacontenttype": "application/json",
"aliyunaccountid": "123456789098****",
"aliyunpublishtime": "2021-01-08T15:34:50.982Asia/Shanghai",
"data": {
"Status": {
"EnqueueTime": "2021-02-07T18:16:29.081610969+08:00",
"State": "Waiting",
"CreateTime": "2021-02-07T18:16:29.081610969+08:00"
},
"Project": "test48351",
"OwnerId": "123456789098****",
"Definition": {
"MountPoints": [
{
"MountPath": "/home/input/",
"Name": "test"
}
],
"FailStrategy": {
"WaitingTimeout": 999
},
"Type": "Batch",
"Volumes": [
{
"OSS": {
"Bucket": "bcs-test-zb",
"Prefix": "blender-demo/scenes/splash279"
},
"Name": "test"
}
],
"Command": [
"python",
"startclient.py",
"invoke",
"{"action": "Convert", "parameters": "{\\"widthPixel\\": \\"256\\", \\"heightPixel\\": \\"256\\", \\"inputUri\\": \\"oss://bcs-test-zb/daemon_app_fast_test/input/sample2.jpg\\", \\"outputUri\\": \\"oss://bcs-test-zb/daemon_app_fast_test/output/\\"}", "requestid": "e419e112-9795-4f6d-a724-438f54ce****"}"
],
"Envs": {
},
"PackageUri": "oss://bcs-test-zb/daemon_app_fast_test/package/startclient.py",
"Runtimes": {
"JobQueue": "cls-0xQ83wAZvGVKCAaTGSU1V69****"
},
"Labels": {
},
"Resources": {
"memory": "1Gi",
"cpu": "1"
}
},
"JobId": "job-0xQ8VSTpk7HLXyjcdW97EQe****",
"Name": "e2e test"
},
"subject": "acs:batchcompute:cn-hangzhou:123456789098****:test48351/job-0w1K9Hswhm8PyHlr3ZkWxWS****",
"specversion": "1.0",
"aliyuneventbusname": "default",
"id": "286-0w358zXmKWQR4go51hyvAGU****",
"source": "acs.batchcompute",
"time": "2021-01-08T15:34:50Z",
"type": "batchcompute:JobStateChange:JobWaiting",
"aliyunpublishaddr": "172.20.XX.XX"
}
data欄位包含的參數解釋如下表所示。
參數 | 類型 | 樣本值 | 描述 |
Status | Struct | 作業狀態資訊。 | |
EnqueueTime | String | 2021-02-07T18:16:29.081610969+08:00 | 作業入隊時間。 |
State | String | Waiting | 作業狀態。 |
CreateTime | String | 2021-02-07T18:16:29.081610969+08:00 | 作業建立時間。 |
Project | String | test48351 | 專案名稱。 |
OwnerId | String | 123456789098**** | 資源擁有者。 |
Definition | Struct | 作業描述資訊。 | |
MountPoints | Struct | 掛載目的點資訊。 | |
MountPath | String | /home/input/ | 掛載後本地的目錄路徑。 |
Name | String | test | 掛載後本地顯示的檔案名稱。 |
FailStrategy | Struct | 失敗策略。 | |
WaitingTimeout | String | 999 | 等待時間。 |
Type | String | Batch | 作業類型。 |
Volumes | Struct | 掛載點資訊。 | |
OSS | Struct | 阿里雲Object Storage Service。 | |
Bucket | String | bcs-test-zb | Bucket名稱。 |
Prefix | String | blender-demo/scenes/splash279 | Bucket下的目錄名。 |
Name | String | test | Bucket下的檔案名稱。 |
Command | String |
| 作業需要啟動並執行Shell命令。 |
Envs | Struct | 作業啟動並執行環境變數。請根據實際情況自訂。 | |
PackageUri | String | oss://bcs-test-zb/daemon_app_fast_test/package/startclient.py | OSS資源的下載連結。 |
Runtimes | Struct | 作業運行過程中的部分資訊。 | |
JobQueue | String | cls-0xQ83wAZvGVKCAaTGSU1V69**** | 作業隊列的名稱。 |
Labels | Struct | 索引值對。請根據實際情況自訂。 | |
Resources | Struct | 作業運行時需要的資源。 | |
memory | String | 1 Gi | CPU記憶體。 |
cpu | String | 1 | CPU個數。 |
JobId | String | job-0xQ8VSTpk7HLXyjcdW97EQe**** | 作業標示符。 |
Name | String | e2e test | 作業名稱。 |