Function Computeのさまざまなトリガーのイベントパラメーターの内容と構造は、特定のトリガーイベントによって異なります。 関数が呼び出されると、対応するビジネスロジックがイベントの情報に基づいて実装されます。
使用上の注意
イベントの形式で渡されるトリガーのトリガーイベントは、使用する前に解析する必要があります。 イベントパラメーターの解析に使用されるサンプルコードの詳細については、「例1: JSON形式のパラメーターの解析」をご参照ください。
HTTPトリガー
HTTPトリガーの関数シグネチャは、イベントオブジェクトではなく、要求オブジェクトと応答オブジェクトです。 したがって、HTTPトリガーはイベント形式に従いません。 詳細については、「HTTPトリガーの設定と使用」をご参照ください。
時間トリガー
{
"triggerTime":"2023-12-26T07:49:00Z",
"triggerName":"timer-trigger",
"payload":"awesome-fc"
} パラメーター | データ型 | 例 | 説明 |
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",
"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 | イベントソース。 値を |
eventTime | String | 2022-08-13T06:45:43.000Z | イベントが発生した時刻。 時間は、ISO 8601標準フォーマットである。 |
eventVersion | String | 1.0 | イベントプロトコルのバージョン。 |
oss | Map | OSSイベントの内容。 | |
bucket | Map | OSSバケットの詳細。 | |
name | String | testbucket | バケットの名前です。 |
arn | String | acs:oss:cn-hangzhou:123456789:testbucket | バケットのAlibaba Cloudリソース名 (ARN) 。 |
ownerIdentity | String | 164901546557 **** | バケットを作成したユーザーのID。 |
object | Map | OSSオブジェクトの詳細。 | |
size | Int | 122539 | OSSオブジェクトのサイズ。 単位: バイト。 |
deltaSize | Int | 122539 | OSSオブジェクトのサイズのバリエーション。 単位: バイト。
|
eTag | String | 688A7BF4F233DC9C88A80BF985AB **** | オブジェクトタグ。 |
key | String | ソース /a.png | オブジェクト名。 |
ossSchemaVersion | String | 1.0 | OSSスキーマのバージョン。 |
ruleId | String | 9adac8e253828f4f7c0466d941fa3db81161 **** | イベントに一致するルールのID。 |
region | String | cn-hangzhou | バケットが存在するリージョン。 |
requestParameters | Map | リクエストのパラメーター | |
sourceIPAddress | String | 140.205.XX.XX | リクエストの送信元のIPアドレス。 |
responseElements | Map | レスポンス要素。 | |
requestId | String | 58F9FF2D3DF792092E12044C | リクエスト ID。 |
userIdentity | Map | ユーザーのプロパティ。 | |
principalId | String | 164901546557 **** | リクエストを開始したAlibaba CloudアカウントのID。 |
シンプルなLog Serviceトリガー
Function Computeでは、eventは入力パラメーターです。 次のコードは、eventパラメーターの形式を示しています。
{
"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
} パラメーター | 説明 | 例 |
パラメーター | トリガーの作成時に設定する [呼び出しパラメーター] パラメーターの値。 | なし |
ソース | 関数がSimple log Serviceから読み取るログブロック情報。
| |
jobName | Simple Log ServiceのETLジョブの名前。 Simple Log Serviceトリガーは、Simple Log ServiceのETLジョブに対応する必要があります。 | 1f7043ced683de1a4e3d8d70b5a412843d81 **** |
taskId | ETLジョブの場合、taskIdは決定論的関数呼び出しの識別子です。 | c2691505-38da-4d1b-998a-f1d4bb8c **** |
cursorTime | Simple log Serviceに最後のログが到着した時刻のUNIXタイムスタンプ。 | 1529486425 |
Alibaba Cloud CDNトリガー
イベントパラメーターは、Function Computeの入力パラメーターです。 次の項目は、イベントの形式を示しています。 eventParameterのキーと値のペアは、Alibaba Cloud CDNイベントタイプによって異なります。
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 } } ] }次の表に、eventパラメーターのフィールドを示します。
項目
データ型
例
説明
eventName
String
LogFileCreated
イベントのタイプ。
eventSource
String
cdn
イベントソースの名前。
region
String
cn-hangzhou
Alibaba Cloud CDNが存在するリージョン。 デフォルト値: cn-hangzhou
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。
リソース
地図
リソースに関する情報。
ドメイン
String
example.com
ドメイン名。
eventParameter
地図
イベントパラメーター。
ドメイン
String
example.com
ドメイン名。
endTime
String
1528959900
ログファイルの終了時刻。
fileSize
String
1788115
ログファイルのサイズ。
filePath
String
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
String
1528959600
ログファイルの開始時刻。
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****" } } ] }次の表に、eventパラメーターのフィールドを示します。
項目
データ型
例
説明
eventName
String
CachedObjectsRefreshed
イベントのタイプ。
eventSource
String
cdn
イベントソースの名前。
region
String
cn-hangzhou
Alibaba Cloud CDNが存在するリージョン。 デフォルト値: cn-hangzhou
eventVersion
String
1.0.0
イベントトリガーのバージョン。
eventTime
String
2018-06-14T15:31:49 + 08:00
イベントが発生した時刻。
traceId
String
c6459282-6a4d-4413-894c-e4ea3968 ****
トラブルシューティングのためにイベントソースによって配信されるID。
リソース
地図
リソースに関する情報。
ドメイン
String
example.com
ドメイン名。
eventParameter
地図
イベントパラメーター。
objectPath
String
/2018/03/16/13/33b430c57e7.mp4
リソース識別子。
createTime
String
1521180769
リフレッシュの開始時刻。
ドメイン
String
example.com
ドメイン名。
completeTime
String
1521180777
更新の終了時間。
objectType
String
ファイル
更新されるアイテム。 有効な値：
ファイル: files
ディレクトリ: フォルダ
taskId
String
2089687230
リソース更新タスクのID。
userIdentity
地図
ユーザーに関する情報。
aliUid
String
164901546557 ****
名前空間を作成したAlibaba Cloudアカウントの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****" } } ] }次の表に、eventパラメーターのフィールドを示します。
項目
データ型
例
説明
eventName
String
CdnDomainStarted
イベントのタイプ。
eventSource
String
cdn
イベントソースの名前。
region
String
cn-hangzhou
Alibaba Cloud CDNが存在するリージョン。 デフォルト値: cn-hangzhou
eventVersion
String
1.0.0
イベントトリガーのバージョン。
eventTime
String
2018-06-14T15:31:49 + 08:00
イベントが発生した時刻。
traceId
String
c6459282-6a4d-4413-894c-e4ea3968 ****
トラブルシューティングのためにイベントソースによって配信されるID。
リソース
地図
リソースに関する情報。
ドメイン
String
example.com
ドメイン名。
eventParameter
地図
イベントパラメーター。
ドメイン
String
example.com
ドメイン名。
status
String
online
高速化ドメイン名のステータス。
userIdentity
地図
ユーザーに関する情報。
aliUid
String
164901546557 ****
名前空間を作成したAlibaba CloudアカウントのID。
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****" } } ] }次の表に、eventパラメーターのフィールドを示します。
項目
データ型
例
説明
eventName
String
CdnDomainAdded
イベントタイプ。
eventSource
String
cdn
イベントソースの名前。
region
String
cn-hangzhou
Alibaba Cloud CDNが存在するリージョン。 デフォルト値: cn-hangzhou
eventVersion
String
1.0.0
イベントトリガーのバージョン。
eventTime
String
2018-06-14T15:31:49 + 08:00
イベントが発生した時刻。
traceId
String
c6459282-6a4d-4413-894c-e4ea3968 ****
トラブルシューティングのためにイベントソースによって配信されるID。
リソース
地図
リソースに関する情報。
ドメイン
String
example.com
ドメイン名。
eventParameter
地図
イベントパラメーター。
ドメイン
String
example.com
ドメイン名。
userIdentity
地図
ユーザーに関する情報。
aliUid
String
164901546557 ****
名前空間を作成したAlibaba CloudアカウントのID。
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
}
]
}
]
}次の表に、イベントのフィールドを示します。
項目 | 説明 |
バージョン | ペイロードのバージョン。 例: Sync-v1。 値は文字列です。 |
レコード | テーブル内の増分データの行を格納する配列。 このパラメータには、次のフィールドが含まれます。
|
PrimaryKey | 主キー列を格納する配列。 このパラメータには、次のフィールドが含まれます。
|
列 | 属性列を格納する配列です。 このパラメータには、次のフィールドが含まれます。
|
MNSトピックトリガー
イベント形式をSTREAMに設定した場合:
メッセージにメッセージ属性が含まれていない場合のイベントパラメーターの形式を次のコードに示します。
説明メッセージにメッセージ属性が含まれていない場合、eventパラメーターの内容はJSON形式の文字列になります。
# The message body. 'hello topic'メッセージにメッセージ属性が含まれている場合のeventパラメーターの形式を次のコードに示します。
説明イベントパラメータの内容には、メッセージ属性に関連するキーと値のペアが含まれます。 詳細については、「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****" }メッセージにメッセージ属性が含まれている場合のeventパラメーターの形式を次のコードに示します。
説明イベントパラメータの内容には、メッセージ属性に関連するキーと値のペアが含まれます。 詳細については、「PublishMessage」をご参照ください。
{ "key": "value", "TopicOwner": "118620210433****", "Message": "hello topic", "Subscriber": "118620210433****", "PublishTime": 1550216302888, "SubscriptionName": "test-fc-subscribe", "MessageMD5": "BA4BA9B48AC81F0F9C66F6C909C3****", "TopicName": "Mytopic", "MessageId": "2F5B3C281B283D4EAC694B742528****" }
MNSキュートリガー
イベントモードのイベントのサンプルコード:
{
"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"
}
}イベントストリームモードのイベントのサンプルコード:
[
{
"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"
}
},
{
"id":"d2g71017-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のパラメーターを示します。 CloudEvents仕様で定義されているパラメーターについては、「概要」をご参照ください。
パラメーター | データ型 | 例 | 説明 |
requestId | String | 606EA3074344430D4C81 **** | リクエストの ID。 各リクエストのIDは一意です。 |
messageId | String | C6DB60D1574661357FA227277445 **** | メッセージの ID 。 各メッセージのIDは一意である。 |
messageBody | String | TEST | メッセージの内容。 |
ApsaraMQ for RocketMQトリガー
イベントモードのイベントのサンプルコード:
{
"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"
}
}イベントストリームモードのイベントのサンプルコード:
[
{
"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"
}
},
{
"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のパラメーターを示します。 CloudEvents仕様で定義されているパラメーターについては、「概要」をご参照ください。
パラメーター | データ型 | 例 | 説明 |
トピック | String | TopicName | トピック名。 |
systemProperties | 地図 | システムのプロパティ。 | |
MIN_OFFSET | Int | 0 | 最も早いオフセット。 |
TRACE_ON | Boolean | true | メッセージトレースが存在するかどうかを示します。 有効な値：
|
MAX_OFFSET | Int | 8 | 最新のオフセット。 |
MSG_地域 | String | cn-hangzhou | メッセージの送信元のリージョン。 |
キー | String | systemProperties.KEYS | メッセージのフィルタリングに使用されるキー。 |
CONSUME_START_TIME | Long | 1628577790396 | メッセージ消費の開始時刻。 単位：ミリ秒。 |
UNIQ_KEY | String | AC14C305069E1B28CDFA3181CDA2 **** | メッセージの一意のキー。 |
タグ | String | systemProperties.TAGS | メッセージのフィルタリングに使用されるタグ。 |
INSTANCE_ID | String | MQ_INST_123456789098 ****_BXhFHryi | ApsaraMQ for RocketMQインスタンスのID。 |
userProperties | 地図 | なし | ユーザーのプロパティ。 |
ボディ | String | TEST | メッセージ本文。 |
ApsaraMQ for RabbitMQトリガー
イベントモードのイベントのサンプルコード:
{
"id":"bj694332-4cj1-389e-9d8c-b137h30b****",
"source":"RabbitMQ-Function-rabbitmq-trigger",
"specversion":"1.0",
"type":"amqp:Queue:SendMessage",
"datacontenttype":"application/json;charset=utf-8",
"subject":"acs:amqp:cn-hangzhou:164901546557****:/instances/amqp-cn-tl32e756****/vhosts/eb-connect/queues/housekeeping",
"time":"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****"
}
}
}イベントストリームモードのイベントのサンプルコード:
[
{
"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****"
}
}
},
{
"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のパラメーターを示します。 CloudEvents仕様で定義されているパラメーターについては、「概要」をご参照ください。
パラメーター | データ型 | 例 | 説明 |
ボディ | 地図 | メッセージ本文。 | |
こんにちは | String | EventBridge | ユーザーデータ。 |
小道具 | 地図 | メッセージ属性。 | |
contentEncoding | String | utf-8 | メッセージ本文がエンコードされる形式。 |
messageId | String | f7622d51-e198-41de-a072-77c1ead7 **** | メッセージ ID 各メッセージのIDは一意である。 |
封筒 | 地図 | メッセージエンベロープに関する情報。 | |
deliveryTag | Int | 98 | メッセージタグ。 |
交換 | String | なし | メッセージを送信する取引所の名前。 |
再配信 | Boolean | false | メッセージを再送信できるかどうかを指定します。 有効な値：
|
routingKey | String | ハウスキーピング | メッセージのルーティングルール。 |
ApsaraMQ for Kafkaトリガー
[
{
"specversion":"1.0",
"id":"8e215af8-ca18-4249-8645-f96c1026****",
"source":"acs:alikafka",
"type":"alikafka:Topic:Message",
"subject":"acs:alikafka_pre-cn-i7m2t7t1****:topic:mytopic",
"datacontenttype":"application/json; charset=utf-8",
"time":"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"
}
},
{
"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に含まれるパラメーターを示します。
パラメーター | データ型 | 例 | 詳細 |
トピック | String | TopicName | トピック名。 |
パーティション | Int | 1 | ApsaraMQ for Kafkaインスタンスのパーティションに関する情報。 |
オフセット | Int | 0 | ApsaraMQ for Kafkaインスタンスのメッセージオフセット。 |
timestamp | String | 1655952591589 | メッセージの消費がいつ開始されたかを示すタイムスタンプ。 |
DTSトリガー
eventのサンプルコード:
[
{
"data": {
"id": 321****,
"topicPartition": {
"hash": 0,
"partition": 0,
"topic": "cn_hangzhou_rm_1234****_test_version2"
},
"offset": 3218099,
"sourceTimestamp": 1654847757,
"operationType": "UPDATE",
"schema": {
"recordFields": [
{
"fieldName": "id",
"rawDataTypeNum": 8,
"isPrimaryKey": true,
"isUniqueKey": false,
"fieldPosition": 0
},
{
"fieldName": "topic",
"rawDataTypeNum": 253,
"isPrimaryKey": false,
"isUniqueKey": false,
"fieldPosition": 1
}
],
"nameIndex": {
"id": {
"fieldName": "id",
"rawDataTypeNum": 8,
"isPrimaryKey": true,
"isUniqueKey": false,
"fieldPosition": 0
},
"topic": {
"fieldName": "topic",
"rawDataTypeNum": 253,
"isPrimaryKey": false,
"isUniqueKey": false,
"fieldPosition": 1
}
},
"schemaId": "(hangzhou-test-db,hangzhou-test-db,message_info)",
"databaseName": "hangzhou--test-db",
"tableName": "message_info",
"primaryIndexInfo": {
"indexType": "PrimaryKey",
"indexFields": [
{
"fieldName": "id",
"rawDataTypeNum": 8,
"isPrimaryKey": true,
"isUniqueKey": false,
"fieldPosition": 0
}
],
"cardinality": 0,
"nullable": true,
"isFirstUniqueIndex": false
},
"uniqueIndexInfo": [],
"foreignIndexInfo": [],
"normalIndexInfo": [],
"databaseInfo": {
"databaseType": "MySQL",
"version": "5.7.35-log"
},
"totalRows": 0
},
"beforeImage": {
"recordSchema": {
"recordFields": [
{
"fieldName": "id",
"rawDataTypeNum": 8,
"isPrimaryKey": true,
"isUniqueKey": false,
"fieldPosition": 0
},
{
"fieldName": "topic",
"rawDataTypeNum": 253,
"isPrimaryKey": false,
"isUniqueKey": false,
"fieldPosition": 1
}
],
"nameIndex": {
"id": {
"fieldName": "id",
"rawDataTypeNum": 8,
"isPrimaryKey": true,
"isUniqueKey": false,
"fieldPosition": 0
},
"topic": {
"fieldName": "topic",
"rawDataTypeNum": 253,
"isPrimaryKey": false,
"isUniqueKey": false,
"fieldPosition": 1
}
},
"schemaId": "(hangzhou-test-db,hangzhou-test-db,message_info)",
"databaseName": "hangzhou-test-db",
"tableName": "message_info",
"primaryIndexInfo": {
"indexType": "PrimaryKey",
"indexFields": [
{
"fieldName": "id",
"rawDataTypeNum": 8,
"isPrimaryKey": true,
"isUniqueKey": false,
"fieldPosition": 0
}
],
"cardinality": 0,
"nullable": true,
"isFirstUniqueIndex": false
},
"uniqueIndexInfo": [],
"foreignIndexInfo": [],
"normalIndexInfo": [],
"databaseInfo": {
"databaseType": "MySQL",
"version": "5.7.35-log"
},
"totalRows": 0
},
"values": [
{
"data": 115
},
{
"data": {
"hb": [
104,
101,
108,
108,
111
],
"offset": 0,
"isReadOnly": false,
"bigEndian": true,
"nativeByteOrder": false,
"mark": -1,
"position": 0,
"limit": 9,
"capacity": 9,
"address": 0
},
"charset": "utf8mb4"
}
],
"size": 45
},
"afterImage": {
"recordSchema": {
"recordFields": [
{
"fieldName": "id",
"rawDataTypeNum": 8,
"isPrimaryKey": true,
"isUniqueKey": false,
"fieldPosition": 0
},
{
"fieldName": "topic",
"rawDataTypeNum": 253,
"isPrimaryKey": false,
"isUniqueKey": false,
"fieldPosition": 1
}
],
"nameIndex": {
"id": {
"fieldName": "id",
"rawDataTypeNum": 8,
"isPrimaryKey": true,
"isUniqueKey": false,
"fieldPosition": 0
},
"topic": {
"fieldName": "topic",
"rawDataTypeNum": 253,
"isPrimaryKey": false,
"isUniqueKey": false,
"fieldPosition": 1
}
},
"schemaId": "(hangzhou-test-db,hangzhou-test-db,message_info)",
"databaseName": "hangzhou-test-db",
"tableName": "message_info",
"primaryIndexInfo": {
"indexType": "PrimaryKey",
"indexFields": [
{
"fieldName": "id",
"rawDataTypeNum": 8,
"isPrimaryKey": true,
"isUniqueKey": false,
"fieldPosition": 0
}
],
"cardinality": 0,
"nullable": true,
"isFirstUniqueIndex": false
},
"uniqueIndexInfo": [],
"foreignIndexInfo": [],
"normalIndexInfo": [],
"databaseInfo": {
"databaseType": "MySQL",
"version": "5.7.35-log"
},
"totalRows": 0
},
"values": [
{
"data": 115
},
{
"data": {
"hb": [
98,
121,
101
],
"offset": 0,
"isReadOnly": false,
"bigEndian": true,
"nativeByteOrder": false,
"mark": -1,
"position": 0,
"limit": 11,
"capacity": 11,
"address": 0
},
"charset": "utf8mb4"
}
],
"size": 47
}
},
"id": "12f701a43741d404fa9a7be89d9acae0-321****",
"source": "DTSstreamDemo",
"specversion": "1.0",
"type": "dts:ConsumeMessage",
"datacontenttype": "application/json; charset=utf-8",
"time": "2022-06-10T07:55:57Z",
"subject": "acs:dts:cn-hangzhou:12345****:kk123abc60g782/dtsabcdet1ro"
}
]CloudEvents仕様で定義されているパラメーターについては、「概要」をご参照ください。
次の表に、dataフィールドに含まれるパラメーターを示します。
パラメーター | データ型 | 説明 |
id | String | DTSデータエントリのID。 |
topicPartition | 配列 | イベントがプッシュされるトピックに関するパーティション情報。 |
ハッシュ | String | DTSの基になるストレージパラメータ。 |
パーティション | String | パーティション。 |
トピック | String | トピック名。 |
オフセット | Int | DTSデータエントリのオフセット。 |
sourceTimestamp | Int | DTSデータエントリがいつ生成されたかを示すタイムスタンプ。 |
operationType | String | DTSデータエントリに含まれる操作のタイプ。 |
スキーマ | 配列 | データベースに関するスキーマ情報。 |
recordFields | 配列 | フィールドの詳細。 |
fieldName | String | フィールド名。 |
rawDataTypeNum | Int | フィールド型のマップされた値。 このパラメーターの値は、変更追跡インスタンスからの逆シリアル化された増分データのdataTypeNumberフィールドの値に対応します。 詳細については、「Kafkaクライアントを使用した追跡データの使用」をご参照ください。 |
isPrimaryKey | Boolean | フィールドが主キーフィールドかどうかを示します。 |
isUniqueKey | Boolean | フィールドに一意のキーがあるかどうかを示します。 |
fieldPosition | String | フィールドの位置。 |
nameIndex | 配列 | フィールド名に基づくフィールドに関するインデックス情報。 |
schemaId | String | データベーススキーマのID。 |
databaseName | String | データベース名。 |
tableName | String | <td class="en-UStry align-left colsep-1 rowsep-1">テーブル名。</td> |
primaryIndexInfo | String | 主キーインデックス。 |
indexType | String | インデックスタイプ。 |
indexFields | 配列 | インデックスが作成されるフィールド。 |
カーディナリティ | String | 主キーのカーディナリティ。 |
nullable | Boolean | プライマリキーをnullにできるかどうかを示します。 |
isFirstUniqueIndex | Boolean | インデックスが最初の一意のインデックスであるかどうかを示します。 |
uniqueIndexInfo | String | 一意のインデックス。 |
foreignIndexInfo | String | 外部キーのインデックス。 |
normalIndexInfo | String | 通常のインデックス。 |
databaseInfo | 配列 | データベースに関する情報。 |
databaseType | String | データベースエンジン。 |
バージョン | String | データベースエンジンのバージョン。 |
totalRows | Int | テーブル内の行の総数。 |
beforeImage | String | 操作が実行される前にフィールド値を記録するイメージ。 |
値 | String | 記録されたフィールド値。 |
サイズ | Int | 記録されたフィールドのサイズ。 |
afterImage | String | 操作が実行された後のフィールド値を記録するイメージ。 |
ApsaraMQ for MQTTトリガー
eventのサンプルコード:
[
{
"props": {
"firstTopic": "testTopic",
"secondTopic": "/testMq4****",
"clientId": "consumerGroupID@@@xxx"
},
"body": "hello mq4Iot pub sub msg"
}
]イベントに含まれるパラメーターを次の表に示します。
パラメーター | データ型 | 例 | 説明 |
小道具 | 地図 | メッセージのプロパティ。 | |
firstTopic | String | testTopic | メッセージの送受信に使用される親トピック。 |
secondTopic | String | /testMq4 **** | サブトピック。 |
clientId | String | consumerGroupID @@@ xx | クライアントのID。 |
ボディ | String | こんにちはmq4Iotパブサブmsg | メッセージの内容。 |
自己管理型Apache RocketMQトリガー
eventのサンプルコード:
[
{
"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。 |
トピック | String | testTopic | トピック名。 |
systemProperties | 地図 | システムのプロパティ。 | |
UNIQ_KEY | String | 7F0000010BDD2A84AEE70DA49B57 **** | メッセージの一意のキー。 |
クラスター | String | DefaultCluster | Apache RocketMQクラスターの名前。 |
MIN_OFFSET | Int | 0 | 最小オフセット。 |
MAX_OFFSET | Int | 128 | 最大オフセット。 |
タグ | String | タガ | メッセージのフィルタリングに使用されるタグ。 |
userProperties | 地図 | なし。 | ユーザーのプロパティ。 |
ボディ | String | こんにちはRocketMQ | メッセージの内容。 |
API Gatewayトリガー
{
"path":"api request path",
"httpMethod":"request method name",
"headers":{all headers,including system headers},
"queryParameters":{query parameters},
"pathParameters":{path parameters},
"body":"string of request payload",
"isBase64Encoded":"true|false, indicate if the body is Base64-encode"
} isBase64Encodedの値がtrueの場合、API GatewayがFunction Computeに送信するbodyコンテンツはBase64-encodedです。 Function Computeは、コンテンツが処理される前に、Base64形式からbodyコンテンツをデコードします。isBase64Encodedの値がfalseの場合、API Gatewayはbodyコンテンツに対してBase64エンコードを実行しません。 Function Computeは、bodyコンテンツを直接取得できます。
DataHubトリガー
{
"eventSource": "acs:datahub",
"eventName": "acs:datahub:putRecord",
"eventSourceARN": "/projects/test_project_name/topics/test_topic_name",
"region": "cn-hangzhou",
"records": [
{
"eventId": "0:12345",
"systemTime": 1463000123000,
"data": "[\"col1's value\",\"col2's value\"]"
},
{
"eventId": "0:12346",
"systemTime": 1463000156000,
"data": "[\"col1's value\",\"col2's value\"]"
}
]
}詳細については、「イベントのデータ構造」をご参照ください。