Format event pemicu di Function Compute - Function Compute

Konten dan struktur parameter event dari berbagai trigger di Function Compute bervariasi tergantung pada jenis peristiwa trigger tertentu. Saat suatu fungsi dipanggil, logika bisnis yang sesuai diimplementasikan berdasarkan informasi dalam event.

Catatan penggunaan

Peristiwa trigger, yang diteruskan dalam bentuk event, harus diuraikan terlebih dahulu sebelum digunakan. Untuk contoh kode penguraian parameter event, lihat Contoh 1: Mengurai Parameter dalam Format JSON.

Trigger HTTP

Tanda tangan fungsi untuk trigger HTTP adalah objek request dan response, bukan objek event. Oleh karena itu, trigger HTTP tidak mengikuti format event. Untuk informasi lebih lanjut, lihat Konfigurasi dan Penggunaan Trigger HTTP.

Trigger waktu

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

Parameter	Tipe	Contoh	Deskripsi
triggerTime	String	2023-12-26T07:49:00Z	Waktu saat fungsi dipicu.
triggerName	String	timer-trigger	Nama trigger waktu.
payload	String	awesome-fc	Nilai Trigger Message yang Anda masukkan saat membuat trigger.

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

Tabel berikut menjelaskan bidang dalam event.

Field	Tipe data	Contoh	Deskripsi
eventName	String	ObjectCreated:PutObject	Jenis peristiwa.
eventSource	String	acs:oss	Sumber peristiwa. Atur nilainya menjadi `acs.oss`.
eventTime	String	2022-08-13T06:45:43.000Z	Waktu terjadinya peristiwa. Waktu ini dalam format standar ISO 8601.
eventVersion	String	1.0	Versi protokol peristiwa.
oss	Map		Konten peristiwa OSS.
bucket	Map		Detail bucket OSS.
name	String	testbucket	Nama bucket.
arn	String	acs:oss:cn-hangzhou:123456789:testbucket	ARN (Alibaba Cloud Resource Name) bucket.
ownerIdentity	String	164901546557****	ID pengguna yang membuat bucket.
object	Map		Detail objek OSS.
size	Int	122539	Ukuran objek OSS. Satuan: byte.
deltaSize	Int	122539	Variasi ukuran objek OSS. Satuan: byte. Jika sebuah objek ditambahkan, nilai parameter ini menunjukkan ukuran objek. Jika objek baru menimpa objek yang ada dengan nama yang sama, nilai parameter ini menunjukkan perbedaan ukuran antara objek baru dan objek asli.
eTag	String	688A7BF4F233DC9C88A80BF985AB****	Tag objek.
key	String	source/a.png	Nama objek.
ossSchemaVersion	String	1.0	Versi skema OSS.
ruleId	String	9adac8e253828f4f7c0466d941fa3db81161****	ID aturan yang cocok dengan peristiwa.
region	String	cn-hangzhou	Wilayah tempat bucket berada.
requestParameters	Map		Parameter permintaan.
sourceIPAddress	String	140.205.XX.XX	Alamat IP dari mana permintaan dikirim.
responseElements	Map		Elemen respons.
requestId	String	58F9FF2D3DF792092E12044C	ID permintaan.
userIdentity	Map		Properti pengguna.
principalId	String	164901546557****	ID akun Alibaba Cloud yang memulai permintaan.

Trigger Layanan Log Sederhana

Dalam Function Compute, event adalah parameter input. Kode berikut menunjukkan format parameter 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
}

