すべてのプロダクト
Search
ドキュメントセンター

Function Compute:トリガーイベントの形式

最終更新日:Apr 02, 2026

Function Compute の各トリガータイプは、それぞれ異なるイベント構造を関数ハンドラに渡します。イベントパラメーターを解析して、ビジネスロジックに必要なフィールドを抽出してください。

注意事項

使用前にイベントペイロードを解析してください。解析コードのサンプルについては、例 1:JSON 形式のパラメーターの解析をご参照ください。

HTTP トリガー

HTTP トリガーのハンドラは、request および response オブジェクトを event オブジェクトの代わりに受信するため、このトピックで説明されているイベント形式は適用されません。詳細については、「HTTP トリガーの設定」をご参照ください。

時間トリガー

{
    "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****"
            }
        }
    ]
}
パラメータータイプ説明
triggerTimeString2023-12-26T07:49:00Z関数がトリガーされた時刻です。
triggerNameStringtimer-trigger時間トリガーの名前です。
payloadStringawesome-fcトリガーの作成時に [トリガーメッセージ] パラメーターで設定されたカスタム値です。

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****"
            }
        }
    ]
}
パラメータータイプ説明
eventNameStringObjectCreated:PutObjectイベントタイプです。
eventSourceStringacs:ossイベントソースです。固定値:acs:oss
eventTimeString2022-08-13T06:45:43.000Zイベントが発生した時刻 (ISO 8601 形式) です。
eventVersionString1.0イベントプロトコルのバージョンです。
ossMapイベントの内容です。
bucketMapバケットの詳細です。
bucket.nameStringtestbucketバケット名です。
bucket.arnStringacs:oss:cn-hangzhou:123456789:testbucketバケットの Alibaba Cloud リソース名 (ARN) です。
bucket.ownerIdentityString164901546557****バケットを作成したユーザーの ID です。
objectMapオブジェクトの詳細です。
object.sizeInt122539オブジェクトのサイズ (バイト単位) です。
object.deltaSizeInt122539オブジェクトサイズの変更量 (バイト単位) です。新しいオブジェクトの場合、この値はオブジェクトサイズと等しくなります。上書きされたオブジェクトの場合、新しいオブジェクトサイズと古いオブジェクトサイズの差分になります。
object.eTagString688A7BF4F233DC9C88A80BF985AB****オブジェクトの ETag です。
object.keyStringsource/a.pngオブジェクト名です。
object.objectMetaMapオブジェクトのメタデータです。
object.objectMeta.mimeTypeStringapplication/zipオブジェクト コンテンツタイプ。詳細については、「Content-Type ヘッダーを設定する方法は?
object.objectMeta.userMetaMapユーザー定義のメタデータです。オブジェクトの目的や属性を識別します。
x-oss-meta-last-modifiedString20250213ユーザーメタデータのキーと値のペアです。キーは x-oss-meta- で始める必要があります。この例では、"x-oss-meta-last-modified":"20250213" は、オブジェクトがソースマシン上で最後に変更された日付を記録しています。詳細については、「ユーザーメタデータ」をご参照ください。
ossSchemaVersionString1.0OSS スキーマのバージョンです。
ruleIdString9adac8e253828f4f7c0466d941fa3db81161****イベントに一致したルールの ID です。
regionStringcn-hangzhouバケットが存在するリージョンです。
requestParametersMapリクエストパラメーターです。
requestParameters.sourceIPAddressString140.205.XX.XXリクエスト送信者の IP アドレスです。
responseElementsMap応答の詳細です。
responseElements.requestIdString58F9FF2D3DF792092E12044Cリクエスト ID です。
userIdentityMapユーザー ID です。
userIdentity.principalIdString164901546557****リクエストを開始した Alibaba Cloud アカウントの ID です。

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
}
パラメーター説明
parameterトリガーの作成時に設定された呼び出しパラメーターです。
source関数が Simple Log Service から読み取るためのログブロックです。フィールド:endpoint (Simple Log Service プロジェクトのリージョンエンドポイント)、projectName (プロジェクト名)、logstoreName (Logstore 名)、shardId (シャード ID)、beginCursor (データ消費の開始オフセット)、endCursor (データ消費の終了オフセット)。上記の例をご参照ください。
jobNameSimple Log Service の ETL ジョブ名です。Simple Log Service トリガーは ETL ジョブに対応している必要があります。1f7043ced683de1a4e3d8d70b5a412843d81****
taskIdETL ジョブ内の特定の関数呼び出しの識別子です。c2691505-38da-4d1b-998a-f1d4bb8c****
cursorTimeSimple Log Service に到着した最後のログエントリの UNIX タイムスタンプです。1529486425

Alibaba Cloud CDN トリガー

