Format data dari peristiwa pemicu - Function Compute

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

Catatan penggunaan

Peristiwa pemicu, yang diteruskan dalam bentuk objek peristiwa, harus diuraikan sebelum digunakan. Untuk contoh kode yang digunakan untuk menguraikan parameter peristiwa, lihat Contoh 1: Mengurai Parameter Berformat JSON.

Pemicu HTTP

Tanda tangan fungsi untuk pemicu HTTP adalah objek permintaan dan respons, bukan objek peristiwa. Oleh karena itu, pemicu HTTP tidak mengikuti format peristiwa. Untuk informasi lebih lanjut, lihat Konfigurasikan Pemicu HTTP.

Pemicu 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 ketika fungsi dipicu.
triggerName	String	timer-trigger	Nama pemicu waktu.
payload	String	awesome-fc	Nilai kustom yang Anda tentukan untuk parameter Trigger Message saat Anda membuat pemicu.

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

Tabel berikut menjelaskan parameter dalam objek peristiwa.

Parameter	Tipe	Contoh	Deskripsi
eventName	String	ObjectCreated:PutObject	Jenis peristiwa.
eventSource	String	acs:oss	Sumber peristiwa. Nilainya tetap `acs.oss`.
eventTime	String	2022-08-13T06:45:43.000Z	Waktu terjadinya peristiwa. Nilainya dalam format standar waktu ISO 8601.
eventVersion	String	1.0	Nomor versi protokol peristiwa.
oss	Map		Konten peristiwa.
bucket	Map		Rincian bucket.
name	String	testbucket	Nama bucket.
arn	String	acs:oss:cn-hangzhou:123456789:testbucket	Nama Sumber Daya Alibaba Cloud (ARN) dari bucket.
ownerIdentity	String	164901546557****	ID pengguna yang membuat bucket.
object	Map		Rincian object.
size	Int	122539	Ukuran object. Satuan: byte.
deltaSize	Int	122539	Perubahan ukuran objek. Satuan: byte. Jika objek baru ditambahkan, nilai parameter ini menunjukkan ukuran objek tersebut. Jika objek yang ada ditimpa dengan objek lain dengan nama yang sama, nilai parameter ini menunjukkan selisih ukuran antara objek baru dan objek lama.
eTag	String	688A7BF4F233DC9C88A80BF985AB****	Tag objek.
key	String	source/a.png	Nama objek.
objectMeta	Map		Rincian parameter objectMeta.
mimeType	String	application/zip	Tipe objek. Untuk informasi lebih lanjut, lihat Bagaimana cara mengonfigurasi header Content-Type?
userMeta	Map		Metadata pengguna. Ini mengidentifikasi tujuan atau atribut objek.
x-oss-meta-last-modified	String	20250213	Metadata pengguna terdiri dari satu set pasangan kunci-nilai. Nama header metadata pengguna harus dimulai dengan `x-oss-meta-`. Dalam contoh ini, pasangan kunci-nilai `"x-oss-meta-last-modified":"20250213"` menunjukkan bahwa objek terakhir dimodifikasi pada 13 Februari 2025, di mesin lokal. Untuk informasi lebih lanjut, lihat Metadata Pengguna.
ossSchemaVersion	String	1.0	Nomor 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		Rincian tanggapan.
requestId	String	58F9FF2D3DF792092E12044C	ID permintaan.
userIdentity	Map		Atribut pengguna.
principalId	String	164901546557****	ID Akun Alibaba Cloud yang memulai permintaan.

Pemicu Layanan Log Sederhana

{
    "parameter": {},
    "source": {
        "endpoint": "http://cn-hangzhou-intranet.log.aliyuncs.com",
        "projectName": "fc-test-project",
        "logstoreName": "fc-test-logstore",
        "shardId": 0,
        "beginCursor": "MTUyOTQ4MDIwOTY1NTk3ODQ2Mw==",
        "endCursor": "MTUyOTQ4MDIwOTY1NTk3ODQ2NA=="
    },
    "jobName": "1f7043ced683de1a4e3d8d70b5a412843d81****",
    "taskId": "c2691505-38da-4d1b-998a-f1d4bb8c****",
    "cursorTime": 1529486425
}

