This topic describes the types of Resource Orchestration Service (ROS) events that can be published to EventBridge.
Event types
The Batch Compute supports the following event types for publishing to EventBridge:
Parameter types | type parameter values |
Operations performed by Alibaba Cloud on resources | batchcompute:ActionTrail:AliyunServiceEvent |
API operation calls | batchcompute:ActionTrail:ApiCall |
Operations performed in the console | batchcompute:ActionTrail:ConsoleOperation |
Cluster creation events | batchcompute:ClusterStateChange:ClusterCreated |
Cluster deletion events | batchcompute:ClusterStateChange:ClusterDeleted |
Cluster error events | batchcompute:ClusterStateChange:ClusterError |
Cluster Rolling events | batchcompute:ClusterStateChange:ClusterRolling |
Instance Busy event | batchcompute:InstanceStateChange:InstanceBusy |
Instance Creation Events | batchcompute:InstanceStateChange:InstanceCreated |
Instance preparation events | batchcompute:InstanceStateChange:InstancePreparing |
Events of Instance Ready | batchcompute:InstanceStateChange:InstanceReady |
Instance Released events | batchcompute:InstanceStateChange:InstanceReleased |
batchcompute:JobStateChange:JobCanceled | |
Job creation event | batchcompute:JobStateChange:JobCreated |
Job deletion events | batchcompute:JobStateChange:JobDeleted |
batchcompute:JobStateChange:JobFailed | |
batchcompute:JobStateChange:JobRunning | |
batchcompute:JobStateChange:JobSucceeded | |
batchcompute:JobStateChange:JobWaiting | |
Project creation event | batchcompute:ProjectStateChange:ProjectCreated |
Project deletion events | batchcompute:ProjectStateChange:ProjectDeleted |
For more information about the parameters defined in the CloudEvents specification, see Overview.
Job canceled events
With the Job canceled event, the sample event received by the EventBridge is shown below.
{
"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"
}
The following table describes the parameters within data.
Parameter | Type | Example | Description |
Status | Struct | The job status information. | |
EnqueueTime | String | 2021-02-07T18:16:29.081610969+08:00 | The time when the job was added to the queue. |
State | String | Canceled | Indicates whether the automated review job is complete. Valid values: |
CreateTime | String | 2021-02-07T18:16:29.081610969+08:00 | The time when the job was created. |
Project | String | test48351 | The name of the project. |
OwnerId | String | 123456789098**** | The resource owner. |
Definition | Struct | The description of the update task. | |
MountPoints | Struct | The details of mount targets. | |
MountPath | String | /home/input/ | The local directory path after the Mount. |
Name | String | test | The name of the file displayed locally after mounting. |
FailStrategy | Struct | The failure policy. | |
WaitingTimeout | String | 999 | The waiting time between deployment batches for the application. |
Type | String | Batch | The type of the job. |
Volumes | Struct | The details of mount targets. | |
OSS | Struct | Alibaba Cloud Object Storage Service. | |
Bucket | String | bcs-test-zb | The name of the bucket. |
Prefix | String | blender-demo/scenes/splash279 | The name of the directory in the Bucket. |
Name | String | test | The name of the file in the Bucket. |
Command | String |
| The Shell command to be run by the job. |
Envs | Struct | The environment variables of the job. Please customize according to the actual situation. | |
PackageUri | String | oss://bcs-test-zb/daemon_app_fast_test/package/startclient.py | The download link of the OSS resource. |
Runtimes | Struct | Part of information during job running. | |
JobQueue | String | cls-0xQ83wAZvGVKCAaTGSU1V69**** | The name of the MNS queue. |
Labels | Struct | The key-value pairs. Please customize according to the actual situation. | |
Resources | Struct | The resources required to run the job. | |
memory | String | 1 Gi | The CPU memory. |
cpu | String | 1 | The number of CPUs. |
JobId | String | job-0xQ8VSTpk7HLXyjcdW97EQe**** | The job identifier. |
Name | String | e2e test | The name of the job. |
Job failure events
With the Job failure event, the EventBridge receives the following sample event:
{
"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"
}
The following table describes the parameters within data.
Parameter | Type | Example | Description |
Status | Struct | The job status information. | |
EnqueueTime | String | 2021-02-07T18:16:29.081610969+08:00 | The time when the job was added to the queue. |
State | String | Failed | Indicates whether the automated review job is complete. Valid values: |
CreateTime | String | 2021-02-07T18:16:29.081610969+08:00 | The time when the job was created. |
Project | String | test48351 | The name of the project. |
OwnerId | String | 123456789098**** | The resource owner. |
Definition | Struct | The description of the update task. | |
MountPoints | Struct | The details of mount targets. | |
MountPath | String | /home/input/ | The local directory path after the Mount. |
Name | String | test | The name of the file displayed locally after mounting. |
FailStrategy | Struct | The failure policy. | |
WaitingTimeout | String | 999 | The waiting time between deployment batches for the application. |
Type | String | Batch | The type of the job. |
Volumes | Struct | The details of mount targets. | |
OSS | Struct | Alibaba Cloud Object Storage Service. | |
Bucket | String | bcs-test-zb | The name of the bucket. |
Prefix | String | blender-demo/scenes/splash279 | The name of the directory in the Bucket. |
Name | String | test | The name of the file in the Bucket. |
Command | String |
| The Shell command to be run by the job. |
Envs | Struct | The environment variables of the job. Please customize according to the actual situation. | |
PackageUri | String | oss://bcs-test-zb/daemon_app_fast_test/package/startclient.py | The download link of the OSS resource. |
Runtimes | Struct | Part of information during job running. | |
JobQueue | String | cls-0xQ83wAZvGVKCAaTGSU1V69**** | The name of the MNS queue. |
Labels | Struct | The key-value pairs. Please customize according to the actual situation. | |
Resources | Struct | The resources required to run the job. | |
memory | String | 1 Gi | The CPU memory. |
cpu | String | 1 | The number of CPUs. |
JobId | String | job-0xQ8VSTpk7HLXyjcdW97EQe**** | The job identifier. |
Name | String | e2e test | The name of the job. |
Job running events
With the Job canceled event, the sample event received by the EventBridge is shown below.
{
"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"
}
The following table describes the parameters within data.
Parameter | Type | Example | Description |
Status | Struct | The job status information. | |
EnqueueTime | String | 2021-02-07T18:16:29.081610969+08:00 | The time when the job was added to the queue. |
State | String | Running | Indicates whether the automated review job is complete. Valid values: |
CreateTime | String | 2021-02-07T18:16:29.081610969+08:00 | The time when the job was created. |
Project | String | test48351 | The name of the project. |
OwnerId | String | 123456789098**** | The resource owner. |
Definition | Struct | The description of the update task. | |
MountPoints | Struct | The details of mount targets. | |
MountPath | String | /home/input/ | The local directory path after the Mount. |
Name | String | test | The name of the file displayed locally after mounting. |
FailStrategy | Struct | The failure policy. | |
WaitingTimeout | String | 999 | The waiting time between deployment batches for the application. |
Type | String | Batch | The type of the job. |
Volumes | Struct | The details of mount targets. | |
OSS | Struct | Alibaba Cloud Object Storage Service. | |
Bucket | String | bcs-test-zb | The name of the bucket. |
Prefix | String | blender-demo/scenes/splash279 | The name of the directory in the Bucket. |
Name | String | test | The name of the file in the Bucket. |
Command | String |
| The Shell command to be run by the job. |
Envs | Struct | The environment variables of the job. Please customize according to the actual situation. | |
PackageUri | String | oss://bcs-test-zb/daemon_app_fast_test/package/startclient.py | The download link of the OSS resource. |
Runtimes | Struct | Part of information during job running. | |
JobQueue | String | cls-0xQ83wAZvGVKCAaTGSU1V69**** | The name of the MNS queue. |
Labels | Struct | The key-value pairs. Please customize according to the actual situation. | |
Resources | Struct | The resources required to run the job. | |
memory | String | 1 Gi | The CPU memory. |
cpu | String | 1 | The number of CPUs. |
JobId | String | job-0xQ8VSTpk7HLXyjcdW97EQe**** | The job identifier. |
Name | String | e2e test | The name of the job. |
Job completion event
With the Job failure event, the EventBridge receives the following sample event:
{
"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"
}
The following table describes the parameters within data.
Parameter | Type | Example | Description |
Status | Struct | The job status information. | |
EnqueueTime | String | 2021-02-07T18:16:29.081610969+08:00 | The time when the job was added to the queue. |
State | String | Succeeded | Indicates whether the automated review job is complete. Valid values: |
CreateTime | String | 2021-02-07T18:16:29.081610969+08:00 | The time when the job was created. |
Project | String | test48351 | The name of the project. |
OwnerId | String | 123456789098**** | The resource owner. |
Definition | Struct | The description of the update task. | |
MountPoints | Struct | The details of mount targets. | |
MountPath | String | /home/input/ | The local directory path after the Mount. |
Name | String | test | The name of the file displayed locally after mounting. |
FailStrategy | Struct | The failure policy. | |
WaitingTimeout | String | 999 | The waiting time between deployment batches for the application. |
Type | String | Batch | The type of the job. |
Volumes | Struct | The details of mount targets. | |
OSS | Struct | Alibaba Cloud Object Storage Service. | |
Bucket | String | bcs-test-zb | The name of the bucket. |
Prefix | String | blender-demo/scenes/splash279 | The name of the directory in the Bucket. |
Name | String | test | The name of the file in the Bucket. |
Command | String |
| The Shell command to be run by the job. |
Envs | Struct | The environment variables of the job. Please customize according to the actual situation. | |
PackageUri | String | oss://bcs-test-zb/daemon_app_fast_test/package/startclient.py | The download link of the OSS resource. |
Runtimes | Struct | Part of information during job running. | |
JobQueue | String | cls-0xQ83wAZvGVKCAaTGSU1V69**** | The name of the MNS queue. |
Labels | Struct | The key-value pairs. Please customize according to the actual situation. | |
Resources | Struct | The resources required to run the job. | |
memory | String | 1 Gi | The CPU memory. |
cpu | String | 1 | The number of CPUs. |
JobId | String | job-0xQ8VSTpk7HLXyjcdW97EQe**** | The job identifier. |
Name | String | e2e test | The name of the job. |
Job wait events
With the Job failure event, the EventBridge receives the following sample event:
{
"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"
}
The following table describes the parameters within data.
Parameter | Type | Example | Description |
Status | Struct | The job status information. | |
EnqueueTime | String | 2021-02-07T18:16:29.081610969+08:00 | The time when the job was added to the queue. |
State | String | Waiting | Indicates whether the automated review job is complete. Valid values: |
CreateTime | String | 2021-02-07T18:16:29.081610969+08:00 | The time when the job was created. |
Project | String | test48351 | The name of the project. |
OwnerId | String | 123456789098**** | The resource owner. |
Definition | Struct | The description of the update task. | |
MountPoints | Struct | The details of mount targets. | |
MountPath | String | /home/input/ | The local directory path after the Mount. |
Name | String | test | The name of the file displayed locally after mounting. |
FailStrategy | Struct | The failure policy. | |
WaitingTimeout | String | 999 | The waiting time between deployment batches for the application. |
Type | String | Batch | The type of the job. |
Volumes | Struct | The details of mount targets. | |
OSS | Struct | Alibaba Cloud Object Storage Service. | |
Bucket | String | bcs-test-zb | The name of the bucket. |
Prefix | String | blender-demo/scenes/splash279 | The name of the directory in the Bucket. |
Name | String | test | The name of the file in the Bucket. |
Command | String |
| The Shell command to be run by the job. |
Envs | Struct | The environment variables of the job. Please customize according to the actual situation. | |
PackageUri | String | oss://bcs-test-zb/daemon_app_fast_test/package/startclient.py | The download link of the OSS resource. |
Runtimes | Struct | Part of information during job running. | |
JobQueue | String | cls-0xQ83wAZvGVKCAaTGSU1V69**** | The name of the MNS queue. |
Labels | Struct | The key-value pairs. Please customize according to the actual situation. | |
Resources | Struct | The resources required to run the job. | |
memory | String | 1 Gi | The CPU memory. |
cpu | String | 1 | The number of CPUs. |
JobId | String | job-0xQ8VSTpk7HLXyjcdW97EQe**** | The job identifier. |
Name | String | e2e test | The name of the job. |