本文介绍批量计算作为事件源发布到事件总线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 | 阿里云对象存储。 | |
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 | 阿里云对象存储。 | |
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 | 阿里云对象存储。 | |
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 | 阿里云对象存储。 | |
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 | 阿里云对象存储。 | |
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 | 作业名称。 |