All Products
Search

This Product

    Function Compute:Trigger event format

    Document Center

    Function Compute:Trigger event format

    Last Updated:Apr 01, 2026

    Each trigger type in Function Compute passes a different event structure to your function handler. Parse the event parameter to extract the fields your business logic needs.

    Usage notes

    Parse the event payload before use. For sample parsing code, see Example 1: Parse JSON-formatted parameters.

    HTTP triggers

    HTTP trigger handlers receive request and response objects instead of an event object, so the event formats described in this topic do not apply. For details, see Configure an HTTP trigger.

    Time triggers

    {
    "triggerTime":"2023-12-26T07:49:00Z",
    "triggerName":"timer-trigger",
    "payload":"awesome-fc"
}
    ParameterTypeExampleDescription
    triggerTimeString2023-12-26T07:49:00ZThe time when the function is triggered.
    triggerNameStringtimer-triggerThe name of the time trigger.
    payloadStringawesome-fcThe custom value set in the Trigger Message parameter when the trigger was created.

    OSS triggers

    {
    "events": [
        {
            "eventName": "ObjectCreated:PutObject",
            "eventSource": "acs:oss",
            "eventTime": "2022-08-13T06:45:43.000Z",
            "eventVersion": "1.0",
            "oss": {
                "bucket": {
                    "arn": "acs:oss:cn-hangzhou:123456789:testbucket",
                    "name": "testbucket",
                    "ownerIdentity": "164901546557****"
                },
                "object": {
                    "deltaSize": 122539,
                    "eTag": "688A7BF4F233DC9C88A80BF985AB****",
                    "key": "source/a.png",
                    "objectMeta": {
                       "mimeType": "application/zip",
                       "userMeta": {
                          "x-oss-meta-last-modified":"20250213"
                       }
                    },
                    "size": 122539
                },
                "ossSchemaVersion": "1.0",
                "ruleId": "9adac8e253828f4f7c0466d941fa3db81161****"
            },
            "region": "cn-hangzhou",
            "requestParameters": {
                "sourceIPAddress": "140.205.XX.XX"
            },
            "responseElements": {
                "requestId": "58F9FF2D3DF792092E12044C"
            },
            "userIdentity": {
                "principalId": "164901546557****"
            }
        }
    ]
}
    ParameterTypeExampleDescription
    eventNameStringObjectCreated:PutObjectThe event type.
    eventSourceStringacs:ossThe event source. Fixed value: acs:oss.
    eventTimeString2022-08-13T06:45:43.000ZThe time when the event occurred, in ISO 8601 format.
    eventVersionString1.0The event protocol version.
    ossMap—The event content.
    bucketMap—The bucket details.
    bucket.nameStringtestbucketThe bucket name.
    bucket.arnStringacs:oss:cn-hangzhou:123456789:testbucketThe Alibaba Cloud Resource Name (ARN) of the bucket.
    bucket.ownerIdentityString164901546557****The ID of the user who created the bucket.
    objectMap—The object details.
    object.sizeInt122539The object size, in bytes.
    object.deltaSizeInt122539The change in object size, in bytes. For a new object, this equals the object size. For an overwritten object, this is the difference between the new and old object sizes.
    object.eTagString688A7BF4F233DC9C88A80BF985AB****The object ETag.
    object.keyStringsource/a.pngThe object name.
    object.objectMetaMap—The object metadata.
    object.objectMeta.mimeTypeStringapplication/zipThe object content type. For details, see How do I configure the Content-Type header?
    object.objectMeta.userMetaMap—User-defined metadata. Identifies the purpose or attributes of the object.
    x-oss-meta-last-modifiedString20250213A user metadata key-value pair. Keys must start with x-oss-meta-. In this example, "x-oss-meta-last-modified":"20250213" records the date the object was last modified on the source machine. For details, see User metadata.
    ossSchemaVersionString1.0The OSS schema version.
    ruleIdString9adac8e253828f4f7c0466d941fa3db81161****The ID of the rule that matched the event.
    regionStringcn-hangzhouThe region where the bucket resides.
    requestParametersMap—The request parameters.
    requestParameters.sourceIPAddressString140.205.XX.XXThe IP address of the request sender.
    responseElementsMap—The response details.
    responseElements.requestIdString58F9FF2D3DF792092E12044CThe request ID.
    userIdentityMap—The user identity.
    userIdentity.principalIdString164901546557****The ID of the Alibaba Cloud account that initiated the request.

    Simple Log Service triggers

    {
    "parameter": {},
    "source": {
        "endpoint": "http://cn-hangzhou-intranet.log.aliyuncs.com",
        "projectName": "aliyun-fc-cn-hangzhou-2238f0df-a742-524f-9f90-976ba457****",
        "logstoreName": "function-log",
        "shardId": 0,
        "beginCursor": "MTUyOTQ4MDIwOTY1NTk3ODQ2Mw==",
        "endCursor": "MTUyOTQ4MDIwOTY1NTk3ODQ2NA=="
    },
    "jobName": "1f7043ced683de1a4e3d8d70b5a412843d81****",
    "taskId": "c2691505-38da-4d1b-998a-f1d4bb8c****",
    "cursorTime": 1529486425
}
    ParameterDescriptionExample
    parameterThe invocation parameters configured when the trigger was created.—
    sourceThe log block for the function to read from Simple Log Service. Fields: endpoint (the Simple Log Service project region endpoint), projectName (the project name), logstoreName (the Logstore name), shardId (the shard ID), beginCursor (the start offset for data consumption), endCursor (the end offset for data consumption).See example above.
    jobNameThe ETL job name in Simple Log Service. Simple Log Service triggers must correspond to ETL jobs.1f7043ced683de1a4e3d8d70b5a412843d81****
    taskIdThe identifier for a specific function invocation within an ETL job.c2691505-38da-4d1b-998a-f1d4bb8c****
    cursorTimeThe UNIX timestamp of the last log entry that arrived at Simple Log Service.1529486425

    Alibaba Cloud CDN triggers

    CDN triggers support four event types: LogFileCreated, CachedObjectsRefreshed / CachedObjectsPushed, CdnDomainStarted / CdnDomainStopped, and CdnDomainAdded / CdnDomainDeleted. All events share a common top-level structure; the eventParameter fields vary by event type.

    All CDN events share the following top-level fields:

    ParameterTypeExampleDescription
    eventNameStringLogFileCreatedThe event type.
    eventSourceStringcdnThe event source.
    regionStringcn-hangzhouThe region of Alibaba Cloud CDN.
    eventVersionString1.0.0The event protocol version.
    eventTimeString2018-06-14T15:31:49+08:00The time when the event occurred.
    traceIdStringc6459282-6a4d-4413-894c-e4ea3968****The trace ID for troubleshooting, provided by the event source.
    userIdentity.aliUidString164901546557****The ID of the Alibaba Cloud account that created the namespace.
    resource.domainStringexample.comThe endpoint.
    eventParameterMap—Event-specific parameters. See the tables below.

    LogFileCreated

    Replace filePath with the path of Alibaba Cloud CDN logs or a test file.

    {
    "events": [
        {
            "eventName": "LogFileCreated",
            "eventSource": "cdn",
            "region": "cn-hangzhou",
            "eventVersion": "1.0.0",
            "eventTime": "2018-06-14T15:31:49+08:00",
            "traceId": "c6459282-6a4d-4413-894c-e4ea3968****",
            "userIdentity": {
                "aliUid": "164901546557****"
            },
            "resource": {
                "domain": "example.com"
            },
            "eventParameter": {
                "domain": "example.com",
                "endTime": 1528959900,
                "fileSize": 1788115,
                "filePath": "http://cdnlog.cn-hangzhou.oss.aliyun-inc.com/www.aliyun.com/2017_12_27/www.aliyun.com_2017_12_27_0800_0900.gz?OSSAccessKeyId=xxxx&Expires=xxxx&Signature=xxxx",
                "startTime": 1528959600
            }
        }
    ]
}

    eventParameter fields for LogFileCreated:

    ParameterTypeExampleDescription
    domainStringexample.comThe endpoint.
    startTimeString1528959600The start time of the log file.
    endTimeString1528959900The end time of the log file.
    fileSizeString1788115The size of the log file.
    filePathStringhttp://cdnlog.cn-hangzhou.oss.aliyun-inc.com/...The location of the log file.

    CachedObjectsRefreshed and CachedObjectsPushed

    {
    "events": [
        {
            "eventName": "CachedObjectsRefreshed",
            "eventVersion": "1.0.0",
            "eventSource": "cdn",
            "region": "cn-hangzhou",
            "eventTime": "2018-03-16T14:19:55+08:00",
            "traceId": "cf89e5a8-7d59-4bb5-a33e-4c3d08e2****",
            "resource": {
                "domain": "example.com"
            },
            "eventParameter": {
                "objectPath": [
                    "/2018/03/16/13/33b430c57e7.mp4",
                    "/2018/03/16/14/4ff6b9bd54d.mp4"
                ],
                "createTime": 1521180769,
                "domain": "example.com",
                "completeTime": 1521180777,
                "objectType": "File",
                "taskId": 2089687230
            },
            "userIdentity": {
                "aliUid": "164901546557****"
            }
        }
    ]
}

    eventParameter fields for CachedObjectsRefreshed and CachedObjectsPushed:

    ParameterTypeExampleDescription
    domainStringexample.comThe endpoint.
    objectPathString/2018/03/16/13/33b430c57e7.mp4The resource identifier.
    createTimeString1521180769The start time of the refresh.
    completeTimeString1521180777The end time of the refresh.
    objectTypeStringFileThe item that is refreshed. Valid values: File, Directory.
    taskIdString2089687230The ID of the refresh task.

    CdnDomainStarted and CdnDomainStopped

    {
    "events": [
        {
            "eventName": "CdnDomainStarted",
            "eventVersion": "1.0.0",
            "eventSource": "cdn",
            "region": "cn-hangzhou",
            "eventTime": "2018-03-16T14:19:55+08:00",
            "traceId": "cf89e5a8-7d59-4bb5-a33e-4c3d08e2****",
            "resource": {
                "domain": "example.com"
            },
            "eventParameter": {
                "domain": "example.com",
                "status": "online"
            },
            "userIdentity": {
                "aliUid": "164901546557****"
            }
        }
    ]
}

    eventParameter fields for CdnDomainStarted and CdnDomainStopped:

    ParameterTypeExampleDescription
    domainStringexample.comThe endpoint.
    statusStringonlineThe status of the accelerated domain name.

    CdnDomainAdded and CdnDomainDeleted

    {
    "events": [
        {
            "eventName": "CdnDomainAdded",
            "eventVersion": "1.0.0",
            "eventSource": "cdn",
            "region": "cn-hangzhou",
            "eventTime": "2018-03-16T14:19:55+08:00",
            "traceId": "cf89e5a8-7d59-4bb5-a33e-4c3d08e2****",
            "resource": {
                "domain": "example.com"
            },
            "eventParameter": {
                "domain": "example.com"
            },
            "userIdentity": {
                "aliUid": "164901546557****"
            }
        }
    ]
}

    eventParameter fields for CdnDomainAdded and CdnDomainDeleted:

    ParameterTypeExampleDescription
    domainStringexample.comThe endpoint.

    Tablestore triggers

    {
    "Version": "Sync-v1",
    "Records": [
        {
            "Type": "PutRow",
            "Info": {
                "Timestamp": 1506416585740836
            },
            "PrimaryKey": [
                {
                    "ColumnName": "pk_0",
                    "Value": 1506416585881590900
                },
                {
                    "ColumnName": "pk_1",
                    "Value": "2017-09-26 17:03:05.8815909 +0800 CST"
                },
                {
                    "ColumnName": "pk_2",
                    "Value": 1506416585741000
                }
            ],
            "Columns": [
                {
                    "Type": "Put",
                    "ColumnName": "attr_0",
                    "Value": "hello_table_store",
                    "Timestamp": 1506416585741
                },
                {
                    "Type": "Put",
                    "ColumnName": "attr_1",
                    "Value": 1506416585881590900,
                    "Timestamp": 1506416585741
                }
            ]
        }
    ]
}
    ParameterDescription
    VersionThe payload version. Example: Sync-v1. Type: String.
    RecordsAn array of incremental data rows. Each element contains Type (the row operation type; valid values: PutRow, UpdateRow, DeleteRow; type: String) and Info (row metadata, including Timestamp, the time of the last modification in UTC; type: INT64).
    PrimaryKeyAn array of primary key columns. Each element contains ColumnName (the column name; type: String) and Value (the column value; type: formated_value, which can be INTEGER, STRING, or BLOB).
    ColumnsAn array of attribute columns. Each element contains Type (the operation type; valid values: Put, DeleteOneVersion, DeleteAllVersions; type: String), ColumnName (the column name; type: String), Value (the column value; type: formatted_value, which can be INTEGER, BOOLEAN, DOUBLE, STRING, or BLOB), and Timestamp (the time of the last modification in UTC; type: INT64).

    Simple Message Queue (formerly MNS) topic triggers

    The event format depends on the Event Format setting configured for the trigger.

    STREAM format

    Without message attributes — the event is a plain JSON string:

    'hello topic'
    When messages have no attributes, the event content is a JSON-formatted string.

    With message attributes — the event includes attribute key-value pairs:

    The event content includes key-value pairs from the message attributes. For details, see PublishMessage.
    {
    "body": "hello topic",
    "attrs": {
        "Extend": "{\"key\":\"value\"}"
    }
}

    JSON format

    Without message attributes:

    {
    "TopicOwner": "118620210433****",
    "Message": "hello topic",
    "Subscriber": "118620210433****",
    "PublishTime": 1550216480040,
    "SubscriptionName": "test-fc-subscribe",
    "MessageMD5": "BA4BA9B48AC81F0F9C66F6C909C3****",
    "TopicName": "Mytopic",
    "MessageId": "2F5B3C082B923D4EAC694B76D928****"
}

    With message attributes — the event includes the attribute key-value pairs in addition to the standard fields:

    The event content includes key-value pairs from the message attributes. For details, see PublishMessage.
    {
    "key": "value",
    "TopicOwner": "118620210433****",
    "Message": "hello topic",
    "Subscriber": "118620210433****",
    "PublishTime": 1550216302888,
    "SubscriptionName": "test-fc-subscribe",
    "MessageMD5": "BA4BA9B48AC81F0F9C66F6C909C3****",
    "TopicName": "Mytopic",
    "MessageId": "2F5B3C281B283D4EAC694B742528****"
}

    JSON format event parameters:

    ParameterTypeExampleDescription
    keyStringvalueThe message attribute key-value pairs.
    TopicOwnerString118620210433****The account ID of the Simple Message Queue (formerly MNS) topic owner.
    MessageStringhello topicThe message body.
    SubscriberString118620210433****The account ID of the topic subscriber.
    PublishTimeInt1550216302888The time when the message was published.
    SubscriptionNameStringtest-fc-subscribeThe subscription name.
    MessageMD5StringBA4BA9B48AC81F0F9C66F6C909C3****The MD5 hash of the message body.
    TopicNameStringMytopicThe Simple Message Queue (formerly MNS) topic name.
    MessageIdString2F5B3C281B283D4EAC694B742528****The message ID.

    MNS queue triggers

    The event is an array of CloudEvents-formatted messages. For CloudEvents specification fields (specversion, id, source, type, datacontenttype, subject, time, and Alibaba Cloud extension fields), see Overview.

    [
    {
        "id":"c2g71017-6f65-fhcf-a814-a396fc8d****",
        "source":"MNS-Function-mnstrigger",
        "specversion":"1.0",
        "type":"mns:Queue:SendMessage",
        "datacontenttype":"application/json; charset=utf-8",
        "subject":"acs:mns:cn-hangzhou:164901546557****:queues/zeus",
        "time":"2021-04-08T06:28:17.093Z",
        "aliyunaccountid":"164901546557****",
        "aliyunpublishtime":"2021-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 fields:

    ParameterTypeExampleDescription
    requestIdString606EA3074344430D4C81****The request ID. Each request has a unique ID.
    messageIdStringC6DB60D1574661357FA227277445****The message ID. Each message has a unique ID.
    messageBodyStringTESTThe message body.

    ApsaraMQ for RocketMQ triggers

    The event is an array of CloudEvents-formatted messages. For CloudEvents specification fields, see Overview.

    [
    {
        "id":"94ebc15f-f0db-4bbe-acce-56fb72fb****",
        "source":"RocketMQ-Function-rocketmq-trigger",
        "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":"2021-04-08T06:01:20.766Z",
        "aliyunaccountid":"164901546557****",
        "aliyunpublishtime":"2021-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 fields:

    ParameterTypeExampleDescription
    topicStringTopicNameThe topic name.
    systemPropertiesMap—The system properties.
    systemProperties.MIN_OFFSETInt0The earliest offset.
    systemProperties.TRACE_ONBooleantrueWhether a message trace exists. Valid values: true, false.
    systemProperties.MAX_OFFSETInt8The latest offset.
    systemProperties.MSG_REGIONStringcn-hangzhouThe region where the message was sent.
    systemProperties.KEYSStringsystemProperties.KEYSThe keys used to filter messages.
    systemProperties.CONSUME_START_TIMELong1628577790396The start time of message consumption, in milliseconds.
    systemProperties.UNIQ_KEYStringAC14C305069E1B28CDFA3181CDA2****The unique key of the message.
    systemProperties.TAGSStringsystemProperties.TAGSThe tags used to filter messages.
    systemProperties.INSTANCE_IDStringMQ_INST_123456789098****_BXhFHryiThe ApsaraMQ for RocketMQ instance ID.
    userPropertiesMap—User-defined properties.
    bodyStringTESTThe message body.

    ApsaraMQ for RabbitMQ triggers

    The event is an array of CloudEvents-formatted messages. For CloudEvents specification fields, see Overview.

    [
    {
        "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":"2021-08-12T06:56:40.709Z",
        "aliyunaccountid":"164901546557****",
        "aliyunpublishtime":"2021-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 fields:

    ParameterTypeExampleDescription
    bodyMap—The message body.
    body.HelloStringEventBridgeUser data.
    propsMap—The message attributes.
    props.contentEncodingStringutf-8The encoding format of the message body.
    props.messageIdStringf7622d51-e198-41de-a072-77c1ead7****The message ID. Each message has a unique ID.
    envelopeMap—The message envelope.
    envelope.deliveryTagInt98The delivery tag.
    envelope.exchangeString—The exchange that routed the message.
    envelope.redeliverBooleanfalseWhether the message is a redelivery. Valid values: true, false.
    envelope.routingKeyStringhousekeepingThe routing key of the message.

    ApsaraMQ for Kafka triggers

    The event is an array of CloudEvents-formatted messages. For CloudEvents specification fields, see Overview.

    [
    {
        "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":"2022-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 fields:

    ParameterTypeExampleDescription
    topicStringTopicNameThe topic name.
    partitionInt1The partition on the ApsaraMQ for Kafka instance.
    offsetInt0The message offset.
    timestampString1655952591589The timestamp when message consumption started.

    DTS triggers

    The event is an array of CloudEvents-formatted messages. For CloudEvents specification fields, see Overview.

    [
  {
    "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
          }
        ],
        "schemaId": "(hangzhou-test-db,hangzhou-test-db,message_info)",
        "databaseName": "hangzhou--test-db",
        "tableName": "message_info",
        "primaryIndexInfo": {
          "indexType": "PrimaryKey",
          "indexFields": [...],
          "cardinality": 0,
          "nullable": true,
          "isFirstUniqueIndex": false
        },
        "databaseInfo": {
          "databaseType": "MySQL",
          "version": "5.7.35-log"
        },
        "totalRows": 0
      },
      "beforeImage": { ... },
      "afterImage": { ... }
    },
    "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 fields:

    ParameterTypeDescription
    idStringThe DTS data entry ID.
    topicPartitionArrayThe partition details of the topic to which the event is pushed.
    topicPartition.hashStringThe underlying storage parameter of DTS.
    topicPartition.partitionStringThe partition.
    topicPartition.topicStringThe topic name.
    offsetIntThe offset of the DTS data entry.
    sourceTimestampIntThe timestamp when the DTS data entry was generated.
    operationTypeStringThe operation type of the DTS data entry.
    schemaArrayThe database schema information.
    schema.recordFieldsArrayThe field details.
    schema.recordFields[].fieldNameStringThe field name.
    schema.recordFields[].rawDataTypeNumIntThe mapped value of the field type. Corresponds to the dataTypeNumber field in deserialized incremental data from the change tracking instance. For details, see Use a Kafka client to consume tracked data.
    schema.recordFields[].isPrimaryKeyBooleanWhether the field is a primary key.
    schema.recordFields[].isUniqueKeyBooleanWhether the field has a unique key.
    schema.recordFields[].fieldPositionStringThe field position.
    schema.nameIndexArrayThe indexing information about the fields based on field names.
    schema.schemaIdStringThe database schema ID.
    schema.databaseNameStringThe database name.
    schema.tableNameStringThe table name.
    schema.primaryIndexInfoStringThe primary key index details.
    schema.primaryIndexInfo.indexTypeStringThe index type.
    schema.primaryIndexInfo.indexFieldsArrayThe indexed fields.
    schema.primaryIndexInfo.cardinalityStringThe cardinality of the primary keys.
    schema.primaryIndexInfo.nullableBooleanWhether the primary keys can be null.
    schema.primaryIndexInfo.isFirstUniqueIndexBooleanWhether the index is the first unique index.
    schema.uniqueIndexInfoStringThe unique indexes.
    schema.foreignIndexInfoStringThe foreign key indexes.
    schema.normalIndexInfoStringThe regular indexes.
    schema.databaseInfoArrayThe database details.
    schema.databaseInfo.databaseTypeStringThe database engine.
    schema.databaseInfo.versionStringThe database engine version.
    schema.totalRowsIntThe total number of rows in the table.
    beforeImageStringThe field values before the operation.
    valuesStringThe field values recorded.
    sizeIntThe size of the fields recorded.
    afterImageStringThe field values after the operation.

    ApsaraMQ for MQTT triggers

    [
  {
    "props": {
      "firstTopic": "testTopic",
      "secondTopic": "/testMq4****",
      "clientId": "consumerGroupID@@@xxx"
    },
    "body": "hello mq4Iot pub sub msg"
  }
]
    ParameterTypeExampleDescription
    propsMap—The message attributes.
    props.firstTopicStringtestTopicThe parent topic used to send and receive messages.
    props.secondTopicString/testMq4****The child topic.
    props.clientIdStringconsumerGroupID@@@xxThe client ID.
    bodyStringhello mq4Iot pub sub msgThe message body.

    Self-managed Apache RocketMQ triggers

    [
  {
    "msgId": "7F0000010BDD2A84AEE70DA49B57****",
    "topic": "testTopic",
    "systemProperties": {
      "UNIQ_KEY": "7F0000010BDD2A84AEE70DA49B57****",
      "CLUSTER": "DefaultCluster",
      "MIN_OFFSET": "0",
      "TAGS": "TagA",
      "MAX_OFFSET": "128"
    },
    "userProperties": {},
    "body": "Hello RocketMQ"
  }
]
    ParameterTypeExampleDescription
    msgIdString7F0000010BDD2A84AEE70DA49B57****The Apache RocketMQ message ID.
    topicStringtestTopicThe topic name in the Apache RocketMQ cluster.
    systemPropertiesMap—The system properties.
    systemProperties.UNIQ_KEYString7F0000010BDD2A84AEE70DA49B57****The unique key of the message.
    systemProperties.CLUSTERStringDefaultClusterThe Apache RocketMQ cluster name.
    systemProperties.MIN_OFFSETInt0The minimum offset.
    systemProperties.MAX_OFFSETInt128The maximum offset.
    systemProperties.TAGSStringTagAThe tags used to filter messages.
    userPropertiesMap—User-defined properties.
    bodyStringHello RocketMQThe message body.