Data format of trigger events when triggers invoke functions - Function Compute: Central de Documentação do Alibaba Cloud

Observações de uso

Analise o payload do evento antes de utilizá-lo. Para exemplos de código de análise, consulte Exemplo 1: Analisar parâmetros formatados em JSON.

Gatilhos HTTP

Os handlers de gatilhos HTTP recebem objetos request e response em vez de um objeto event. Portanto, os formatos de evento descritos neste tópico não se aplicam. Para mais detalhes, consulte Configurar um gatilho HTTP.

Gatilhos de tempo

{
    "triggerTime":"2023-12-26T07:49:00Z",
    "triggerName":"timer-trigger",
    "payload":"awesome-fc"
}

Parâmetro	Tipo	Exemplo	Descrição
`triggerTime`	String	`2023-12-26T07:49:00Z`	Momento em que a função é acionada.
`triggerName`	String	`timer-trigger`	Nome do gatilho de tempo.
`payload`	String	`awesome-fc`	Valor personalizado definido no parâmetro Trigger Message durante a criação do gatilho.

Gatilhos OSS

{
    "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****"
            }
        }
    ]
}

Parâmetro	Tipo	Exemplo	Descrição
`eventName`	String	`ObjectCreated:PutObject`	Tipo do evento.
`eventSource`	String	`acs:oss`	Origem do evento. Valor fixo: `acs:oss`.
`eventTime`	String	`2022-08-13T06:45:43.000Z`	Horário de ocorrência do evento, no formato ISO 8601.
`eventVersion`	String	`1.0`	Versão do protocolo do evento.
`oss`	Map	—	Conteúdo do evento.
`bucket`	Map	—	Detalhes do bucket.
`bucket.name`	String	`testbucket`	Nome do bucket.
`bucket.arn`	String	`acs:oss:cn-hangzhou:123456789:testbucket`	Alibaba Cloud Resource Name (ARN) do bucket.
`bucket.ownerIdentity`	String	`164901546557****`	ID do usuário que criou o bucket.
`object`	Map	—	Detalhes do objeto.
`object.size`	Int	`122539`	Tamanho do objeto, em bytes.
`object.deltaSize`	Int	`122539`	Variação no tamanho do objeto, em bytes. Para um novo objeto, equivale ao tamanho total. Para um objeto sobrescrito, representa a diferença entre os tamanhos novo e antigo.
`object.eTag`	String	`688A7BF4F233DC9C88A80BF985AB****`	ETag do objeto.
`object.key`	String	`source/a.png`	Nome do objeto.
`object.objectMeta`	Map	—	Metadados do objeto.
`object.objectMeta.mimeType`	String	`application/zip`	Tipo de conteúdo do objeto. Para mais detalhes, consulte Como configurar o cabeçalho Content-Type?
`object.objectMeta.userMeta`	Map	—	Metadados definidos pelo usuário. Identificam a finalidade ou os atributos do objeto.
`x-oss-meta-last-modified`	String	`20250213`	Par chave-valor de metadados do usuário. As chaves devem começar com `x-oss-meta-`. Neste exemplo, `"x-oss-meta-last-modified":"20250213"` registra a data da última modificação do objeto na máquina de origem. Para mais detalhes, consulte Metadados do usuário.
`ossSchemaVersion`	String	`1.0`	Versão do esquema do OSS.
`ruleId`	String	`9adac8e253828f4f7c0466d941fa3db81161****`	ID da regra correspondente ao evento.
`region`	String	`cn-hangzhou`	Região onde o bucket está localizado.
`requestParameters`	Map	—	Parâmetros da solicitação.
`requestParameters.sourceIPAddress`	String	`140.205.XX.XX`	Endereço IP do remetente da solicitação.
`responseElements`	Map	—	Detalhes da resposta.
`responseElements.requestId`	String	`58F9FF2D3DF792092E12044C`	ID da solicitação.
`userIdentity`	Map	—	Identidade do usuário.
`userIdentity.principalId`	String	`164901546557****`	ID da conta Alibaba Cloud que iniciou a solicitação.

Gatilhos do Simple Log Service

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

