本文介绍批量计算作为事件源发布到事件总线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
Job已取消事件 batchcompute:JobStateChange:JobCanceled
Job创建事件 batchcompute:JobStateChange:JobCreated
Job删除事件 batchcompute:JobStateChange:JobDeleted
Job失败事件 batchcompute:JobStateChange:JobFailed
Job运行中事件 batchcompute:JobStateChange:JobRunning
Job完成事件 batchcompute:JobStateChange:JobSucceeded
Job等待事件 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
[
    "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****"}"
]
作业需要运行的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
[
    "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****"}"
]
作业需要运行的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
[
    "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****"}"
]
作业需要运行的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
[
    "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****"}"
]
作业需要运行的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
[
    "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****"}"
]
作业需要运行的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 作业名称。