CDN トリガーは、LogFileCreatedCachedObjectsRefreshed / CachedObjectsPushedCdnDomainStarted / CdnDomainStopped、および CdnDomainAdded / CdnDomainDeleted の 4 つのイベントタイプをサポートしています。すべてのイベントは共通のトップレベル構造を共有しており、eventParameter フィールドはイベントタイプによって異なります。

すべての CDN イベントは、以下のトップレベルフィールドを共有します:

パラメータータイプ説明
eventNameStringLogFileCreatedイベントタイプです。
eventSourceStringcdnイベントソースです。
regionStringcn-hangzhouAlibaba Cloud CDN のリージョンです。
eventVersionString1.0.0イベントプロトコルのバージョンです。
eventTimeString2018-06-14T15:31:49+08:00イベントが発生した時刻です。
traceIdStringc6459282-6a4d-4413-894c-e4ea3968****トラブルシューティングのためのトレース ID で、イベントソースによって提供されます。
userIdentity.aliUidString164901546557****名前空間を作成した Alibaba Cloud アカウントの ID です。
resource.domainStringexample.comエンドポイントです。
eventParameterMapイベント固有のパラメーターです。以下の表をご参照ください。

LogFileCreated

filePath を Alibaba Cloud CDN のログまたはテストファイルのパスに置き換えてください。

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

LogFileCreatedeventParameter フィールド:

パラメータータイプ説明
domainStringexample.comエンドポイントです。
startTimeString1528959600ログファイルの開始時刻です。
endTimeString1528959900ログファイルの終了時刻です。
fileSizeString1788115ログファイルのサイズです。
filePathStringhttp://cdnlog.cn-hangzhou.oss.aliyun-inc.com/...ログファイルの場所です。

CachedObjectsRefreshed および 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****"
            }
        }
    ]
}

CachedObjectsRefreshed および CachedObjectsPushedeventParameter フィールド:

パラメータータイプ説明
domainStringexample.comエンドポイントです。
objectPathString/2018/03/16/13/33b430c57e7.mp4リソース識別子です。
createTimeString1521180769リフレッシュの開始時刻です。
completeTimeString1521180777リフレッシュの終了時刻です。
objectTypeStringFileリフレッシュされる項目です。有効値:FileDirectory
taskIdString2089687230リフレッシュタスクの ID です。

CdnDomainStarted および 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****"
            }
        }
    ]
}

CdnDomainStarted および CdnDomainStoppedeventParameter フィールド:

パラメータータイプ説明
domainStringexample.comエンドポイントです。
statusStringonlineCDN ドメイン名のステータスです。

CdnDomainAdded および 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****"
            }
        }
    ]
}

CdnDomainAdded および CdnDomainDeletedeventParameter フィールド:

パラメータータイプ説明
domainStringexample.comエンドポイントです。

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
                }
            ]
        }
    ]
}
パラメーター説明
Versionペイロードのバージョンです。例:Sync-v1。タイプ:String。
Records増分データ行の配列です。各要素には、Type (行の操作タイプ。有効値:PutRowUpdateRowDeleteRow。タイプ:String) と Info (行のメタデータ。Timestamp (最終変更時刻、協定世界時 (UTC)) を含む。タイプ:INT64) が含まれます。
PrimaryKeyプライマリキー列の配列です。各要素には、ColumnName (列名。タイプ:String) と Value (列の値。タイプ:formated_value。INTEGER、STRING、または BLOB) が含まれます。
Columns属性列の配列です。各要素には、Type (操作タイプ。有効値:PutDeleteOneVersionDeleteAllVersions。タイプ:String)、ColumnName (列名。タイプ:String)、Value (列の値。タイプ:formatted_value。INTEGER、BOOLEAN、DOUBLE、STRING、または BLOB)、および Timestamp (最終変更時刻、協定世界時 (UTC)。タイプ:INT64) が含まれます。

Simple Message Queue (旧称:MNS) トピックトリガー

イベント形式は、トリガーに設定された [イベント形式] の設定によって異なります。

STREAM 形式

メッセージ属性なし — イベントはプレーンな JSON 文字列です:

'hello topic'
メッセージに属性がない場合、イベントの内容は JSON 形式の文字列になります。

メッセージ属性あり — イベントには属性のキーと値のペアが含まれます:

イベントの内容には、メッセージ属性からのキーと値のペアが含まれます。詳細については、「PublishMessage」をご参照ください。
{
    "body": "hello topic",
    "attrs": {
        "Extend": "{\"key\":\"value\"}"
    }
}

JSON 形式

メッセージ属性なし:

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

メッセージ属性あり — イベントには、標準フィールドに加えて属性のキーと値のペアが含まれます:

イベントの内容には、メッセージ属性からのキーと値のペアが含まれます。詳細については、「PublishMessage」をご参照ください。
{
    "key": "value",
    "TopicOwner": "118620210433****",
    "Message": "hello topic",
    "Subscriber": "118620210433****",
    "PublishTime": 1550216302888,
    "SubscriptionName": "test-fc-subscribe",
    "MessageMD5": "BA4BA9B48AC81F0F9C66F6C909C3****",
    "TopicName": "Mytopic",
    "MessageId": "2F5B3C281B283D4EAC694B742528****"
}

JSON 形式のイベントパラメーター:

パラメータータイプ説明
keyStringvalueメッセージ属性のキーと値のペアです。
TopicOwnerString118620210433****Simple Message Queue (旧称:MNS) トピック所有者のアカウント ID です。
MessageStringhello topicメッセージ本文です。
SubscriberString118620210433****トピックサブスクライバーのアカウント ID です。
PublishTimeInt1550216302888メッセージが公開された時刻です。
SubscriptionNameStringtest-fc-subscribeサブスクリプション名です。
MessageMD5StringBA4BA9B48AC81F0F9C66F6C909C3****メッセージ本文の MD5 ハッシュです。
TopicNameStringMytopicSimple Message Queue (旧称:MNS) のトピック名です。
MessageIdString2F5B3C281B283D4EAC694B742528****メッセージ ID です。

MNS キュートリガー

イベントは、CloudEvents フォーマットのメッセージの配列です。CloudEvents 仕様のフィールド(specversionidsourcetypedatacontenttypesubjecttime、および Alibaba Cloud 拡張フィールド)については、「概要」をご参照ください。