Parameter	Deskripsi
parameter	Nilai parameter Invocation Parameters yang Anda konfigurasikan saat membuat pemicu.
source	Informasi blok log yang Anda inginkan untuk dibaca oleh fungsi dari Simple Log Service. Titik akhir: titik akhir dari Wilayah Alibaba Cloud di mana Proyek Simple Log Service berada. projectName: nama dari Proyek Simple Log Service. logstoreName: nama dari penyimpanan log yang ingin Anda konsumsi menggunakan Function Compute. Pemicu saat ini berlangganan data dalam penyimpanan log dan mengirimkan data ke Function Compute secara berkala untuk diproses secara kustom. shardId: ID dari shard tertentu dalam penyimpanan log. beginCursor: offset dari mana konsumsi data dimulai. endCursor: offset di mana konsumsi data berakhir. Catatan Anda dapat memanggil operasi GetCursor untuk mendapatkan beginCursor dan endCursor. Kemudian, Anda dapat membuat suatu event dalam format sebelumnya untuk men-debug fungsi tersebut.
jobName	Nama pekerjaan ETL di Layanan Log Sederhana. Pemicu Layanan Log Sederhana harus sesuai dengan pekerjaan ETL di Layanan Log Sederhana. Parameter ini dibuat secara otomatis oleh Function Compute dan tidak perlu dikonfigurasi.
taskId	Untuk pekerjaan ETL, taskId adalah pengenal untuk pemanggilan fungsi yang deterministik. Parameter ini dibuat secara otomatis oleh Function Compute dan tidak perlu dikonfigurasi.
cursorTime	Stempel waktu UNIX dari waktu ketika log terakhir tiba di Layanan Log Sederhana. Satuan: detik.

Pemicu Alibaba Cloud CDN

Contoh Event LogFileCreated

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

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

Tabel berikut menjelaskan bidang dalam parameter event.

Parameter	Tipe	Contoh	Deskripsi
eventName	String	LogFileCreated	Jenis event.
eventSource	String	cdn	Nama sumber event.
region	String	cn-hangzhou	Wilayah Alibaba Cloud CDN.
eventVersion	String	1.0.0	Versi pemicu event.
eventTime	String	2018-06-14T15:31:49+08:00	Waktu terjadinya suatu event.
traceId	String	c6459282-6a4d-4413-894c-e4ea3968****	ID yang dikirimkan oleh sumber event untuk pemecahan masalah.
userIdentity	Map		Informasi tentang pengguna.
aliUid	String	164901546557****	ID Akun Alibaba Cloud yang membuat namespace.
resource	Map		Informasi tentang sumber daya.
domain	String	example.com	Titik akhir.
eventParameter	Map		Parameter event.
domain	String	example.com	Titik akhir.
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****",
            "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****"
            }
        }
    ]
}

Tabel berikut menjelaskan bidang dalam parameter event.

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

Contoh Event 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.

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

Contoh Event 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.

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

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

Parameter	Deskripsi
Version	Versi dari muatan. Contoh: Sync-v1. Nilainya adalah string.
Records	Array yang menyimpan baris-baris data inkremental dalam tabel. Setiap elemen berisi parameter berikut: Type: jenis operasi yang dilakukan pada baris. Nilai yang valid: PutRow, UpdateRow, dan DeleteRow. Nilainya adalah string. Info: informasi tentang baris, termasuk parameter Timestamp, yang menentukan waktu terakhir baris dimodifikasi. Waktu harus dalam UTC. Nilainya bertipe INT64.
PrimaryKey	Array yang menyimpan kolom kunci primer. Setiap elemen berisi parameter berikut: ColumnName: nama kolom kunci primer. Nilainya adalah string. Value: nilai dari kolom kunci primer. Nilainya bertipe formated_value, yang dapat berupa INTEGER, STRING, atau BLOB.
Columns	Array yang menyimpan kolom atribut. Setiap elemen berisi parameter berikut: Type: jenis operasi yang dilakukan pada kolom atribut. Nilai yang valid: Put, DeleteOneVersion, dan DeleteAllVersions. Nilainya adalah string. ColumnName: nama kolom atribut. Nilainya adalah string. Value: nilai dari kolom atribut. Nilainya bertipe formatted_value, yang dapat berupa INTEGER, BOOLEAN, DOUBLE, STRING, atau BLOB. Timestamp: waktu terakhir kolom atribut dimodifikasi. Waktu harus dalam UTC. Nilainya bertipe INT64.

Pemicu Topik MNS

Contoh Format Konten Event Jika Anda Mengatur Parameter Event Format ke STREAM untuk Pemicu Topik Simple Message Queue (formerly MNS):
- Kode contoh berikut menunjukkan format konten event jika pesan tidak mengandung atribut pesan:
  Catatan
  Jika pesan tidak mengandung atribut pesan, konten event adalah string dalam format JSON.
```
# Isi pesan.
'hello topic'
```
- Kode contoh berikut menunjukkan format konten event jika pesan mengandung atribut pesan:
  Catatan
  Konten event mencakup pasangan kunci-nilai yang terkait dengan atribut pesan. Untuk informasi lebih lanjut, lihat PublishMessage.
```
    {
        "body": "hello topic",
        "attrs": {
            "Extend": "{\\"key\\":\\"value\\"}"
        }
    }                    
```

Contoh Format Konten Event Jika Anda Mengatur Parameter Format Event ke JSON untuk Pemicu Topik Simple Message Queue (formerly MNS):