Parameter	Deskripsi	Contoh
parameter	Nilai parameter Invocation Parameters yang Anda konfigurasikan saat membuat trigger.	Tidak ada
source	Informasi blok log yang ingin dibaca oleh fungsi dari Layanan Log Sederhana. endpoint: titik akhir wilayah Alibaba Cloud tempat proyek Layanan Log Sederhana berada. projectName: nama proyek Layanan Log Sederhana. logstoreName: nama penyimpanan log. shardId: ID shard tertentu dalam penyimpanan log. beginCursor: offset dari mana konsumsi data dimulai. endCursor: offset di mana konsumsi data berakhir.	`{ "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	Nama pekerjaan ETL di Layanan Log Sederhana. Trigger Layanan Log Sederhana harus sesuai dengan pekerjaan ETL di Layanan Log Sederhana.	1f7043ced683de1a4e3d8d70b5a412843d81****
taskId	Untuk pekerjaan ETL, taskId adalah pengenal untuk pemanggilan fungsi deterministik.	c2691505-38da-4d1b-998a-f1d4bb8c****
cursorTime	Timestamp UNIX dari waktu kedatangan log terakhir di Layanan Log Sederhana.	1529486425

Trigger CDN Alibaba Cloud

Parameter event adalah parameter input dari Function Compute. Pasangan kunci-nilai dalam eventParameter bervariasi dengan jenis peristiwa CDN Alibaba Cloud.

Contoh Peristiwa LogFileCreated

Ganti filePath dengan jalur log CDN Alibaba Cloud atau file uji.

{
    "events": [
        {
            "eventName": "LogFileCreated",
            "eventSource": "cdn",
            "eventTime": "2018-06-14T15:31:49+08:00",
            "eventVersion": "1.0.0",
            "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
            }
        }
    ]
}

Tabel berikut menjelaskan bidang dalam parameter event.

Bidang	Tipe	Contoh	Deskripsi
eventName	String	LogFileCreated	Jenis peristiwa.
eventSource	String	cdn	Nama sumber peristiwa.
region	String	cn-hangzhou	Wilayah tempat CDN Alibaba Cloud berada. Nilai default: cn-hangzhou.
eventVersion	String	1.0.0	Versi trigger peristiwa.
eventTime	String	2018-06-14T15:31:49+08:00	Waktu terjadinya peristiwa.
traceId	String	c6459282-6a4d-4413-894c-e4ea3968****	ID yang dikirimkan oleh sumber peristiwa untuk pemecahan masalah.
userIdentity	Map		Informasi pengguna.
aliUid	String	164901546557****	ID akun Alibaba Cloud yang membuat namespace.
resource	Map		Informasi tentang sumber daya.
domain	String	example.com	Nama domain.
eventParameter	Map		Parameter peristiwa.
domain	String	example.com	Nama domain.
endTime	String	1528959900	Waktu akhir file log.
fileSize	String	1788115	Ukuran file log.
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	Lokasi file log.
startTime	String	1528959600	Waktu mulai file log.

Contoh Event untuk CachedObjectsRefreshed dan 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****",
            "userIdentity": {
                "aliUid": "164901546557****"
            },
            "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
            }
        }
    ]
}

Tabel berikut menjelaskan bidang dalam parameter event.

Bidang	Tipe	Contoh	Deskripsi
eventName	String	CachedObjectsRefreshed	Jenis dari acara tersebut.
eventSource	String	cdn	Nama sumber peristiwa.
region	String	cn-hangzhou	Wilayah tempat Alibaba Cloud CDN berada. Nilai default: cn-hangzhou.
eventVersion	String	1.0.0	Versi dari pemicu acara.
eventTime	String	2018-06-14T15:31:49+08:00	Waktu terjadinya suatu peristiwa.
traceId	String	c6459282-6a4d-4413-894c-e4ea3968****	ID yang dikirimkan oleh sumber peristiwa untuk pemecahan masalah.
resource	Peta		Informasi tentang sumber daya.
domain	String	example.com	Nama domain.
eventParameter	Peta		Parameter acara.
objectPath	String	/2018/03/16/13/33b430c57e7.mp4	Pengenal sumber daya.
createTime	String	1521180769	Waktu mulai refresh.
domain	String	example.com	Nama domain.
completeTime	String	1521180777	Waktu akhir refresh.
objectType	String	File	Item yang diperbarui. Nilai valid: File: file Directory: folder
taskId	String	2089687230	ID tugas refresh sumber daya.
userIdentity	Peta		Informasi tentang pengguna.
aliUid	String	164901546557****	ID akun Alibaba Cloud yang membuat namespace.

Contoh Event untuk CdnDomainStarted dan 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****"
         } 
      } 
   ]
}

Tabel berikut menjelaskan bidang dalam parameter event.

Bidang	Tipe	Contoh	Deskripsi
eventName	String	CdnDomainStarted	Jenis peristiwa.
eventSource	String	cdn	Nama sumber peristiwa.
region	String	cn-hangzhou	Wilayah tempat Alibaba Cloud CDN berada. Nilai default: cn-hangzhou.
eventVersion	String	1.0.0	Versi trigger peristiwa.
eventTime	String	2018-06-14T15:31:49+08:00	Waktu terjadinya peristiwa.
traceId	String	c6459282-6a4d-4413-894c-e4ea3968****	ID yang dikirimkan oleh sumber peristiwa untuk pemecahan masalah.
resource	Map		Informasi tentang sumber daya.
domain	String	example.com	Nama domain.
eventParameter	Map		Parameter peristiwa.
domain	String	example.com	Nama domain.
status	String	online	Status nama domain yang dipercepat.
userIdentity	Map		Informasi pengguna.
aliUid	String	164901546557****	ID akun Alibaba Cloud yang membuat namespace.

Contoh Event untuk CdnDomainAdded dan 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****"
         }
      }
   ]
}

Tabel berikut menjelaskan bidang dalam parameter event.

Bidang	Tipe	Contoh	Deskripsi
eventName	String	CdnDomainAdded	Jenis peristiwa.
eventSource	String	cdn	Nama sumber peristiwa.
region	String	cn-hangzhou	Wilayah tempat CDN Alibaba Cloud berada. Nilai default: cn-hangzhou.
eventVersion	String	1.0.0	Versi trigger peristiwa.
eventTime	String	2018-06-14T15:31:49+08:00	Waktu terjadinya peristiwa.
traceId	String	c6459282-6a4d-4413-894c-e4ea3968****	ID yang dikirimkan oleh sumber peristiwa untuk pemecahan masalah.
resource	Map		Informasi tentang sumber daya.
domain	String	example.com	Nama domain.
eventParameter	Map		Parameter peristiwa.
domain	String	example.com	Nama domain.
userIdentity	Map		Informasi pengguna.
aliUid	String	164901546557****	ID akun Alibaba Cloud yang membuat namespace.

Trigger 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
                }
            ]
        }
    ]
}

Tabel berikut menjelaskan bidang dalam event.

Bidang	Deskripsi
Version	Versi payload. Contoh: Sync-v1. Nilainya adalah string.
Records	Array yang menyimpan baris data tambahan dalam tabel. Parameter ini mencakup bidang berikut: Type: jenis operasi yang dilakukan pada baris. Nilai valid: PutRow, UpdateRow, dan DeleteRow. Nilainya adalah string. Info: informasi tentang baris, termasuk parameter Timestamp, yang menentukan waktu terakhir kali baris dimodifikasi. Waktu harus dalam UTC. Nilainya bertipe "Int64."
PrimaryKey	Array yang menyimpan kolom kunci utama. Parameter ini mencakup bidang berikut: ColumnName: nama kolom kunci utama. Nilainya adalah string. Value: isi kolom kunci utama. Nilainya bertipe formated_value, yang bisa berupa Integer, String, atau Blob.
Columns	Array yang menyimpan kolom atribut. Parameter ini mencakup bidang berikut: Type: jenis operasi yang dilakukan pada kolom atribut. Nilai valid: Put, DeleteOneVersion, dan DeleteAllVersions. Nilainya adalah string. ColumnName: nama kolom atribut. Nilainya adalah string. Value: isi kolom atribut. Nilainya bertipe formatted_value, yang bisa berupa Integer, Boolean, Double, String, atau Blob. Timestamp: waktu terakhir kali kolom atribut dimodifikasi. Waktu harus dalam UTC. Nilainya bertipe "Int64."

Trigger topik MNS

Jika Anda mengatur Event Format ke STREAM:
- Kode berikut menunjukkan format parameter event jika pesan tidak mengandung atribut pesan:
  Catatan
  Jika pesan tidak mengandung atribut pesan, isi parameter event adalah string dalam format JSON.
```
# Badan pesan. 
'hello topic'
```
- Kode berikut menunjukkan format parameter event jika pesan mengandung atribut pesan:
  Catatan
  Konten parameter event berisi pasangan kunci-nilai yang terkait dengan atribut pesan. Untuk informasi lebih lanjut, lihat PublishMessage.
```
   {
        "body": "hello topic",
        "attrs": {
            "Extend": "{\\"key\\":\\"value\\"}"
        }
    }                    
