工作流调度简介

工作流的执行可以通过控制台或调用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中query的内容,不包括请求Webhook的Token。

云产品事件调度

{
    "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

是否有消息轨迹。取值说明如下:

  • true:有消息轨迹。

  • false:无消息轨迹。

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

是否支持重发消息。取值说明如下:

  • true:支持

  • 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

消息内容。