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****"
}
}
]
}| パラメーター | タイプ | 例 | 説明 |
|---|---|---|---|
triggerTime | String | 2023-12-26T07:49:00Z | 関数がトリガーされた時刻です。 |
triggerName | String | timer-trigger | 時間トリガーの名前です。 |
payload | String | awesome-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****"
}
}
]
}| パラメーター | タイプ | 例 | 説明 |
|---|---|---|---|
eventName | String | ObjectCreated:PutObject | イベントタイプです。 |
eventSource | String | acs:oss | イベントソースです。固定値:acs:oss。 |
eventTime | String | 2022-08-13T06:45:43.000Z | イベントが発生した時刻 (ISO 8601 形式) です。 |
eventVersion | String | 1.0 | イベントプロトコルのバージョンです。 |
oss | Map | — | イベントの内容です。 |
bucket | Map | — | バケットの詳細です。 |
bucket.name | String | testbucket | バケット名です。 |
bucket.arn | String | acs:oss:cn-hangzhou:123456789:testbucket | バケットの Alibaba Cloud リソース名 (ARN) です。 |
bucket.ownerIdentity | String | 164901546557**** | バケットを作成したユーザーの ID です。 |
object | Map | — | オブジェクトの詳細です。 |
object.size | Int | 122539 | オブジェクトのサイズ (バイト単位) です。 |
object.deltaSize | Int | 122539 | オブジェクトサイズの変更量 (バイト単位) です。新しいオブジェクトの場合、この値はオブジェクトサイズと等しくなります。上書きされたオブジェクトの場合、新しいオブジェクトサイズと古いオブジェクトサイズの差分になります。 |
object.eTag | String | 688A7BF4F233DC9C88A80BF985AB**** | オブジェクトの ETag です。 |
object.key | String | source/a.png | オブジェクト名です。 |
object.objectMeta | Map | — | オブジェクトのメタデータです。 |
object.objectMeta.mimeType | String | application/zip | オブジェクト コンテンツタイプ。詳細については、「Content-Type ヘッダーを設定する方法は? |
object.objectMeta.userMeta | Map | — | ユーザー定義のメタデータです。オブジェクトの目的や属性を識別します。 |
x-oss-meta-last-modified | String | 20250213 | ユーザーメタデータのキーと値のペアです。キーは x-oss-meta- で始める必要があります。この例では、"x-oss-meta-last-modified":"20250213" は、オブジェクトがソースマシン上で最後に変更された日付を記録しています。詳細については、「ユーザーメタデータ」をご参照ください。 |
ossSchemaVersion | String | 1.0 | OSS スキーマのバージョンです。 |
ruleId | String | 9adac8e253828f4f7c0466d941fa3db81161**** | イベントに一致したルールの ID です。 |
region | String | cn-hangzhou | バケットが存在するリージョンです。 |
requestParameters | Map | — | リクエストパラメーターです。 |
requestParameters.sourceIPAddress | String | 140.205.XX.XX | リクエスト送信者の IP アドレスです。 |
responseElements | Map | — | 応答の詳細です。 |
responseElements.requestId | String | 58F9FF2D3DF792092E12044C | リクエスト ID です。 |
userIdentity | Map | — | ユーザー ID です。 |
userIdentity.principalId | String | 164901546557**** | リクエストを開始した 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 (データ消費の終了オフセット)。 | 上記の例をご参照ください。 |
jobName | Simple Log Service の ETL ジョブ名です。Simple Log Service トリガーは ETL ジョブに対応している必要があります。 | 1f7043ced683de1a4e3d8d70b5a412843d81**** |
taskId | ETL ジョブ内の特定の関数呼び出しの識別子です。 | c2691505-38da-4d1b-998a-f1d4bb8c**** |
cursorTime | Simple Log Service に到着した最後のログエントリの UNIX タイムスタンプです。 | 1529486425 |
Alibaba Cloud CDN トリガー
CDN トリガーは、LogFileCreated、CachedObjectsRefreshed / CachedObjectsPushed、CdnDomainStarted / CdnDomainStopped、および CdnDomainAdded / CdnDomainDeleted の 4 つのイベントタイプをサポートしています。すべてのイベントは共通のトップレベル構造を共有しており、eventParameter フィールドはイベントタイプによって異なります。
すべての CDN イベントは、以下のトップレベルフィールドを共有します:
| パラメーター | タイプ | 例 | 説明 |
|---|---|---|---|
eventName | String | LogFileCreated | イベントタイプです。 |
eventSource | String | cdn | イベントソースです。 |
region | String | cn-hangzhou | Alibaba Cloud CDN のリージョンです。 |
eventVersion | String | 1.0.0 | イベントプロトコルのバージョンです。 |
eventTime | String | 2018-06-14T15:31:49+08:00 | イベントが発生した時刻です。 |
traceId | String | c6459282-6a4d-4413-894c-e4ea3968**** | トラブルシューティングのためのトレース ID で、イベントソースによって提供されます。 |
userIdentity.aliUid | String | 164901546557**** | 名前空間を作成した Alibaba Cloud アカウントの ID です。 |
resource.domain | String | example.com | エンドポイントです。 |
eventParameter | Map | — | イベント固有のパラメーターです。以下の表をご参照ください。 |
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
}
}
]
}LogFileCreated の eventParameter フィールド:
| パラメーター | タイプ | 例 | 説明 |
|---|---|---|---|
domain | String | example.com | エンドポイントです。 |
startTime | String | 1528959600 | ログファイルの開始時刻です。 |
endTime | String | 1528959900 | ログファイルの終了時刻です。 |
fileSize | String | 1788115 | ログファイルのサイズです。 |
filePath | String | http://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 および CachedObjectsPushed の eventParameter フィールド:
| パラメーター | タイプ | 例 | 説明 |
|---|---|---|---|
domain | String | example.com | エンドポイントです。 |
objectPath | String | /2018/03/16/13/33b430c57e7.mp4 | リソース識別子です。 |
createTime | String | 1521180769 | リフレッシュの開始時刻です。 |
completeTime | String | 1521180777 | リフレッシュの終了時刻です。 |
objectType | String | File | リフレッシュされる項目です。有効値:File、Directory。 |
taskId | String | 2089687230 | リフレッシュタスクの 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 および CdnDomainStopped の eventParameter フィールド:
| パラメーター | タイプ | 例 | 説明 |
|---|---|---|---|
domain | String | example.com | エンドポイントです。 |
status | String | online | CDN ドメイン名のステータスです。 |
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 および CdnDomainDeleted の eventParameter フィールド:
| パラメーター | タイプ | 例 | 説明 |
|---|---|---|---|
domain | String | example.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 (行の操作タイプ。有効値:PutRow、UpdateRow、DeleteRow。タイプ:String) と Info (行のメタデータ。Timestamp (最終変更時刻、協定世界時 (UTC)) を含む。タイプ:INT64) が含まれます。 |
PrimaryKey | プライマリキー列の配列です。各要素には、ColumnName (列名。タイプ:String) と Value (列の値。タイプ:formated_value。INTEGER、STRING、または BLOB) が含まれます。 |
Columns | 属性列の配列です。各要素には、Type (操作タイプ。有効値:Put、DeleteOneVersion、DeleteAllVersions。タイプ: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 形式のイベントパラメーター:
| パラメーター | タイプ | 例 | 説明 |
|---|---|---|---|
key | String | value | メッセージ属性のキーと値のペアです。 |
TopicOwner | String | 118620210433**** | Simple Message Queue (旧称:MNS) トピック所有者のアカウント ID です。 |
Message | String | hello topic | メッセージ本文です。 |
Subscriber | String | 118620210433**** | トピックサブスクライバーのアカウント ID です。 |
PublishTime | Int | 1550216302888 | メッセージが公開された時刻です。 |
SubscriptionName | String | test-fc-subscribe | サブスクリプション名です。 |
MessageMD5 | String | BA4BA9B48AC81F0F9C66F6C909C3**** | メッセージ本文の MD5 ハッシュです。 |
TopicName | String | Mytopic | Simple Message Queue (旧称:MNS) のトピック名です。 |
MessageId | String | 2F5B3C281B283D4EAC694B742528**** | メッセージ ID です。 |
MNS キュートリガー
イベントは、CloudEvents フォーマットのメッセージの配列です。CloudEvents 仕様のフィールド(specversion、id、source、type、datacontenttype、subject、time、および 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 フィールド:
| パラメーター | タイプ | 例 | 説明 |
|---|---|---|---|
requestId | String | 606EA3074344430D4C81**** | リクエスト ID です。各リクエストには一意の ID があります。 |
messageId | String | C6DB60D1574661357FA227277445**** | メッセージ ID です。各メッセージには一意の ID があります。 |
messageBody | String | TEST | メッセージ本文です。 |
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 フィールド:
| パラメーター | タイプ | 例 | 説明 |
|---|---|---|---|
topic | String | TopicName | トピック名です。 |
systemProperties | Map | — | システムプロパティです。 |
systemProperties.MIN_OFFSET | Int | 0 | 最小オフセットです。 |
systemProperties.TRACE_ON | Boolean | true | メッセージトレースが存在するかどうかを示します。有効値:true、false。 |
systemProperties.MAX_OFFSET | Int | 8 | 最大オフセットです。 |
systemProperties.MSG_REGION | String | cn-hangzhou | メッセージが送信されたリージョンです。 |
systemProperties.KEYS | String | systemProperties.KEYS | メッセージをフィルターするために使用されるキーです。 |
systemProperties.CONSUME_START_TIME | Long | 1628577790396 | メッセージ消費の開始時刻 (ミリ秒単位) です。 |
systemProperties.UNIQ_KEY | String | AC14C305069E1B28CDFA3181CDA2**** | メッセージの一意キーです。 |
systemProperties.TAGS | String | systemProperties.TAGS | メッセージをフィルターするために使用されるタグです。 |
systemProperties.INSTANCE_ID | String | MQ_INST_123456789098****_BXhFHryi | ApsaraMQ for RocketMQ インスタンスの ID です。 |
userProperties | Map | — | ユーザー定義のプロパティです。 |
body | String | TEST | メッセージ本文です。 |
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 フィールド:
| パラメーター | タイプ | 例 | 説明 |
|---|---|---|---|
body | Map | — | メッセージ本文です。 |
body.Hello | String | EventBridge | ユーザーデータです。 |
props | Map | — | メッセージ属性です。 |
props.contentEncoding | String | utf-8 | メッセージ本文のエンコード形式です。 |
props.messageId | String | f7622d51-e198-41de-a072-77c1ead7**** | メッセージ ID です。各メッセージには一意の ID があります。 |
envelope | Map | — | メッセージエンベロープです。 |
envelope.deliveryTag | Int | 98 | 配信タグです。 |
envelope.exchange | String | — | メッセージをルーティングした交換機です。 |
envelope.redeliver | Boolean | false | メッセージが再配信されたものかどうかを示します。有効値:true、false。 |
envelope.routingKey | String | housekeeping | メッセージのルーティングキーです。 |
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 フィールド:
| パラメーター | タイプ | 例 | 説明 |
|---|---|---|---|
topic | String | TopicName | トピック名です。 |
partition | Int | 1 | ApsaraMQ for Kafka インスタンスのパーティションです。 |
offset | Int | 0 | メッセージオフセットです。 |
timestamp | String | 1655952591589 | メッセージ消費が開始されたときのタイムスタンプです。 |
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 フィールド:
| パラメーター | タイプ | 説明 |
|---|---|---|
id | String | DTS データ入力 ID です。 |
topicPartition | Array | イベントがプッシュされるトピックのパーティション詳細です。 |
topicPartition.hash | String | DTS の基盤となるストレージパラメーターです。 |
topicPartition.partition | String | パーティションです。 |
topicPartition.topic | String | トピック名です。 |
offset | Int | DTS データ入力のオフセットです。 |
sourceTimestamp | Int | DTS データ入力が生成されたときのタイムスタンプです。 |
operationType | String | DTS データ入力の操作タイプです。 |
schema | Array | データベーススキーマ情報です。 |
schema.recordFields | Array | フィールドの詳細です。 |
schema.recordFields[].fieldName | String | フィールド名です。 |
schema.recordFields[].rawDataTypeNum | Int | フィールド型のマップされた値。変更追跡インスタンスから逆シリアル化された増分データの dataTypeNumber フィールドに対応します。詳細については、「Kafka クライアントを使用してトラックされたデータを消費する」をご参照ください。 |
schema.recordFields[].isPrimaryKey | Boolean | フィールドがプライマリキーであるかどうかを示します。 |
schema.recordFields[].isUniqueKey | Boolean | フィールドに一意キーがあるかどうかを示します。 |
schema.recordFields[].fieldPosition | String | フィールドの位置です。 |
schema.nameIndex | Array | フィールド名に基づくフィールドのインデックス情報です。 |
schema.schemaId | String | データベーススキーマ ID です。 |
schema.databaseName | String | データベース名です。 |
schema.tableName | String | テーブル名です。 |
schema.primaryIndexInfo | String | 主キーインデックスの詳細です。 |
schema.primaryIndexInfo.indexType | String | インデックスタイプです。 |
schema.primaryIndexInfo.indexFields | Array | インデックスフィールドです。 |
schema.primaryIndexInfo.cardinality | String | プライマリキーのカーディナリティです。 |
schema.primaryIndexInfo.nullable | Boolean | プライマリキーが null にできるかどうかを示します。 |
schema.primaryIndexInfo.isFirstUniqueIndex | Boolean | インデックスが最初の一意なインデックスであるかどうかを示します。 |
schema.uniqueIndexInfo | String | 一意なインデックスです。 |
schema.foreignIndexInfo | String | 外部キーインデックスです。 |
schema.normalIndexInfo | String | 通常のインデックスです。 |
schema.databaseInfo | Array | データベースの詳細です。 |
schema.databaseInfo.databaseType | String | データベースエンジンです。 |
schema.databaseInfo.version | String | データベースエンジンバージョンです。 |
schema.totalRows | Int | テーブルの総行数です。 |
beforeImage | String | 操作前のフィールド値です。 |
values | String | 記録されたフィールド値です。 |
size | Int | 記録されたフィールドのサイズです。 |
afterImage | String | 操作後のフィールド値です。 |
ApsaraMQ for MQTT トリガー
[
{
"props": {
"firstTopic": "testTopic",
"secondTopic": "/testMq4****",
"clientId": "consumerGroupID@@@xxx"
},
"body": "hello mq4Iot pub sub msg"
}
]| パラメーター | タイプ | 例 | 説明 |
|---|---|---|---|
props | Map | — | メッセージ属性です。 |
props.firstTopic | String | testTopic | メッセージの送受信に使用される親トピックです。 |
props.secondTopic | String | /testMq4**** | 子トピックです。 |
props.clientId | String | consumerGroupID@@@xx | クライアント ID です。 |
body | String | hello 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"
}
]| パラメーター | タイプ | 例 | 説明 |
|---|---|---|---|
msgId | String | 7F0000010BDD2A84AEE70DA49B57**** | Apache RocketMQ のメッセージ ID です。 |
topic | String | testTopic | Apache RocketMQ クラスターのトピック名です。 |
systemProperties | Map | — | システムプロパティです。 |
systemProperties.UNIQ_KEY | String | 7F0000010BDD2A84AEE70DA49B57**** | メッセージの一意キーです。 |
systemProperties.CLUSTER | String | DefaultCluster | Apache RocketMQ クラスター名です。 |
systemProperties.MIN_OFFSET | Int | 0 | 最小オフセットです。 |
systemProperties.MAX_OFFSET | Int | 128 | 最大オフセットです。 |
systemProperties.TAGS | String | TagA | メッセージをフィルターするために使用されるタグです。 |
userProperties | Map | — | ユーザー定義のプロパティです。 |
body | String | Hello RocketMQ | メッセージ本文です。 |