```

Jika Anda mengatur Format Peristiwa ke JSON:

Kode berikut menunjukkan format parameter event jika pesan tidak mengandung atribut pesan:

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

Kode berikut menunjukkan format parameter event jika pesan mengandung atribut pesan:

Catatan

Isi parameter event berisi pasangan kunci-nilai yang terkait dengan atribut pesan. Untuk informasi lebih lanjut, lihat PublishMessage.

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

Trigger antrian MNS

Contoh kode event dalam mode peristiwa:

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

Contoh kode event dalam mode aliran event:

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

Tabel berikut menjelaskan parameter dalam data. Untuk informasi tentang parameter yang didefinisikan dalam spesifikasi CloudEvents, lihat Overview.

Parameter	Diperlukan	Contoh	Deskripsi
requestId	String	606EA3074344430D4C81****	ID permintaan. ID setiap permintaan unik.
messageId	String	C6DB60D1574661357FA227277445****	ID pesan. ID setiap pesan unik.
messageBody	String	TEST	Badan pesan.

Trigger ApsaraMQ untuk RocketMQ

Contoh kode event dalam mode peristiwa:

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

Contoh kode event dalam mode aliran peristiwa:

[
    {
    "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":"NamaTopik",
        "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":"UJI"
    }
    },
    {
    "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":"NamaTopik",
        "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":"UJI"
    }
    }
]

Tabel berikut menjelaskan parameter dalam data. Untuk informasi tentang parameter yang didefinisikan dalam spesifikasi CloudEvents, lihat Ikhtisar.

Parameter	Tipe	Contoh	Deskripsi
topic	String	TopicName	Nama topik.
systemProperties	Map		Properti sistem.
MIN_OFFSET	Int	0	Offset paling awal.
TRACE_ON	Boolean	true	Menunjukkan apakah jejak pesan ada. Nilai valid: true false
MAX_OFFSET	Int	8	Offset terbaru.
MSG_REGION	String	cn-hangzhou	Wilayah dari mana pesan dikirim.
KEYS	String	systemProperties.KEYS	Kunci yang digunakan untuk memfilter pesan.
CONSUME_START_TIME	Panjang	1628577790396	Waktu mulai konsumsi pesan. Satuan: milidetik.
UNIQ_KEY	String	AC14C305069E1B28CDFA3181CDA2****	Kunci unik pesan.
TAGS	String	systemProperties.TAGS	Tag yang digunakan untuk memfilter pesan.
INSTANCE_ID	String	MQ_INST_123456789098****_BXhFHryi	ID instance ApsaraMQ untuk RocketMQ.
userProperties	Map	None	Properti pengguna.
body	String	TEST	Badan pesan.

Trigger ApsaraMQ untuk RabbitMQ

Contoh kode event dalam mode peristiwa:

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

Contoh kode event:

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

Tabel berikut menjelaskan parameter dalam data. Untuk informasi tentang parameter yang didefinisikan dalam spesifikasi CloudEvents, lihat Ikhtisar.

Parameter	Tipe	Contoh	Deskripsi
body	Map		Badan pesan.
Hello	String	EventBridge	Data pengguna.
props	Map		Atribut pesan.
contentEncoding	String	utf-8	Format di mana badan pesan dienkripsi.
messageId	String	f7622d51-e198-41de-a072-77c1ead7****	ID pesan. ID setiap pesan unik.
envelope	Map		Informasi tentang amplop pesan.
deliveryTag	Int	98	Tag pesan.
exchange	String	None	Nama exchange yang mengirim pesan.
redeliver	Boolean	false	Menentukan apakah pesan dapat dikirim ulang. Nilai valid: true false
routingKey	String	housekeeping	Aturan routing pesan.

Trigger ApsaraMQ untuk 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":"pesan kafka halo"
        }
    },
    {
        "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":"pesan kafka halo"
        }
    }
]

Tabel berikut menjelaskan parameter yang terkandung dalam data.

Parameter	Tipe	Contoh	Detail
topic	String	TopicName	Nama topik.
partition	Int	1	Informasi partisi pada instance ApsaraMQ untuk Kafka.
offset	Int	0	Offset pesan dari instance ApsaraMQ untuk Kafka.
timestamp	String	1655952591589	Timestamp yang menunjukkan kapan konsumsi pesan dimulai.

Trigger DTS

Contoh kode :

[
  {
    "data": {
      "id": 321****,
      "topicPartition": {
        "hash": 0,
        "partition": 0,
        "topic": "cn_hangzhou_rm_1234****_test_version2"
      },
      "offset": 3.218.099,
      "sourceTimestamp": 1.654.847.757,
      "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"
  }
]

Untuk informasi tentang parameter yang didefinisikan dalam spesifikasi CloudEvents, lihat Overview.

Tabel berikut menjelaskan parameter yang terkandung dalam field data.

Parameter	Tipe	Deskripsi
id	String	ID entri data DTS.
topicPartition	Array	Informasi partisi topik tempat acara didorong.
hash	String	Parameter penyimpanan dasar DTS.
partition	String	Partisi.
topic	String	Nama topik.
offset	Int	Offset entri data DTS.
sourceTimestamp	Int	Cap waktu yang menunjukkan kapan entri data DTS dihasilkan.
operationType	String	Jenis operasi yang terlibat dalam entri data DTS.
schema	Array	Informasi skema tentang database.
recordFields	Array	Detail bidang.
fieldName	String	Nama bidang.
rawDataTypeNum	Int	Nilai pemetaan tipe bidang. Nilai parameter ini sesuai dengan nilai bidang dataTypeNumber dalam data tambahan yang telah dideserialisasi dari instance pelacakan perubahan. Untuk informasi lebih lanjut, lihat Gunakan klien Kafka untuk mengonsumsi data yang dilacak.
isPrimaryKey	Boolean	Menunjukkan apakah bidang tersebut adalah bidang kunci utama.
isUniqueKey	Boolean	Menunjukkan apakah bidang tersebut memiliki kunci unik.
fieldPosition	String	Posisi bidang.
nameIndex	Array	Informasi pengindeksan bidang berdasarkan nama bidang.
schemaId	String	ID skema database.
databaseName	String	Nama database.
tableName	String	Nama tabel.
primaryIndexInfo	String	Indeks kunci utama.
indexType	String	Tipe indeks.
indexFields	Array	Bidang tempat indeks dibuat.
cardinality	String	Kardinalitas kunci utama.
nullable	Boolean	Menunjukkan apakah kunci utama dapat bernilai null.
isFirstUniqueIndex	Boolean	Menunjukkan apakah indeks tersebut adalah indeks unik pertama.
uniqueIndexInfo	String	Indeks unik.
foreignIndexInfo	String	Indeks untuk kunci asing.
normalIndexInfo	String	Indeks reguler.
databaseInfo	Array	Informasi tentang database.
databaseType	String	Mesin database.
version	String	Versi mesin database.
totalRows	Int	Jumlah total baris dalam tabel.
beforeImage	String	Gambar yang mencatat nilai bidang sebelum operasi dilakukan.
values	String	Nilai bidang yang dicatat.
size	Int	Ukuran bidang yang dicatat.
afterImage	String	Gambar yang mencatat nilai bidang setelah operasi dilakukan.

Pemicu ApsaraMQ for MQTT

Contoh kode event:

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

The following table describes parameters that are contained in event.

Parameter	Tipe	Contoh	Deskripsi
props	Map		Properti dari pesan.
firstTopic	String	testTopic	Topik induk yang digunakan untuk mengirim dan menerima pesan.
secondTopic	String	/testMq4****	Subtopik.
clientId	String	consumerGroupID@@@xx	ID klien.
body	String	hello mq4Iot pub sub msg	Konten dari pesan.

Pemicu Apache RocketMQ yang dikelola sendiri

Contoh kode event:

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

The following table describes parameters that are contained in event.

Parameter	Tipe	Contoh	Deskripsi
msgId	String	7F0000010BDD2A84AEE70DA49B57****	ID pesan Apache RocketMQ.
topic	String	testTopic	Nama topik.
systemProperties	Map		Properti sistem.
UNIQ_KEY	String	7F0000010BDD2A84AEE70DA49B57****	Kunci unik dari pesan.
CLUSTER	String	DefaultCluster	Nama kluster Apache RocketMQ.
MIN_OFFSET	Int	0	Offset minimum.
MAX_OFFSET	Int	128	Offset maksimum.
TAGS	String	TagA	Tag yang digunakan untuk menyaring pesan.
userProperties	Map	Tidak ada.	Properti pengguna.
body	String	Hello RocketMQ	Isi pesan.

Pemicu API Gateway

{
    "path":"jalur permintaan api",
    "httpMethod":"nama metode permintaan",
    "headers":{semua header, termasuk header sistem},
    "queryParameters":{parameter kueri},
    "pathParameters":{parameter jalur},
    "body":"string payload permintaan",
    "isBase64Encoded":"true|false, menunjukkan apakah body dienkripsi Base64"
}

Catatan

Jika nilai dari isBase64Encoded adalah true, konten body yang dikirim oleh API Gateway ke Function Compute dienkripsi dalam format Base64. Function Compute mendekode konten body dari format Base64 sebelum diproses.
Jika nilai dari isBase64Encoded adalah false, API Gateway tidak melakukan enkripsi Base64 pada konten body. Function Compute dapat langsung memperoleh konten body.

Pemicu DataHub

{
  "eventSource": "acs:datahub",
  "eventName": "acs:datahub:putRecord",
  "eventSourceARN": "/projects/nama_proyek_uji/topics/nama_topik_uji",
  "region": "cn-hangzhou",
  "records": [
    {
      "eventId": "0:12345",
      "systemTime": 1.463.000.123.000,
      "data": "[\"nilai kolom1\",\"nilai kolom2\"]"
    },
    {
      "eventId": "0:12346",
      "systemTime": 1.463.000.156.000,
      "data": "[\"nilai kolom1\",\"nilai kolom2\"]"
    }
  ]
}

Untuk informasi lebih lanjut, lihat Struktur Data Peristiwa.