[
    {
        "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 フィールド:

パラメータータイプ説明
requestIdString606EA3074344430D4C81****リクエスト ID です。各リクエストには一意の ID があります。
messageIdStringC6DB60D1574661357FA227277445****メッセージ ID です。各メッセージには一意の ID があります。
messageBodyStringTESTメッセージ本文です。

ApsaraMQ for RocketMQ トリガー

イベントは CloudEvents フォーマットのメッセージの配列です。CloudEvents 仕様フィールドについては、「概要」をご参照ください。

[
    {
        "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 フィールド:

パラメータータイプ説明
topicStringTopicNameトピック名です。
systemPropertiesMapシステムプロパティです。
systemProperties.MIN_OFFSETInt0最小オフセットです。
systemProperties.TRACE_ONBooleantrueメッセージトレースが存在するかどうかを示します。有効値:truefalse
systemProperties.MAX_OFFSETInt8最大オフセットです。
systemProperties.MSG_REGIONStringcn-hangzhouメッセージが送信されたリージョンです。
systemProperties.KEYSStringsystemProperties.KEYSメッセージをフィルターするために使用されるキーです。
systemProperties.CONSUME_START_TIMELong1628577790396メッセージ消費の開始時刻 (ミリ秒単位) です。
systemProperties.UNIQ_KEYStringAC14C305069E1B28CDFA3181CDA2****メッセージの一意キーです。
systemProperties.TAGSStringsystemProperties.TAGSメッセージをフィルターするために使用されるタグです。
systemProperties.INSTANCE_IDStringMQ_INST_123456789098****_BXhFHryiApsaraMQ for RocketMQ インスタンスの ID です。
userPropertiesMapユーザー定義のプロパティです。
bodyStringTESTメッセージ本文です。

ApsaraMQ for RabbitMQ トリガー

イベントは、CloudEvents フォーマットのメッセージの配列です。CloudEvents 仕様フィールドについては、「概要」をご参照ください。

[
    {
        "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 フィールド:

パラメータータイプ説明
bodyMapメッセージ本文です。
body.HelloStringEventBridgeユーザーデータです。
propsMapメッセージ属性です。
props.contentEncodingStringutf-8メッセージ本文のエンコード形式です。
props.messageIdStringf7622d51-e198-41de-a072-77c1ead7****メッセージ ID です。各メッセージには一意の ID があります。
envelopeMapメッセージエンベロープです。
envelope.deliveryTagInt98配信タグです。
envelope.exchangeStringメッセージをルーティングした交換機です。
envelope.redeliverBooleanfalseメッセージが再配信されたものかどうかを示します。有効値:truefalse
envelope.routingKeyStringhousekeepingメッセージのルーティングキーです。

ApsaraMQ for Kafka トリガー

イベントは、CloudEvents 形式のメッセージの配列です。CloudEvents 仕様のフィールドについては、「概要」をご参照ください。

[
    {
        "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 フィールド:

パラメータータイプ説明
topicStringTopicNameトピック名です。
partitionInt1ApsaraMQ for Kafka インスタンスのパーティションです。
offsetInt0メッセージオフセットです。
timestampString1655952591589メッセージ消費が開始されたときのタイムスタンプです。

DTS トリガー

このイベントは、CloudEvents 形式のメッセージの配列です。CloudEvents 仕様のフィールドについては、「概要」をご参照ください。

[
  {
    "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 フィールド:

パラメータータイプ説明
idStringDTS データ入力 ID です。
topicPartitionArrayイベントがプッシュされるトピックのパーティション詳細です。
topicPartition.hashStringDTS の基盤となるストレージパラメーターです。
topicPartition.partitionStringパーティションです。
topicPartition.topicStringトピック名です。
offsetIntDTS データ入力のオフセットです。
sourceTimestampIntDTS データ入力が生成されたときのタイムスタンプです。
operationTypeStringDTS データ入力の操作タイプです。
schemaArrayデータベーススキーマ情報です。
schema.recordFieldsArrayフィールドの詳細です。
schema.recordFields[].fieldNameStringフィールド名です。
schema.recordFields[].rawDataTypeNumIntフィールド型のマップされた値。変更追跡インスタンスから逆シリアル化された増分データの dataTypeNumber フィールドに対応します。詳細については、「Kafka クライアントを使用してトラックされたデータを消費する」をご参照ください。
schema.recordFields[].isPrimaryKeyBooleanフィールドがプライマリキーであるかどうかを示します。
schema.recordFields[].isUniqueKeyBooleanフィールドに一意キーがあるかどうかを示します。
schema.recordFields[].fieldPositionStringフィールドの位置です。
schema.nameIndexArrayフィールド名に基づくフィールドのインデックス情報です。
schema.schemaIdStringデータベーススキーマ ID です。
schema.databaseNameStringデータベース名です。
schema.tableNameStringテーブル名です。
schema.primaryIndexInfoString主キーインデックスの詳細です。
schema.primaryIndexInfo.indexTypeStringインデックスタイプです。
schema.primaryIndexInfo.indexFieldsArrayインデックスフィールドです。
schema.primaryIndexInfo.cardinalityStringプライマリキーのカーディナリティです。
schema.primaryIndexInfo.nullableBooleanプライマリキーが null にできるかどうかを示します。
schema.primaryIndexInfo.isFirstUniqueIndexBooleanインデックスが最初の一意なインデックスであるかどうかを示します。
schema.uniqueIndexInfoString一意なインデックスです。
schema.foreignIndexInfoString外部キーインデックスです。
schema.normalIndexInfoString通常のインデックスです。
schema.databaseInfoArrayデータベースの詳細です。
schema.databaseInfo.databaseTypeStringデータベースエンジンです。
schema.databaseInfo.versionStringデータベースエンジンバージョンです。
schema.totalRowsIntテーブルの総行数です。
beforeImageString操作前のフィールド値です。
valuesString記録されたフィールド値です。
sizeInt記録されたフィールドのサイズです。
afterImageString操作後のフィールド値です。

ApsaraMQ for MQTT トリガー

[
  {
    "props": {
      "firstTopic": "testTopic",
      "secondTopic": "/testMq4****",
      "clientId": "consumerGroupID@@@xxx"
    },
    "body": "hello mq4Iot pub sub msg"
  }
]
パラメータータイプ説明
propsMapメッセージ属性です。
props.firstTopicStringtestTopicメッセージの送受信に使用される親トピックです。
props.secondTopicString/testMq4****子トピックです。
props.clientIdStringconsumerGroupID@@@xxクライアント ID です。
bodyStringhello mq4Iot pub sub msgメッセージ本文です。

セルフマネージド Apache RocketMQ トリガー

[
  {
    "msgId": "7F0000010BDD2A84AEE70DA49B57****",
    "topic": "testTopic",
    "systemProperties": {
      "UNIQ_KEY": "7F0000010BDD2A84AEE70DA49B57****",
      "CLUSTER": "DefaultCluster",
      "MIN_OFFSET": "0",
      "TAGS": "TagA",
      "MAX_OFFSET": "128"
    },
    "userProperties": {},
    "body": "Hello RocketMQ"
  }
]
パラメータータイプ説明
msgIdString7F0000010BDD2A84AEE70DA49B57****Apache RocketMQ のメッセージ ID です。
topicStringtestTopicApache RocketMQ クラスターのトピック名です。
systemPropertiesMapシステムプロパティです。
systemProperties.UNIQ_KEYString7F0000010BDD2A84AEE70DA49B57****メッセージの一意キーです。
systemProperties.CLUSTERStringDefaultClusterApache RocketMQ クラスター名です。
systemProperties.MIN_OFFSETInt0最小オフセットです。
systemProperties.MAX_OFFSETInt128最大オフセットです。
systemProperties.TAGSStringTagAメッセージをフィルターするために使用されるタグです。
userPropertiesMapユーザー定義のプロパティです。
bodyStringHello RocketMQメッセージ本文です。