Parâmetro	Descrição	Exemplo
`parameter`	Parâmetros de invocação configurados durante a criação do gatilho.	—
`source`	Bloco de logs que a função deve ler no Simple Log Service. Campos: `endpoint` (endpoint da região do projeto do Simple Log Service), `projectName` (nome do projeto), `logstoreName` (nome do Logstore), `shardId` (ID do shard), `beginCursor` (offset inicial para consumo de dados), `endCursor` (offset final para consumo de dados).	Consulte o exemplo acima.
`jobName`	Nome do job ETL no Simple Log Service. Gatilhos do Simple Log Service devem corresponder a jobs ETL.	`1f7043ced683de1a4e3d8d70b5a412843d81****`
`taskId`	Identificador de uma invocação específica da função dentro de um job ETL.	`c2691505-38da-4d1b-998a-f1d4bb8c****`
`cursorTime`	Timestamp UNIX da última entrada de log recebida pelo Simple Log Service.	`1529486425`

Gatilhos do Alibaba Cloud CDN

Os gatilhos CDN suportam quatro tipos de eventos: LogFileCreated, CachedObjectsRefreshed / CachedObjectsPushed, CdnDomainStarted / CdnDomainStopped e CdnDomainAdded / CdnDomainDeleted. Todos os eventos compartilham uma estrutura comum de nível superior; os campos eventParameter variam conforme o tipo de evento.

Todos os eventos CDN compartilham os seguintes campos de nível superior:

Parâmetro	Tipo	Exemplo	Descrição
`eventName`	String	`LogFileCreated`	Tipo do evento.
`eventSource`	String	`cdn`	Origem do evento.
`region`	String	`cn-hangzhou`	Região do Alibaba Cloud CDN.
`eventVersion`	String	`1.0.0`	Versão do protocolo do evento.
`eventTime`	String	`2018-06-14T15:31:49+08:00`	Horário de ocorrência do evento.
`traceId`	String	`c6459282-6a4d-4413-894c-e4ea3968****`	ID de rastreamento para solução de problemas, fornecido pela origem do evento.
`userIdentity.aliUid`	String	`164901546557****`	ID da conta Alibaba Cloud que criou o namespace.
`resource.domain`	String	`example.com`	Endpoint.
`eventParameter`	Map	—	Parâmetros específicos do evento. Consulte as tabelas abaixo.

LogFileCreated

Substitua filePath pelo caminho dos logs do Alibaba Cloud CDN ou de um arquivo de teste.

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

Campos eventParameter para LogFileCreated:

Parâmetro	Tipo	Exemplo	Descrição
`domain`	String	`example.com`	Endpoint.
`startTime`	String	`1528959600`	Horário inicial do arquivo de log.
`endTime`	String	`1528959900`	Horário final do arquivo de log.
`fileSize`	String	`1788115`	Tamanho do arquivo de log.
`filePath`	String	`http://cdnlog.cn-hangzhou.oss.aliyun-inc.com/...`	Localização do arquivo de log.

CachedObjectsRefreshed e 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****"
            }
        }
    ]
}

Campos eventParameter para CachedObjectsRefreshed e CachedObjectsPushed:

Parâmetro	Tipo	Exemplo	Descrição
`domain`	String	`example.com`	Endpoint.
`objectPath`	String	`/2018/03/16/13/33b430c57e7.mp4`	Identificador do recurso.
`createTime`	String	`1521180769`	Horário inicial da atualização.
`completeTime`	String	`1521180777`	Horário final da atualização.
`objectType`	String	`File`	Item atualizado. Valores válidos: `File`, `Directory`.
`taskId`	String	`2089687230`	ID da tarefa de atualização.

CdnDomainStarted e 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****"
            }
        }
    ]
}

Campos eventParameter para CdnDomainStarted e CdnDomainStopped:

Parâmetro	Tipo	Exemplo	Descrição
`domain`	String	`example.com`	Endpoint.
`status`	String	`online`	Status do nome de domínio acelerado.

CdnDomainAdded e 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****"
            }
        }
    ]
}

Campos eventParameter para CdnDomainAdded e CdnDomainDeleted:

Parâmetro	Tipo	Exemplo	Descrição
`domain`	String	`example.com`	Endpoint.

Gatilhos Tablestore

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