Kode contoh berikut menunjukkan format konten 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 contoh berikut menunjukkan format konten event jika pesan mengandung atribut pesan:

Catatan

Konten event mencakup 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****"
    }

Tabel berikut menjelaskan parameter dari event.

Parameter	Tipe	Contoh	Deskripsi
key	String	value	Pasangan kunci-nilai yang terkait dengan atribut pesan.
TopicOwner	String	118620210433****	ID akun pemilik topik Simple Message Queue (formerly MNS).
Message	String	hello topic	Isi dari pesan.
Subscriber	String	118620210433****	ID akun pengguna yang berlangganan ke topik Simple Message Queue (formerly MNS).
PublishTime	Int	1550216302888	Waktu ketika pesan diterbitkan.
SubscriptionName	String	test-fc-subscribe	Nama langganan.
MessageMD5	String	BA4BA9B48AC81F0F9C66F6C909C3****	Nilai hash MD5 dari isi pesan.
TopicName	String	Mytopic	Nama dari topik Simple Message Queue (formerly MNS).
MessageId	String	2F5B3C281B283D4EAC694B742528****	ID pesan.

Pemicu Antrian MNS

Contoh Kode dari 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 yang terkandung dalam data. Untuk informasi tentang parameter yang didefinisikan dalam spesifikasi CloudEvents, lihat Ikhtisar.

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

Pemicu ApsaraMQ for RocketMQ

Contoh Kode dari event:

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

Tabel berikut menjelaskan parameter yang terkandung 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 yang 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 menyaring pesan.
CONSUME_START_TIME	Long	1628577790396	Waktu mulai konsumsi pesan. Satuan: milidetik.
UNIQ_KEY	String	AC14C305069E1B28CDFA3181CDA2****	Kunci unik dari pesan.
TAGS	String	systemProperties.TAGS	Tag yang digunakan untuk menyaring pesan.
INSTANCE_ID	String	MQ_INST_123456789098****_BXhFHryi	ID Instans ApsaraMQ for RocketMQ.
userProperties	Map	Tidak ada	Properti pengguna.
body	String	TEST	Isi pesan.

Pemicu ApsaraMQ for RabbitMQ

Contoh Kode dari 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 yang terkandung dalam data. Untuk informasi tentang parameter yang didefinisikan dalam spesifikasi CloudEvents, lihat Ikhtisar.

Parameter	Tipe	Contoh	Deskripsi
body	Map		Isi pesan.
Hello	String	EventBridge	Data pengguna.
props	Map		Atribut pesan.
contentEncoding	String	utf-8	Format pengkodean isi pesan.
messageId	String	f7622d51-e198-41de-a072-77c1ead7****	ID pesan. Setiap ID pesan bersifat 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.

Pemicu ApsaraMQ for Kafka

Berikut ini adalah contoh kode yang menyediakan gambaran tentang event:

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

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

Tabel berikut menjelaskan parameter yang terkandung dalam data.

Parameter	Tipe	Contoh	Detail
topik	String	NamaTopik	Nama topik.
partisi	Int	1	Informasi tentang partisi pada instans ApsaraMQ for Kafka.
offset	Int	0	Offset pesan dari instans ApsaraMQ for Kafka.
timestamp	String	1655952591589	Cap waktu yang menunjukkan kapan konsumsi pesan dimulai.

Pemicu DTS

Berikut ini adalah contoh kode yang memberikan gambaran tentang format konten 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"
  }
]

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

Tabel berikut menjelaskan parameter yang terkandung dalam bidang data.

Parameter	Tipe	Deskripsi
id	String	ID entri data DTS.
topicPartition	Array	Informasi partisi tentang topik ke mana event didorong.
hash	String	Parameter penyimpanan dasar DTS.
partition	String	Partisi.
topic	String	Nama topik.
offset	Int	Offset dari entri data DTS.
sourceTimestamp	Int	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 field dataTypeNumber dalam data inkremental 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 merupakan bidang kunci utama.
isUniqueKey	Boolean	Menunjukkan apakah bidang 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 merupakan 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	Citra yang mencatat nilai bidang sebelum operasi dilakukan.
values	String	Nilai bidang yang dicatat.
size	Int	Ukuran bidang yang dicatat.
afterImage	String	Citra yang mencatat nilai bidang setelah operasi dilakukan.

Pemicu ApsaraMQ for MQTT

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

The following table describes the parameters of the event.

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

Pemicu Apache RocketMQ yang dikelola sendiri

[
  {
    "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 the parameters of the event.

Parameter	Tipe	Contoh	Deskripsi
msgId	String	7F0000010BDD2A84AEE70DA49B57****	ID dari pesan Apache RocketMQ.
topic	String	testTopic	Nama topik dalam kluster Apache RocketMQ.
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	N/A	Properti pengguna.
body	String	Hello RocketMQ	Isi dari pesan.