Este tópico descreve os tipos de eventos do Resource Orchestration Service (ROS) publicáveis no EventBridge.
Tipos de eventos
O Batch Compute oferece suporte aos seguintes tipos de eventos para publicação no EventBridge:
|
Tipos de parâmetro |
Valores do parâmetro type |
|
Operações da Alibaba Cloud em recursos |
batchcompute:ActionTrail:AliyunServiceEvent |
|
Chamadas de operação de API |
batchcompute:ActionTrail:ApiCall |
|
Operações no console |
batchcompute:ActionTrail:ConsoleOperation |
|
Criação de cluster |
batchcompute:ClusterStateChange:ClusterCreated |
|
Exclusão de cluster |
batchcompute:ClusterStateChange:ClusterDeleted |
|
Erro de cluster |
batchcompute:ClusterStateChange:ClusterError |
|
Rolling de cluster |
batchcompute:ClusterStateChange:ClusterRolling |
|
Instância ocupada |
batchcompute:InstanceStateChange:InstanceBusy |
|
Criação de instância |
batchcompute:InstanceStateChange:InstanceCreated |
|
Preparação de instância |
batchcompute:InstanceStateChange:InstancePreparing |
|
Instância pronta |
batchcompute:InstanceStateChange:InstanceReady |
|
Liberação de instância |
batchcompute:InstanceStateChange:InstanceReleased |
|
batchcompute:JobStateChange:JobCanceled |
|
|
Criação de job |
batchcompute:JobStateChange:JobCreated |
|
Exclusão de job |
batchcompute:JobStateChange:JobDeleted |
|
batchcompute:JobStateChange:JobFailed |
|
|
batchcompute:JobStateChange:JobRunning |
|
|
batchcompute:JobStateChange:JobSucceeded |
|
|
batchcompute:JobStateChange:JobWaiting |
|
|
Criação de projeto |
batchcompute:ProjectStateChange:ProjectCreated |
|
Exclusão de projeto |
batchcompute:ProjectStateChange:ProjectDeleted |
Para mais informações sobre os parâmetros definidos na especificação CloudEvents, consulte Visão geral de eventos.
Eventos de job cancelado
No evento de job cancelado, o EventBridge recebe o seguinte evento de exemplo:
{
"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"
}A tabela a seguir descreve os parâmetros em data.
Parâmetro | Tipo | Exemplo | Descrição |
Status | Struct | Informações de status do job. | |
EnqueueTime | String | 2021-02-07T18:16:29.081610969+08:00 | Momento em que o job foi adicionado à fila. |
State | String | Canceled | Indica se o job de revisão automatizada está concluído. Valores válidos: |
CreateTime | String | 2021-02-07T18:16:29.081610969+08:00 | Momento de criação do job. |
Project | String | test48351 | Nome do projeto. |
OwnerId | String | 123456789098**** | Proprietário do recurso. |
Definition | Struct | Descrição da tarefa de atualização. | |
MountPoints | Struct | Detalhes dos destinos de montagem. | |
MountPath | String | /home/input/ | Caminho do diretório local após a montagem. |
Name | String | test | Nome do arquivo exibido localmente após a montagem. |
FailStrategy | Struct | Política de falha. | |
WaitingTimeout | String | 999 | Tempo de espera entre lotes de implantação do aplicativo. |
Type | String | Batch | Tipo do job. |
Volumes | Struct | Detalhes dos destinos de montagem. | |
OSS | Struct | Alibaba Cloud Object Storage Service. | |
Bucket | String | bcs-test-zb | Nome do bucket. |
Prefix | String | blender-demo/scenes/splash279 | Nome do diretório no Bucket. |
Name | String | test | Nome do arquivo no Bucket. |
Command | String | | Comando Shell a ser executado pelo job. |
Envs | Struct | Variáveis de ambiente do job. Personalize conforme necessário. | |
PackageUri | String | oss://bcs-test-zb/daemon_app_fast_test/package/startclient.py | Link para baixe do recurso OSS. |
Runtimes | Struct | Parte das informações durante a execução do job. | |
JobQueue | String | cls-0xQ83wAZvGVKCAaTGSU1V69**** | Nome da fila MNS. |
Labels | Struct | Pares chave-valor. Personalize conforme necessário. | |
Resources | Struct | Recursos necessários para execute o job. | |
memory | String | 1 Gi | Memória da CPU. |
cpu | String | 1 | Número de CPUs. |
JobId | String | job-0xQ8VSTpk7HLXyjcdW97EQe**** | Identificador do job. |
Name | String | e2e test | Nome do job. |
Eventos de falha de job
No evento de falha de job, o EventBridge recebe o seguinte evento de exemplo:
{
"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"
}A tabela a seguir descreve os parâmetros em data.
Parâmetro | Tipo | Exemplo | Descrição |
Status | Struct | Informações de status do job. | |
EnqueueTime | String | 2021-02-07T18:16:29.081610969+08:00 | Momento em que o job foi adicionado à fila. |
State | String | Failed | Indica se o job de revisão automatizada está concluído. Valores válidos: |
CreateTime | String | 2021-02-07T18:16:29.081610969+08:00 | Momento de criação do job. |
Project | String | test48351 | Nome do projeto. |
OwnerId | String | 123456789098**** | Proprietário do recurso. |
Definition | Struct | Descrição da tarefa de atualização. | |
MountPoints | Struct | Detalhes dos destinos de montagem. | |
MountPath | String | /home/input/ | Caminho do diretório local após a montagem. |
Name | String | test | Nome do arquivo exibido localmente após a montagem. |
FailStrategy | Struct | Política de falha. | |
WaitingTimeout | String | 999 | Tempo de espera entre lotes de implantação do aplicativo. |
Type | String | Batch | Tipo do job. |
Volumes | Struct | Detalhes dos destinos de montagem. | |
OSS | Struct | Alibaba Cloud Object Storage Service. | |
Bucket | String | bcs-test-zb | Nome do bucket. |
Prefix | String | blender-demo/scenes/splash279 | Nome do diretório no Bucket. |
Name | String | test | Nome do arquivo no Bucket. |
Command | String | | Comando Shell a ser executado pelo job. |
Envs | Struct | Variáveis de ambiente do job. Personalize conforme necessário. | |
PackageUri | String | oss://bcs-test-zb/daemon_app_fast_test/package/startclient.py | Link para baixe do recurso OSS. |
Runtimes | Struct | Parte das informações durante a execução do job. | |
JobQueue | String | cls-0xQ83wAZvGVKCAaTGSU1V69**** | Nome da fila MNS. |
Labels | Struct | Pares chave-valor. Personalize conforme necessário. | |
Resources | Struct | Recursos necessários para execute o job. | |
memory | String | 1 Gi | Memória da CPU. |
cpu | String | 1 | Número de CPUs. |
JobId | String | job-0xQ8VSTpk7HLXyjcdW97EQe**** | Identificador do job. |
Name | String | e2e test | Nome do job. |
Eventos de job em execução
No evento de job em execução, o EventBridge recebe o seguinte evento de exemplo:
{
"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"
}A tabela a seguir descreve os parâmetros em data.
Parâmetro | Tipo | Exemplo | Descrição |
Status | Struct | Informações de status do job. | |
EnqueueTime | String | 2021-02-07T18:16:29.081610969+08:00 | Momento em que o job foi adicionado à fila. |
State | String | Running | Indica se o job de revisão automatizada está concluído. Valores válidos: |
CreateTime | String | 2021-02-07T18:16:29.081610969+08:00 | Momento de criação do job. |
Project | String | test48351 | Nome do projeto. |
OwnerId | String | 123456789098**** | Proprietário do recurso. |
Definition | Struct | Descrição da tarefa de atualização. | |
MountPoints | Struct | Detalhes dos destinos de montagem. | |
MountPath | String | /home/input/ | Caminho do diretório local após a montagem. |
Name | String | test | Nome do arquivo exibido localmente após a montagem. |
FailStrategy | Struct | Política de falha. | |
WaitingTimeout | String | 999 | Tempo de espera entre lotes de implantação do aplicativo. |
Type | String | Batch | Tipo do job. |
Volumes | Struct | Detalhes dos destinos de montagem. | |
OSS | Struct | Alibaba Cloud Object Storage Service. | |
Bucket | String | bcs-test-zb | Nome do bucket. |
Prefix | String | blender-demo/scenes/splash279 | Nome do diretório no Bucket. |
Name | String | test | Nome do arquivo no Bucket. |
Command | String | | Comando Shell a ser executado pelo job. |
Envs | Struct | Variáveis de ambiente do job. Personalize conforme necessário. | |
PackageUri | String | oss://bcs-test-zb/daemon_app_fast_test/package/startclient.py | Link para baixe do recurso OSS. |
Runtimes | Struct | Parte das informações durante a execução do job. | |
JobQueue | String | cls-0xQ83wAZvGVKCAaTGSU1V69**** | Nome da fila MNS. |
Labels | Struct | Pares chave-valor. Personalize conforme necessário. | |
Resources | Struct | Recursos necessários para execute o job. | |
memory | String | 1 Gi | Memória da CPU. |
cpu | String | 1 | Número de CPUs. |
JobId | String | job-0xQ8VSTpk7HLXyjcdW97EQe**** | Identificador do job. |
Name | String | e2e test | Nome do job. |
Evento de conclusão de job
No evento de conclusão de job, o EventBridge recebe o seguinte evento de exemplo:
{
"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"
}A tabela a seguir descreve os parâmetros em data.
Parâmetro | Tipo | Exemplo | Descrição |
Status | Struct | Informações de status do job. | |
EnqueueTime | String | 2021-02-07T18:16:29.081610969+08:00 | Momento em que o job foi adicionado à fila. |
State | String | Succeeded | Indica se o job de revisão automatizada está concluído. Valores válidos: |
CreateTime | String | 2021-02-07T18:16:29.081610969+08:00 | Momento de criação do job. |
Project | String | test48351 | Nome do projeto. |
OwnerId | String | 123456789098**** | Proprietário do recurso. |
Definition | Struct | Descrição da tarefa de atualização. | |
MountPoints | Struct | Detalhes dos destinos de montagem. | |
MountPath | String | /home/input/ | Caminho do diretório local após a montagem. |
Name | String | test | Nome do arquivo exibido localmente após a montagem. |
FailStrategy | Struct | Política de falha. | |
WaitingTimeout | String | 999 | Tempo de espera entre lotes de implantação do aplicativo. |
Type | String | Batch | Tipo do job. |
Volumes | Struct | Detalhes dos destinos de montagem. | |
OSS | Struct | Alibaba Cloud Object Storage Service. | |
Bucket | String | bcs-test-zb | Nome do bucket. |
Prefix | String | blender-demo/scenes/splash279 | Nome do diretório no Bucket. |
Name | String | test | Nome do arquivo no Bucket. |
Command | String | | Comando Shell a ser executado pelo job. |
Envs | Struct | Variáveis de ambiente do job. Personalize conforme necessário. | |
PackageUri | String | oss://bcs-test-zb/daemon_app_fast_test/package/startclient.py | Link para baixe do recurso OSS. |
Runtimes | Struct | Parte das informações durante a execução do job. | |
JobQueue | String | cls-0xQ83wAZvGVKCAaTGSU1V69**** | Nome da fila MNS. |
Labels | Struct | Pares chave-valor. Personalize conforme necessário. | |
Resources | Struct | Recursos necessários para execute o job. | |
memory | String | 1 Gi | Memória da CPU. |
cpu | String | 1 | Número de CPUs. |
JobId | String | job-0xQ8VSTpk7HLXyjcdW97EQe**** | Identificador do job. |
Name | String | e2e test | Nome do job. |
Eventos de espera de job
No evento de espera de job, o EventBridge recebe o seguinte evento de exemplo:
{
"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"
}A tabela a seguir descreve os parâmetros em data.
Parâmetro | Tipo | Exemplo | Descrição |
Status | Struct | Informações de status do job. | |
EnqueueTime | String | 2021-02-07T18:16:29.081610969+08:00 | Momento em que o job foi adicionado à fila. |
State | String | Waiting | Indica se o job de revisão automatizada está concluído. Valores válidos: |
CreateTime | String | 2021-02-07T18:16:29.081610969+08:00 | Momento de criação do job. |
Project | String | test48351 | Nome do projeto. |
OwnerId | String | 123456789098**** | Proprietário do recurso. |
Definition | Struct | Descrição da tarefa de atualização. | |
MountPoints | Struct | Detalhes dos destinos de montagem. | |
MountPath | String | /home/input/ | Caminho do diretório local após a montagem. |
Name | String | test | Nome do arquivo exibido localmente após a montagem. |
FailStrategy | Struct | Política de falha. | |
WaitingTimeout | String | 999 | Tempo de espera entre lotes de implantação do aplicativo. |
Type | String | Batch | Tipo do job. |
Volumes | Struct | Detalhes dos destinos de montagem. | |
OSS | Struct | Alibaba Cloud Object Storage Service. | |
Bucket | String | bcs-test-zb | Nome do bucket. |
Prefix | String | blender-demo/scenes/splash279 | Nome do diretório no Bucket. |
Name | String | test | Nome do arquivo no Bucket. |
Command | String | | Comando Shell a ser executado pelo job. |
Envs | Struct | Variáveis de ambiente do job. Personalize conforme necessário. | |
PackageUri | String | oss://bcs-test-zb/daemon_app_fast_test/package/startclient.py | Link para baixe do recurso OSS. |
Runtimes | Struct | Parte das informações durante a execução do job. | |
JobQueue | String | cls-0xQ83wAZvGVKCAaTGSU1V69**** | Nome da fila MNS. |
Labels | Struct | Pares chave-valor. Personalize conforme necessário. | |
Resources | Struct | Recursos necessários para execute o job. | |
memory | String | 1 Gi | Memória da CPU. |
cpu | String | 1 | Número de CPUs. |
JobId | String | job-0xQ8VSTpk7HLXyjcdW97EQe**** | Identificador do job. |
Name | String | e2e test | Nome do job. |