Parâmetro	Descrição
`Version`	Versão do payload. Exemplo: `Sync-v1`. Tipo: String.
`Records`	Array de linhas de dados incrementais. Cada elemento contém `Type` (tipo de operação da linha; valores válidos: `PutRow`, `UpdateRow`, `DeleteRow`; tipo: String) e `Info` (metadados da linha, incluindo `Timestamp`, horário da última modificação em UTC; tipo: INT64).
`PrimaryKey`	Array de colunas de chave primária. Cada elemento contém `ColumnName` (nome da coluna; tipo: String) e `Value` (valor da coluna; tipo: `formated_value`, podendo ser INTEGER, STRING ou BLOB).
`Columns`	Array de colunas de atributo. Cada elemento contém `Type` (tipo de operação; valores válidos: `Put`, `DeleteOneVersion`, `DeleteAllVersions`; tipo: String), `ColumnName` (nome da coluna; tipo: String), `Value` (valor da coluna; tipo: `formatted_value`, podendo ser INTEGER, BOOLEAN, DOUBLE, STRING ou BLOB) e `Timestamp` (horário da última modificação em UTC; tipo: INT64).

Gatilhos de tópico do Simple Message Queue (antigo MNS)

O formato do evento depende da configuração Event Format definida para o gatilho.

Formato STREAM

Sem atributos de mensagem — o evento é uma string JSON simples:

'hello topic'

Quando as mensagens não possuem atributos, o conteúdo do evento é uma string formatada em JSON.

Com atributos de mensagem — o evento inclui pares chave-valor de atributos:

O conteúdo do evento inclui pares chave-valor provenientes dos atributos da mensagem. Para mais detalhes, consulte PublishMessage .

{
    "body": "hello topic",
    "attrs": {
        "Extend": "{\"key\":\"value\"}"
    }
}

Formato JSON

Sem atributos de mensagem:

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

Com atributos de mensagem — o evento inclui os pares chave-valor dos atributos além dos campos padrão:

O conteúdo do evento inclui pares chave-valor provenientes dos atributos da mensagem. Para mais detalhes, consulte PublishMessage .

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

Parâmetros de evento no formato JSON:

Parâmetro	Tipo	Exemplo	Descrição
`key`	String	`value`	Pares chave-valor dos atributos da mensagem.
`TopicOwner`	String	`118620210433****`	ID da conta proprietária do tópico do Simple Message Queue (antigo MNS).
`Message`	String	`hello topic`	Corpo da mensagem.
`Subscriber`	String	`118620210433****`	ID da conta assinante do tópico.
`PublishTime`	Int	`1550216302888`	Horário de publicação da mensagem.
`SubscriptionName`	String	`test-fc-subscribe`	Nome da assinatura.
`MessageMD5`	String	`BA4BA9B48AC81F0F9C66F6C909C3****`	Hash MD5 do corpo da mensagem.
`TopicName`	String	`Mytopic`	Nome do tópico do Simple Message Queue (antigo MNS).
`MessageId`	String	`2F5B3C281B283D4EAC694B742528****`	ID da mensagem.

Gatilhos de fila MNS

O evento consiste em um array de mensagens formatadas em CloudEvents. Para os campos da especificação CloudEvents (specversion, id, source, type, datacontenttype, subject, time e campos de extensão da Alibaba Cloud), consulte Visão geral.

[
    {
        "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"
        }
    }
]

Campos data:

Parâmetro	Tipo	Exemplo	Descrição
`requestId`	String	`606EA3074344430D4C81****`	ID da solicitação. Cada solicitação possui um ID exclusivo.
`messageId`	String	`C6DB60D1574661357FA227277445****`	ID da mensagem. Cada mensagem possui um ID exclusivo.
`messageBody`	String	`TEST`	Corpo da mensagem.

Gatilhos ApsaraMQ for RocketMQ

O evento consiste em um array de mensagens formatadas em CloudEvents. Para os campos da especificação CloudEvents, consulte Visão geral.

[
    {
        "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"
        }
    }
]

Campos data:

Parâmetro	Tipo	Exemplo	Descrição
`topic`	String	`TopicName`	Nome do tópico.
`systemProperties`	Map	—	Propriedades do sistema.
`systemProperties.MIN_OFFSET`	Int	`0`	Offset mais antigo.
`systemProperties.TRACE_ON`	Boolean	`true`	Indica se existe rastreamento de mensagem. Valores válidos: `true`, `false`.
`systemProperties.MAX_OFFSET`	Int	`8`	Offset mais recente.
`systemProperties.MSG_REGION`	String	`cn-hangzhou`	Região de envio da mensagem.
`systemProperties.KEYS`	String	`systemProperties.KEYS`	Chaves utilizadas para filtrar mensagens.
`systemProperties.CONSUME_START_TIME`	Long	`1628577790396`	Horário inicial do consumo da mensagem, em milissegundos.
`systemProperties.UNIQ_KEY`	String	`AC14C305069E1B28CDFA3181CDA2****`	Chave exclusiva da mensagem.
`systemProperties.TAGS`	String	`systemProperties.TAGS`	Tags utilizadas para filtrar mensagens.
`systemProperties.INSTANCE_ID`	String	`MQ_INST_123456789098****_BXhFHryi`	ID da instância ApsaraMQ for RocketMQ.
`userProperties`	Map	—	Propriedades definidas pelo usuário.
`body`	String	`TEST`	Corpo da mensagem.

Gatilhos ApsaraMQ for RabbitMQ

O evento consiste em um array de mensagens formatadas em CloudEvents. Para os campos da especificação CloudEvents, consulte Visão geral.

[
    {
        "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****"
            }
        }
    }
]

Campos data:

Parâmetro	Tipo	Exemplo	Descrição
`body`	Map	—	Corpo da mensagem.
`body.Hello`	String	`EventBridge`	Dados do usuário.
`props`	Map	—	Atributos da mensagem.
`props.contentEncoding`	String	`utf-8`	Formato de codificação do corpo da mensagem.
`props.messageId`	String	`f7622d51-e198-41de-a072-77c1ead7****`	ID da mensagem. Cada mensagem possui um ID exclusivo.
`envelope`	Map	—	Envelope da mensagem.
`envelope.deliveryTag`	Int	`98`	Tag de entrega.
`envelope.exchange`	String	—	Exchange que roteou a mensagem.
`envelope.redeliver`	Boolean	`false`	Indica se a mensagem é uma reentrega. Valores válidos: `true`, `false`.
`envelope.routingKey`	String	`housekeeping`	Chave de roteamento da mensagem.

Gatilhos ApsaraMQ for Kafka

O evento consiste em um array de mensagens formatadas em CloudEvents. Para os campos da especificação CloudEvents, consulte Visão geral.

[
    {
        "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"
        }
    }
]

Campos data:

Parâmetro	Tipo	Exemplo	Descrição
`topic`	String	`TopicName`	Nome do tópico.
`partition`	Int	`1`	Partição na instância ApsaraMQ for Kafka.
`offset`	Int	`0`	Offset da mensagem.
`timestamp`	String	`1655952591589`	Timestamp de início do consumo da mensagem.

Gatilhos DTS

O evento consiste em um array de mensagens formatadas em CloudEvents. Para os campos da especificação CloudEvents, consulte Visão geral.

[
  {
    "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"
  }
]

Campos data:

Parâmetro	Tipo	Descrição
`id`	String	ID da entrada de dados DTS.
`topicPartition`	Array	Detalhes da partição do tópico para o qual o evento é enviado.
`topicPartition.hash`	String	Parâmetro de armazenamento subjacente do DTS.
`topicPartition.partition`	String	Partição.
`topicPartition.topic`	String	Nome do tópico.
`offset`	Int	Offset da entrada de dados DTS.
`sourceTimestamp`	Int	Timestamp de geração da entrada de dados DTS.
`operationType`	String	Tipo de operação da entrada de dados DTS.
`schema`	Array	Informações do esquema do banco de dados.
`schema.recordFields`	Array	Detalhes dos campos.
`schema.recordFields[].fieldName`	String	Nome do campo.
`schema.recordFields[].rawDataTypeNum`	Int	Valor mapeado do tipo de campo. Corresponde ao campo `dataTypeNumber` nos dados incrementais desserializados da instância de rastreamento de alterações. Para mais detalhes, consulte Usar um cliente Kafka para consumir dados rastreados.
`schema.recordFields[].isPrimaryKey`	Boolean	Indica se o campo é uma chave primária.
`schema.recordFields[].isUniqueKey`	Boolean	Indica se o campo possui uma chave exclusiva.
`schema.recordFields[].fieldPosition`	String	Posição do campo.
`schema.nameIndex`	Array	Informações de indexação dos campos baseadas em nomes.
`schema.schemaId`	String	ID do esquema do banco de dados.
`schema.databaseName`	String	Nome do banco de dados.
`schema.tableName`	String	Nome da tabela.
`schema.primaryIndexInfo`	String	Detalhes do índice de chave primária.
`schema.primaryIndexInfo.indexType`	String	Tipo de índice.
`schema.primaryIndexInfo.indexFields`	Array	Campos indexados.
`schema.primaryIndexInfo.cardinality`	String	Cardinalidade das chaves primárias.
`schema.primaryIndexInfo.nullable`	Boolean	Indica se as chaves primárias podem ser nulas.
`schema.primaryIndexInfo.isFirstUniqueIndex`	Boolean	Indica se o índice é o primeiro índice exclusivo.
`schema.uniqueIndexInfo`	String	Índices exclusivos.
`schema.foreignIndexInfo`	String	Índices de chave estrangeira.
`schema.normalIndexInfo`	String	Índices regulares.
`schema.databaseInfo`	Array	Detalhes do banco de dados.
`schema.databaseInfo.databaseType`	String	Mecanismo do banco de dados.
`schema.databaseInfo.version`	String	Versão do mecanismo do banco de dados.
`schema.totalRows`	Int	Número total de linhas na tabela.
`beforeImage`	String	Valores dos campos antes da operação.
`values`	String	Valores dos campos registrados.
`size`	Int	Tamanho dos campos registrados.
`afterImage`	String	Valores dos campos após a operação.

Gatilhos ApsaraMQ for MQTT

[
  {
    "props": {
      "firstTopic": "testTopic",
      "secondTopic": "/testMq4****",
      "clientId": "consumerGroupID@@@xxx"
    },
    "body": "hello mq4Iot pub sub msg"
  }
]

Parâmetro	Tipo	Exemplo	Descrição
`props`	Map	—	Atributos da mensagem.
`props.firstTopic`	String	`testTopic`	Tópico pai usado para enviar e receber mensagens.
`props.secondTopic`	String	`/testMq4****`	Tópico filho.
`props.clientId`	String	`consumerGroupID@@@xx`	ID do cliente.
`body`	String	`hello mq4Iot pub sub msg`	Corpo da mensagem.

Gatilhos Apache RocketMQ autogerenciados

[
  {
    "msgId": "7F0000010BDD2A84AEE70DA49B57****",
    "topic": "testTopic",
    "systemProperties": {
      "UNIQ_KEY": "7F0000010BDD2A84AEE70DA49B57****",
      "CLUSTER": "DefaultCluster",
      "MIN_OFFSET": "0",
      "TAGS": "TagA",
      "MAX_OFFSET": "128"
    },
    "userProperties": {},
    "body": "Hello RocketMQ"
  }
]

Parâmetro	Tipo	Exemplo	Descrição
`msgId`	String	`7F0000010BDD2A84AEE70DA49B57****`	ID da mensagem Apache RocketMQ.
`topic`	String	`testTopic`	Nome do tópico no cluster Apache RocketMQ.
`systemProperties`	Map	—	Propriedades do sistema.
`systemProperties.UNIQ_KEY`	String	`7F0000010BDD2A84AEE70DA49B57****`	Chave exclusiva da mensagem.
`systemProperties.CLUSTER`	String	`DefaultCluster`	Nome do cluster Apache RocketMQ.
`systemProperties.MIN_OFFSET`	Int	`0`	Offset mínimo.
`systemProperties.MAX_OFFSET`	Int	`128`	Offset máximo.
`systemProperties.TAGS`	String	`TagA`	Tags utilizadas para filtrar mensagens.
`userProperties`	Map	—	Propriedades definidas pelo usuário.
`body`	String	`Hello RocketMQ`	Corpo da mensagem.