工作流的執行可以通過控制臺或調用SDK觸發，也可以由事件源來觸發。您可以在指定工作流中創建工作流調度，工作流調度描述了一組規則，當某個事件滿足這些規則，事件源就會觸發關聯的工作流執行。本文介紹什么是工作流調度。
什么是工作流調度
工作流調度（即觸發器）是觸發工作流執行的方式。在事件驅動的計算模型中，事件源是事件的生產者，工作流是事件的處理者，而工作流調度提供了一種集中、統一的方式來管理不同的事件源。在事件源中，當事件發生時，如果滿足工作流調度定義的規則，事件源會自動調用工作流調度關聯的工作流。
場景示例
示例一 ：對象存儲 OSS（Object Storage Service）中的圖片狀態變更觸發工作流執行。
您可以通過直接調用工作流的方式去下載圖片進行處理，并將結果存入OSS或者其他服務。如果OSS能夠幫助我們關注新上傳的圖片，并且自動去調用關聯的工作流，您將無需再調用工作流，從而簡化了開發和使用流程。
OSS調度的作用就是關注這些事件并調度工作流的流程執行 。配置OSS調度后，當有新圖片上傳時，OSS調度會自動觸發工作流執行，下載并處理圖片。
示例二：日志服務 SLS（Simple Log Service）中日志更新觸發工作流執行。
您可以通過直接調用工作流對增量的日志進行查詢和分析。如果SLS能夠幫助我們關注更新的日志，并自動調用關聯的工作流，您無需再調用工作流。
SLS調度的作用就是關注這些事件并調用工作流的流程。配置了SLS調度后，當有日志更新時，SLS調度會自動觸發工作流消費增量的日志。
示例三：在指定時間觸發工作流執行。
某應用需要每隔1小時收集一次數據。您可以每隔1小時通過直接調用工作流收集數據并處理。如果工作流中能每隔1小時自動執行，您將無需再關注時間。
定時調度的作用就是關注時間事件并調用工作流。配置了定時調度后，在指定的時間，定時調度會自動觸發工作流執行收集和處理數據。
調度類型
按照工作流調度集成方式，工作流支持的調度類型如下。
雙向集成調度：您既可以在工作流配置調度，又可以在事件源端配置調度。
云產品事件調度：支持在工作流配置調度，同時支持在事件總線EventBridge創建工作流觸發規則，無需在事件源端配置。
從工作流調用方式的角度，工作流調度又可以分為同步調用調度和異步調用調度，兩種調用方式的區別如下所示。
同步調用：事件被工作流處理后直接返回結果。
異步調用：事件在寫入到工作流內部隊列后返回結果，工作流系統會保證該消息被可靠地處理。
雙向集成調度
調度名稱 | 標準執行模式工作流調用方式 | 快速執行模式工作流調用方式 |
定時調度 | 異步調用 | 同步調用 |
SLS調度 | 異步調用 | 同步調用 |
MNS調度 | 異步調用 | 同步調用 |
Kafka調度 | 異步調用 | 同步調用 |
RocketMQ調度 | 異步調用 | 同步調用 |
RabbitMQ調度 | 異步調用 | 同步調用 |
HTTP調度 | 異步調用 | 同步調用 |
云產品事件調度
調度名稱 | 標準執行模式工作流調用方式 | 快速執行模式工作流調用方式 |
阿里云官方事件調度 | 異步調用 | 同步調用 |
工作流調度的Event格式
不同調度類型，其觸發的事件傳遞到工作流接口的Event格式不同，各調度類型的Event格式如下所示。
工作流調度觸發事件，傳遞到工作流的Event參數需要您通過表達式提取才能使用。具體操作，請參見輸入和輸出。
定時調度
{
"datacontenttype":"application/json;charset=utf-8",
"aliyunaccountid":"143998900779****",
"aliyunpublishtime":"2022-09-21T05:00:00.035Z",
"data":{
"TimeZone":"GMT+0:00",
"Schedule":"0/30 * * * * ?",
"UserData":{
"key":"value"
}
},
"specversion":"1.0",
"aliyuneventbusname":"Housekeeping-Bus",
"id":"d100262d-90c7-4caf-a3b5-813f3526a1f7-****",
"source":"housekeeping.scheduledevent",
"time":"2022-09-21T05:00:00Z",
"aliyunregionid":"cn-beijing",
"type":"eventbridge:Events:ScheduledEvent"
}data字段包含的參數解釋如下表所示。關于CloudEvents規范中定義的參數解釋，請參見事件概述。
參數 | 類型 | 示例值 | 描述 |
TimeZone | String | GMT+8:00 | 時區。 |
Schedule | String | 0 */10 * * * * | 觸發周期為自定義Corn時的Corn表達式。 |
UserData | Object | {"key":"value"} | 填寫的自定義參數，格式為JSON對象。 |
HTTP調度
{
"datacontenttype": "application/json",
"aliyunaccountid": "164901546557****",
"data": {
"headers": {
"content-length": "0",
"Accept": "text/html,application/xhtml+xml,application/xml;q=0.9,image/avif,image/webp,image/apng,*/*;q=0.8,application/signed-exchange;v=b3;q=0.7",
"Host": "164901546557****.eventbridge.cn-hangzhou.aliyuncs.com",
"Accept-Encoding": "gzip, deflate",
"X-Forwarded-Port": "80",
"Upgrade-Insecure-Requests": "1",
"X-Forwarded-For": "183.247.0.***",
"Accept-Language": "zh-CN,zh;q=0.9",
"X-Real-IP": "183.247.0.***",
"X-Scheme": "http"
},
"path": "/webhook/putEvents",
"body": "",
"httpMethod": "GET",
"queryString": {}
},
"subject": "acs:eventbridge:cn-hangzhou:164901546557****:eventbus/eventbus-created-by-fnf-466ccc7e-418a-403f-8d96-2d73a8e****/eventsource/httpschedule",
"aliyunoriginalaccountid": "164901546557****",
"source": "httpschedule",
"type": "eventbridge:Events:HTTPEvent",
"aliyunpublishtime": "2023-08-06T18:37:01.666Z",
"specversion": "1.0",
"aliyuneventbusname": "eventbus-created-by-fnf-466ccc7e-418a-403f-8d96-2d73a8e****",
"id": "6751261d-e496-4b36-a707-3c087bf3****",
"time": "2023-08-07T02:37:01.666+08:00",
"aliyunregionid": "cn-hangzhou",
"aliyunpublishaddr": "183.247.0.***"
}data字段包含的參數解釋如下表所示。關于CloudEvents規范中定義的參數解釋，請參見事件概述。
參數 | 類型 | 示例值 | 描述 |
headers | Object | { "Accept": "application/json" } | HTTP請求頭的內容。 |
path | String | /webhook/putEvents | 請求路徑。 |
body | Object | { "filePath": "/tmp/uploader" } | HTTP請求體的內容。 |
httpMethod | String | GET | HTTP調用方法。 |
queryString | String | username=leo | HTTP URL中 |
云產品事件調度
{
"id":"c2g71017-6f65-fhcf-a814-a396fc8d****",
"source":"OSS-FunctionFlow-osstrigger",
"specversion":"1.0",
"type":"oss:PutObject",
"datacontenttype":"application/json; charset=utf-8",
"subject":"acs:mns:cn-hangzhou:164901546557****:queues/zeus",
"time":"2021-04-08T06:28:17.093Z",
"aliyunaccountid":"1649015465574023",
"aliyunpublishtime":"2021-10-15T07:06:34.028Z",
"aliyunoriginalaccountid":"164901546557****",
"aliyuneventbusname":"OSS-FunctionFlow-osstrigger",
"aliyunregionid":"cn-chengdu",
"aliyunpublishaddr":"42.120.XX.XX",
"data":{
*** 這部分根據事件源的不同而不同 ***
}
}data字段包含的參數與阿里云產品的事件源類型有關。關于云產品事件源的種類以及格式，請參見阿里云官方事件源。
SLS調度
[
{
"datacontenttype": "application/json;charset=utf-8",
"aliyunaccountid": "164901546557****",
"data": {
"key1": "value1",
"key2": "value2",
"__topic__": "test_topic",
"__source__": "test_source",
"__client_ip__": "122.231.XX.XX",
"__receive_time__": "1663487595",
"__pack_id__": "59b662b2257796****"
},
"subject": "acs:log:cn-qingdao:164901546557****:project/qiingdaoproject/logstore/qingdao-logstore-1",
"aliyunoriginalaccountid": "164901546557****",
"source": "SLS-FunctionFlow-slstrigger",
"type": "sls:connector",
"aliyunpublishtime": "2022-09-18T07:53:15.387Z",
"specversion": "1.0",
"aliyuneventbusname": "SLS-FunctionFlow-slstrigger",
"id": "qiingdaoproject-qingdao-logstore-1-1-MTY2MzExODM5ODY4NjAxOTQyMw****",
"time": "2022-09-18T07:53:12Z",
"aliyunregionid": "cn-qingdao",
"aliyunpublishaddr": "10.50.XX.XX"
}
]data字段包含的參數解釋如下表所示。其中以__開頭和結尾的為SLS系統字段，關于其解釋，請參見保留字段。關于CloudEvents規范中定義的參數解釋，請參見事件概述。
參數 | 類型 | 示例值 | 描述 |
key1 | String | testKey | "key1": "value1"、"key2": "value2"表示用戶的SLS日志中的字段及對應內容。 |
__topic__ | String | testTopic | 日志主題。 |
__source__ | String | testSource | 日志來源設備。 |
__client_ip__ | String | 122.231.XX.XX | 日志所在主機的IP地址。 |
__receive_time__ | String | 1663487595 | 日志到達服務端的時間。 |
__pack_id__ | String | 59b662b2257796**** | 該日志所屬的LogGroup的唯一身份標識。 |
MNS調度
[
{
"id":"c2g71017-6f65-fhcf-a814-a396fc8d****",
"source":"MNS-FunctionFlow-mnstrigger",
"specversion":"1.0",
"type":"mns:Queue:SendMessage",
"datacontenttype":"application/json; charset=utf-8",
"subject":"acs:mns:cn-hangzhou:164901546557****:queues/zeus",
"time":"2023-04-08T06:28:17.093Z",
"aliyunaccountid":"1649015465574023",
"aliyunpublishtime":"2023-10-15T07:06:34.028Z",
"aliyunoriginalaccountid":"164901546557****",
"aliyuneventbusname":"MNS-Function-mnstrigger",
"aliyunregionid":"cn-chengdu",
"aliyunpublishaddr":"42.120.XX.XX",
"data":{
"requestId":"606EA3074344430D4C81****",
"messageId":"C6DB60D1574661357FA227277445****",
"messageBody":"TEST"
}
}
]data字段包含的參數解釋如下表所示。關于CloudEvents規范中定義的參數解釋，請參見事件概述。
參數 | 類型 | 示例值 | 描述 |
requestId | String | 606EA3074344430D4C81**** | 請求ID。每個請求的ID取值唯一。 |
messageId | String | C6DB60D1574661357FA227277445**** | 消息ID。每條消息的ID取值唯一。 |
messageBody | String | TEST | 消息內容。 |
RocketMQ調度
[
{
"id":"94ebc15f-f0db-4bbe-acce-56fb72fb****",
"source":"RocketMQ-rocketmq-schedule",
"specversion":"1.0",
"type":"mq:Topic:SendMessage",
"datacontenttype":"application/json; charset=utf-8",
"subject":"acs:mq:cn-hangzhou:164901546557****:MQ_INST_164901546557****_BXhFHryi%TopicName",
"time":"2023-04-08T06:01:20.766Z",
"aliyunaccountid":"164901546557****",
"aliyunpublishtime":"2023-10-15T02:05:16.791Z",
"aliyunoriginalaccountid":"164901546557****",
"aliyuneventbusname":"RocketMQ-Function-rocketmq-trigger",
"aliyunregionid":"cn-chengdu",
"aliyunpublishaddr":"42.120.XX.XX",
"data":{
"topic":"TopicName",
"systemProperties":{
"MIN_OFFSET":"0",
"TRACE_ON":"true",
"MAX_OFFSET":"8",
"MSG_REGION":"cn-hangzhou",
"KEYS":"systemProperties.KEYS",
"CONSUME_START_TIME":1628577790396,
"TAGS":"systemProperties.TAGS",
"INSTANCE_ID":"MQ_INST_164901546557****_BXhFHryi"
},
"userProperties":{
},
"body":"TEST"
}
}
]data字段包含的參數解釋如下表所示。關于CloudEvents規范中定義的參數解釋，請參見事件概述。
參數 | 類型 | 示例值 | 描述 |
topic | String | TopicName | Topic名稱。 |
systemProperties | Map | 系統屬性。 | |
MIN_OFFSET | Int | 0 | 最低位點。 |
TRACE_ON | Boolean | true | 是否有消息軌跡。取值說明如下：
|
MAX_OFFSET | Int | 8 | 最高位點。 |
MSG_REGION | String | cn-hangzhou | 發送消息的地域。 |
KEYS | String | systemProperties.KEYS | 過濾屬性。 |
CONSUME_START_TIME | Long | 1628577790396 | 開始消費時間。單位：毫秒。 |
UNIQ_KEY | String | AC14C305069E1B28CDFA3181CDA2**** | 消息唯一鍵。 |
TAGS | String | systemProperties.TAGS | 過濾屬性。 |
INSTANCE_ID | String | MQ_INST_123456789098****_BXhFHryi | 實例ID。 |
userProperties | Map | 無 | 用戶屬性。 |
body | String | TEST | 消息內容。 |
RabbitMQ調度
[
{
"id":"bj694332-4cj1-389e-9d8c-b137h30b****",
"source":"RabbitMQ-Function-rabbitmq-trigger",
"specversion":"1.0",
"type":"amqp:Queue:SendMessage",
"datacontenttype":"application/json;charset=utf-8",
"subject":"acs:amqp:cn-hangzhou:164901546557****:/instances/amqp-cn-tl32e756****/vhosts/eb-connect/queues/housekeeping",
"time":"2023-08-12T06:56:40.709Z",
"aliyunaccountid":"164901546557****",
"aliyunpublishtime":"2023-10-15T08:58:55.140Z",
"aliyunoriginalaccountid":"164901546557****",
"aliyuneventbusname":"RabbitMQ-Function-rabbitmq-trigger",
"aliyunregionid":"cn-chengdu",
"aliyunpublishaddr":"42.120.XX.XX",
"data":{
"envelope":{
"deliveryTag":98,
"exchange":"",
"redeliver":false,
"routingKey":"housekeeping"
},
"body":{
"Hello":"RabbitMQ"
},
"props":{
"contentEncoding":"UTF-8",
"messageId":"f7622d51-e198-41de-a072-77c1ead7****"
}
}
}
]data字段包含的參數解釋如下表所示。關于CloudEvents規范中定義的參數解釋，請參見事件概述。
參數 | 類型 | 示例值 | 描述 |
body | Map | 消息內容。 | |
Hello | String | EventBridge | 用戶數據。 |
props | Map | 消息屬性。 | |
contentEncoding | String | utf-8 | 消息內容編碼。 |
messageId | String | f7622d51-e198-41de-a072-77c1ead7**** | 消息ID。每條消息的ID取值唯一。 |
envelope | Map | 消息的envelope信息。 | |
deliveryTag | Int | 98 | 消息的Tag。 |
exchange | String | 無 | 消息的Exchange。 |
redeliver | Boolean | false | 是否支持重發消息。取值說明如下：
|
routingKey | String | housekeeping | 消息的路由規則。 |
Kafka調度
[
{
"specversion":"1.0",
"id":"8e215af8-ca18-4249-8645-f96c1026****",
"source":"acs:alikafka",
"type":"alikafka:Topic:Message",
"subject":"acs:alikafka_pre-cn-i7m2t7t1****:topic:mytopic",
"datacontenttype":"application/json; charset=utf-8",
"time":"2023-06-23T02:49:51.589Z",
"aliyunaccountid":"164901546557****",
"data":{
"topic":"****",
"partition":7,
"offset":25,
"timestamp":1655952591589,
"headers":{
"headers":[
],
"isReadOnly":false
},
"key":"keytest",
"value":"hello kafka msg"
}
}
]data字段包含的參數解釋如下表所示。關于CloudEvents規范中定義的參數解釋，請參見事件概述。
參數 | 類型 | 示例值 | 描述 |
topic | String | TopicName | Topic的名稱。 |
partition | Int | 1 | 消息隊列Kafka版的消費分區信息。 |
offset | Int | 0 | 消息隊列Kafka版的消息位點。 |
timestamp | String | 1655952591589 | 開始消費時間戳。 |
DTS調度
{
"data": {
"id": 321****,
"topicPartition": {
"hash": 0,
"partition": 0,
"topic": "cn_hangzhou_rm_1234****_test_version2"
},
"offset": 3218099,
"sourceTimestamp": 1654847757,
"operationType": "UPDATE",
"schema": {
"recordFields": [
{
"fieldName": "id",
"rawDataTypeNum": 8,
"isPrimaryKey": true,
"isUniqueKey": false,
"fieldPosition": 0
},
{
"fieldName": "topic",
"rawDataTypeNum": 253,
"isPrimaryKey": false,
"isUniqueKey": false,
"fieldPosition": 1
}
],
"nameIndex": {
"id": {
"fieldName": "id",
"rawDataTypeNum": 8,
"isPrimaryKey": true,
"isUniqueKey": false,
"fieldPosition": 0
},
"topic": {
"fieldName": "topic",
"rawDataTypeNum": 253,
"isPrimaryKey": false,
"isUniqueKey": false,
"fieldPosition": 1
}
},
"schemaId": "(hangzhou-test-db,hangzhou-test-db,message_info)",
"databaseName": "hangzhou--test-db",
"tableName": "message_info",
"primaryIndexInfo": {
"indexType": "PrimaryKey",
"indexFields": [
{
"fieldName": "id",
"rawDataTypeNum": 8,
"isPrimaryKey": true,
"isUniqueKey": false,
"fieldPosition": 0
}
],
"cardinality": 0,
"nullable": true,
"isFirstUniqueIndex": false
},
"uniqueIndexInfo": [],
"foreignIndexInfo": [],
"normalIndexInfo": [],
"databaseInfo": {
"databaseType": "MySQL",
"version": "5.7.35-log"
},
"totalRows": 0
},
"beforeImage": {
"recordSchema": {
"recordFields": [
{
"fieldName": "id",
"rawDataTypeNum": 8,
"isPrimaryKey": true,
"isUniqueKey": false,
"fieldPosition": 0
},
{
"fieldName": "topic",
"rawDataTypeNum": 253,
"isPrimaryKey": false,
"isUniqueKey": false,
"fieldPosition": 1
}
],
"nameIndex": {
"id": {
"fieldName": "id",
"rawDataTypeNum": 8,
"isPrimaryKey": true,
"isUniqueKey": false,
"fieldPosition": 0
},
"topic": {
"fieldName": "topic",
"rawDataTypeNum": 253,
"isPrimaryKey": false,
"isUniqueKey": false,
"fieldPosition": 1
}
},
"schemaId": "(hangzhou-test-db,hangzhou-test-db,message_info)",
"databaseName": "hangzhou-test-db",
"tableName": "message_info",
"primaryIndexInfo": {
"indexType": "PrimaryKey",
"indexFields": [
{
"fieldName": "id",
"rawDataTypeNum": 8,
"isPrimaryKey": true,
"isUniqueKey": false,
"fieldPosition": 0
}
],
"cardinality": 0,
"nullable": true,
"isFirstUniqueIndex": false
},
"uniqueIndexInfo": [],
"foreignIndexInfo": [],
"normalIndexInfo": [],
"databaseInfo": {
"databaseType": "MySQL",
"version": "5.7.35-log"
},
"totalRows": 0
},
"values": [
{
"data": 115
},
{
"data": {
"hb": [
104,
101,
108,
108,
111
],
"offset": 0,
"isReadOnly": false,
"bigEndian": true,
"nativeByteOrder": false,
"mark": -1,
"position": 0,
"limit": 9,
"capacity": 9,
"address": 0
},
"charset": "utf8mb4"
}
],
"size": 45
},
"afterImage": {
"recordSchema": {
"recordFields": [
{
"fieldName": "id",
"rawDataTypeNum": 8,
"isPrimaryKey": true,
"isUniqueKey": false,
"fieldPosition": 0
},
{
"fieldName": "topic",
"rawDataTypeNum": 253,
"isPrimaryKey": false,
"isUniqueKey": false,
"fieldPosition": 1
}
],
"nameIndex": {
"id": {
"fieldName": "id",
"rawDataTypeNum": 8,
"isPrimaryKey": true,
"isUniqueKey": false,
"fieldPosition": 0
},
"topic": {
"fieldName": "topic",
"rawDataTypeNum": 253,
"isPrimaryKey": false,
"isUniqueKey": false,
"fieldPosition": 1
}
},
"schemaId": "(hangzhou-test-db,hangzhou-test-db,message_info)",
"databaseName": "hangzhou-test-db",
"tableName": "message_info",
"primaryIndexInfo": {
"indexType": "PrimaryKey",
"indexFields": [
{
"fieldName": "id",
"rawDataTypeNum": 8,
"isPrimaryKey": true,
"isUniqueKey": false,
"fieldPosition": 0
}
],
"cardinality": 0,
"nullable": true,
"isFirstUniqueIndex": false
},
"uniqueIndexInfo": [],
"foreignIndexInfo": [],
"normalIndexInfo": [],
"databaseInfo": {
"databaseType": "MySQL",
"version": "5.7.35-log"
},
"totalRows": 0
},
"values": [
{
"data": 115
},
{
"data": {
"hb": [
98,
121,
101
],
"offset": 0,
"isReadOnly": false,
"bigEndian": true,
"nativeByteOrder": false,
"mark": -1,
"position": 0,
"limit": 11,
"capacity": 11,
"address": 0
},
"charset": "utf8mb4"
}
],
"size": 47
}
},
"id": "12f701a43741d404fa9a7be89d9acae0-321****",
"source": "DTSstreamDemo",
"specversion": "1.0",
"type": "dts:ConsumeMessage",
"datacontenttype": "application/json; charset=utf-8",
"time": "2022-06-10T07:55:57Z",
"subject": "acs:dts:cn-hangzhou:12345****:kk123abc60g782/dtsabcdet1ro"
}data字段包含的參數解釋如下表所示。關于CloudEvents規范中定義的參數解釋，請參見事件概述。
參數 | 類型 | 示例值 | 描述 | |||
id | String | 321**** | DTS數據ID。 | |||
topicPartition | Array | Topic的分區信息。 | ||||
hash | String | 0 | DTS底層存儲參數。 | |||
partition | String | 0 | Topic的分區。 | |||
topic | String | cn_hangzhou_rm_1234****_test_version2 | Topic的名稱。 | |||
offset | Int | 3218099 | DTS數據對應的消息存儲位點。 | |||
sourceTimestamp | Int | 1654847757 | DTS數據生成時間戳。 | |||
operationType | String | UPDATE | DTS數據的操作類型。 | |||
schema | Array | 數據庫表結構信息。 | ||||
recordFields | Array | 字段詳情記錄。 | ||||
fieldName | String | id | 字段名稱。 | |||
rawDataTypeNum | Int | 8 | 字段類型映射值。 | |||
isPrimaryKey | Boolean | true | 字段是否是主鍵。 | |||
isUniqueKey | Boolean | false | 字段是否是唯一值。 | |||
fieldPosition | String | 0 | 字段位置。 | |||
nameIndex | Array | 命名索引。 | ||||
schemaId | String | (hangzhou-test-db,hangzhou-test-db,message_info) | 數據庫表結構信息的ID。 | |||
databaseName | String | hangzhou--test-db | 數據庫名稱。 | |||
tableName | String | message_info | 數據表名稱。 | |||
primaryIndexInfo | Array | 主鍵索引。 | ||||
indexType | String | PrimaryKey | 主鍵索引類型。 | |||
indexFields | Array | 主鍵索引字段內容。 | ||||
cardinality | String | 0 | 主鍵基數。 | |||
nullable | Boolean | true | 主鍵是否可為null。 | |||
isFirstUniqueIndex | Boolean | false | 是否是第一個唯一索引。 | |||
uniqueIndexInfo | String | [] | 唯一索引。 | |||
foreignIndexInfo | String | [] | 外鍵索引。 | |||
normalIndexInfo | String | [] | 普通索引。 | |||
databaseInfo | Array | 數據庫信息。 | ||||
databaseType | String | MySQL | 數據庫類型。 | |||
version | String | 5.7.35-log | 數據庫版本。 | |||
totalRows | Int | 0 | 數據表的總行數。 | |||
beforeImage | String | 操作前記錄字段內容鏡像。 | ||||
values | String | 記錄字段的值。 | ||||
size | Int | 47 | 記錄字段大小。 | |||
afterImage | String | 操作后記錄字段內容鏡像。 | ||||
MQTT調度
[
{
"specversion":"1.0",
"id":"AC1EC0C950650816F27D46F7D7CA****",
"source":"acs:mqtt",
"type":"mqtt:Topic:SendMessage",
"subject":"acs:mq:cn-hangzhou:143998900779****:topic/mqtt-cn-2r42qam****/housekee****",
"datacontenttype":"application/json; charset\u003dutf-8",
"time":"2022-06-22T03:53:47.959Z",
"aliyunaccountid":"143998900779****",
"data":{
"props":{
"firstTopic":"housekee****",
"secondTopic":"/testMq4****",
"clientId":"GID_****"
},
"body":"TEST"
}
}
]data字段包含的參數解釋如下表所示。關于CloudEvents規范中定義的參數解釋，請參見事件概述。
參數 | 類型 | 示例值 | 描述 |
props | Map | 消息屬性。 | |
firstTopic | String | housekee**** | 用于收發消息的父級Topic。 |
secondTopic | String | /testMq4**** | 子級Topic。 |
clientId | String | GID_**** | 客戶端ID。 |
body | String | TEST | 消息內容。 |