Gunakan ListEventStreamings untuk mengambil daftar event stream - EventBridge - Alibaba Cloud - EventBridge

Mengkueri aliran acara.

Deskripsi operasi

Mengkueri aliran acara.

Coba sekarang

Coba API ini di OpenAPI Explorer tanpa perlu penandatanganan manual. Panggilan yang berhasil akan secara otomatis menghasilkan contoh kode SDK sesuai dengan parameter Anda. Unduh kode tersebut dengan kredensial bawaan yang aman untuk penggunaan lokal.

Test

RAM authorization

Tabel berikut menjelaskan otorisasi yang diperlukan untuk memanggil API ini. Anda dapat menentukannya dalam kebijakan Resource Access Management (RAM). Kolom pada tabel dijelaskan sebagai berikut:

Action: Aksi yang dapat digunakan dalam elemen Action pada pernyataan kebijakan izin RAM untuk memberikan izin guna melakukan operasi tersebut.
API: API yang dapat Anda panggil untuk melakukan aksi tersebut.
Access level: Tingkat akses yang telah ditentukan untuk setiap API. Nilai yang valid: create, list, get, update, dan delete.
Resource type: Jenis resource yang mendukung otorisasi untuk melakukan aksi tersebut. Ini menunjukkan apakah aksi tersebut mendukung izin tingkat resource. Resource yang ditentukan harus kompatibel dengan aksi tersebut. Jika tidak, kebijakan tersebut tidak akan berlaku.
- Untuk API dengan izin tingkat resource, jenis resource yang diperlukan ditandai dengan tanda bintang (*). Tentukan Nama Sumber Daya Alibaba Cloud (ARN) yang sesuai dalam elemen Resource pada kebijakan.
- Untuk API tanpa izin tingkat resource, ditampilkan sebagai All Resources. Gunakan tanda bintang (*) dalam elemen Resource pada kebijakan.
Condition key: Kunci kondisi yang didefinisikan oleh layanan. Kunci ini memungkinkan kontrol granular, berlaku baik hanya untuk aksi maupun untuk aksi yang terkait dengan resource tertentu. Selain kunci kondisi spesifik layanan, Alibaba Cloud menyediakan serangkaian common condition keys yang berlaku di semua layanan yang didukung RAM.
Dependent action: Aksi dependen yang diperlukan untuk menjalankan aksi tersebut. Untuk menyelesaikan aksi tersebut, pengguna RAM atau role RAM harus memiliki izin untuk melakukan semua aksi dependen.

Action

Access level

Resource type

Condition key

Dependent action

eventbridge:ListEventStreamings

list

*EventStreaming

acs:eventbridge:{#regionId}:{#accountId}:eventstreaming/*

None

Parameter permintaan

Parameter	Type	Required	Description	Example
NamePrefix	string	No	Awalan nama aliran acara.	name.
Limit	integer	No	Jumlah maksimum entri yang dikembalikan per permintaan. Anda dapat menggunakan parameter ini bersama dengan NextToken untuk mengimplementasikan paging. Penting Jumlah maksimum entri yang dikembalikan per permintaan tidak boleh melebihi 100.	10
NextToken	string	No	Jika jumlah entri melebihi nilai Limit, NextToken akan dikembalikan.	10
Tags	array<object>	No	Tag yang digunakan untuk pemfilteran.
	object	No	Tag.
Key	string	No	Kunci tag.	mns.
Value	string	No	Nilai tag.	mnstest.
SourceArn	string	No	ARN sumber event.	acs:alikafka:cn-hangzhou:118609547428**:Instans/alikafka_pre-cn-zxu36kvi**/Topik/test-topic
SinkArn	string	No	ARN target event.	acs:fc:cn-hangzhou:118609547428****:layanan/fw1.LATEST/functions/log1

Elemen respons

Element	Type	Description	Example
	object	Parameter tanggapan.
Message	string	Paket error.	aliran acara [xxxx] tidak ada!
RequestId	string	ID permintaan yang dihasilkan oleh Alibaba Cloud untuk permintaan ini.	283FF852-C4B8-58C9-9777-F88A5A16****
Data	object	Daftar aliran acara.
EventStreamings	array<object>	Daftar aliran acara.
	array<object>	Entitas aliran acara.
EventStreamingName	string	Nama streaming peristiwa.	name
Description	string	Deskripsi streaming peristiwa.	demo
Source	object	Sumber peristiwa.
SourceMNSParameters	object	Parameter yang dikembalikan jika sumber peristiwa adalah Simple Message Queue (sebelumnya MNS).
RegionId	string	ID wilayah.	cn-zhangjiakou
QueueName	string	Nama antrean Simple Message Queue (sebelumnya MNS).	work4
IsBase64Decode	boolean	Menunjukkan apakah dekode Base64 diaktifkan.	true
SourceRabbitMQParameters	object	Parameter yang dikembalikan jika sumber peristiwa adalah RabbitMQ.
RegionId	string	ID wilayah.	cn-zhangjiakou
InstanceId	string	ID instans ApsaraMQ for RabbitMQ.	dbaudit-cn-7mz2hqo****
VirtualHostName	string	Nama vhost instans ApsaraMQ for RabbitMQ.	eb-connect
QueueName	string	Nama antrean instans ApsaraMQ for RabbitMQ.	liuyang
SourceRocketMQParameters	object	Parameter yang dikembalikan jika sumber peristiwa adalah RocketMQ.
RegionId	string	ID wilayah instans ApsaraMQ for RocketMQ.	cn-chengdu
InstanceId	string	ID instans ApsaraMQ for RocketMQ.	i-f8zbher64dlm58pl****
Topic	string	Topik pesan.	topic_add_anima
Tag	string	Tag filter pesan.	v1
Offset	string	Offset konsumsi pesan. Nilai yang valid: CONSUMEFROMLASTOFFSET: konsumsi dimulai dari offset terbaru. CONSUMEFROMFIRSTOFFSET: konsumsi dimulai dari offset paling awal. CONSUMEFROMTIMESTAMP: konsumsi dimulai dari offset pada titik waktu tertentu.	CONSUMEFROMTIMESTAMP
GroupID	string	ID grup instans ApsaraMQ for RocketMQ.	GID_group1
Timestamp	integer	Stempel waktu. Parameter ini hanya valid jika parameter Offset diatur ke CONSUMEFROMTIMESTAMP.	1670742074043
InstanceType	string	Tipe instans. Nilai yang valid: Cloud_4: instans ApsaraMQ for RocketMQ 4.0 (default) Cloud_5: instans ApsaraMQ for RocketMQ 5.0 SelfBuilt: kluster Apache RocketMQ yang dikelola sendiri.	Cloud_4
InstanceEndpoint	string	Endpoint instans.	registry-vpc.cn-hangzhou.aliyuncs.com
AuthType	string	Tipe autentikasi.	ACL
InstanceUsername	string	Nama pengguna instans.	admin**
InstancePassword	string	Kata sandi instans.	123
InstanceVpcId	string	ID VPC.	vpc-bp1a4gmlk31hy***l3ss
InstanceVSwitchIds	string	Informasi vSwitch instans.	vsw-m5ev8asdc6h123456****
InstanceSecurityGroupId	string	Informasi grup keamanan instans.	sg-m5edtu24f12345****
InstanceNetwork	string	Tipe jaringan instans. Nilai yang valid: PublicNetwork PrivateNetwork.	PublicNetwork
BodyDataType	string	Format enkode badan pesan. Nilai yang valid: JSON Text Binary.	JSON
Network	string	Tipe jaringan. Nilai yang valid: PublicNetwork PrivateNetwork.	PublicNetwork
FilterType	string	Tipe filter pesan.	Tag
FilterSql	string	Pernyataan filter SQL.	index > 10
VpcId	string	ID VPC.	vpc-m5e3sv4b12345****
VSwitchIds	string	ID vSwitch.	vsw-m5ev8asdc6h12345****
SecurityGroupId	string	ID grup keamanan.	sg-m5edtu24f12345****
SourceRocketMQCheckpointParameters	object	Parameter yang dikembalikan jika sumber peristiwa adalah RocketMQ Checkpoint.
RegionId	string	ID wilayah.	cn-hangzhou
InstanceType	string	Tipe instans ApsaraMQ for RocketMQ.	Cloud_5
InstanceId	string	ID instans ApsaraMQ for RocketMQ.	rmq-cn-jte3w******
Topics	array	Topik instans ApsaraMQ for RocketMQ.
	string	Topik instans ApsaraMQ for RocketMQ.	myTopic
SourceApacheRocketMQCheckpointParameters	object	Parameter yang dikembalikan jika sumber peristiwa adalah RocketMQ Checkpoint.
RegionId	string	ID wilayah.	cn-hangzhou
Topics	array	Topik instans Apache RocketMQ.
	string	Topik instans Apache RocketMQ.	myTopic
InstanceEndpoint	string	Endpoint instans Apache RocketMQ.	192.168.1.1:9876
InstanceUsername	string	Nama pengguna instans Apache RocketMQ.	admin
InstancePassword	string	Kata sandi instans Apache RocketMQ.	****
NetworkType	string	Tipe jaringan.	PrivateNetwork
VpcId	string	ID VPC.	vpc-adw1awdw*****
VSwitchId	string	ID vSwitch.	vsw-dwaafds****
SecurityGroupId	string	ID grup keamanan.	sg-mw43*****
SourceKafkaParameters	object	Parameter yang dikembalikan jika sumber peristiwa adalah Kafka.
RegionId	string	ID wilayah instans.	cn-chengdu
InstanceId	string	ID instans.	bastionhost-cn-i7m2gwt****
Topic	string	Nama topik.	topic_empower_1642473600414
ConsumerGroup	string	ID grup konsumen yang berlangganan topik.	GID_TEST
OffsetReset	string	Offset.	latest
Network	string	Konfigurasi jaringan. Nilai default adalah Default. Untuk jaringan VPC, nilainya adalah PublicNetwork.	Default
VpcId	string	ID VPC.	vpc-wz9ki1qdlx3cx5cbf****
VSwitchIds	string	ID vSwitch.	vsw-bp1rmi8rind7eo50c****
SecurityGroupId	string	ID grup keamanan.	sg-5ud5f3p0rqqis69****eho7cp
ValueDataType	string	Format enkode dan dekode badan pesan. Nilai yang valid: JSON Text Binary.	JSON
SourceMQTTParameters	object	Parameter yang dikembalikan jika sumber peristiwa adalah MQTT.
RegionId	string	ID wilayah.	cn-qingdao
InstanceId	string	ID instans.	bastionhost-cn-zvp27kc****
Topic	string	Nama topik.	migration_instance
BodyDataType	string	Format enkode badan pesan. Nilai yang valid: JSON Text Binary.	JSON
NetworkType	string	Tipe jaringan.
VpcId	string	ID VPC.
VSwitchIds	string	ID vSwitch.
SecurityGroupId	string	ID grup keamanan.
SourceDTSParameters	object	Parameter yang dikembalikan jika sumber peristiwa adalah Data Transmission Service (DTS).
TaskId	string	ID tugas.	1611b337285f44e2936a2c4170****
BrokerUrl	string	Alamat jaringan dan nomor port saluran langganan data.
Topic	string	Topik langganan saluran langganan data.	TP_TEST_UNDERWRITE_ISSUE
Sid	string	ID grup konsumen.	HG9
Username	string	Nama pengguna grup konsumen.	admin
Password	string	Kata sandi grup konsumen.	123456
InitCheckPoint	string	Checkpoint konsumsi, yaitu stempel waktu ketika klien SDK mengonsumsi catatan data pertama. Nilainya adalah stempel waktu UNIX.	1620962769
SourceSLSParameters	object	Parameter yang dikembalikan jika sumber peristiwa adalah Simple Log Service.
Project	string	Proyek Simple Log Service.	dmmzk
LogStore	string	Logstore Simple Log Service.	waf-logstore
ConsumerGroup	string	ID grup konsumen yang berlangganan topik.	go-dts-shelf-group
ConsumePosition	string	Offset konsumsi awal. Anda dapat memilih offset paling awal atau terbaru, yang masing-masing sesuai dengan "begin" atau "end". Anda juga dapat memulai konsumsi dari titik waktu tertentu, dalam detik.	begin
RoleName	string	Saat mengotorisasi EventBridge untuk menggunakan peran ini untuk membaca konten log SLS, kondisi berikut harus dipenuhi: saat membuat peran yang digunakan oleh layanan di konsol RAM, Anda harus memilih "Layanan Alibaba Cloud", dan "Layanan Tepercaya" harus diatur ke "EventBridge".	testRole
SourcePrometheusParameters	object	Parameter yang dikembalikan jika sumber peristiwa adalah Prometheus.
RegionId	string	ID wilayah.	cn-beijing
ClusterId	string	ID kluster.	c83555068b6******ad213f565f209
DataType	string	Tipe data.	JSON
Labels	string	Tag.	__name__=.*
RoleName	string	Peran yang digunakan untuk mengakses data Prometheus.	testRole
ExternalLabels	string	Label kustom yang dilampirkan ke peristiwa.	{"source":"prometheus-prod"}
SourceCustomizedKafkaParameters	object	Parameter yang dikembalikan jika sumber peristiwa adalah sumber Kafka kustom.
InstanceId	string	ID instans.	gtm-cn-k2c2yfg****
SourceCustomizedKafkaConnectorParameters	object	Parameter yang dikembalikan jika sumber peristiwa adalah konektor Apache Kafka kustom.
ConnectorPackageUrl	string	URL unduhan paket ZIP sumber daya OSS.	"https://examplebucket.oss-cn-hangzhou.aliyuncs.com/testDoc/Old_Homebrew/2024-06-26%2022%3A34%3A08/opt/homebrew/homebrew/Library/Homebrew/test/support/fixtures/cask/AppWithBinary.zip?OSSAccessKeyId=ri&Expires=1725539627&Signature=rb8q3OpV2i3gZJ"
ConnectorParameters	object	Parameter konektor.
Name	string	Nama konektor.	test-name
Config	object	Konfigurasi konektor.	{ "connector.class": "com.mongodb.kafka.connect.MongoSinkConnector", "tasks.max": "1", "topics": "sourceA,sourceB" }
WorkerParameters	object	Konfigurasi instans Kafka.	{ "group.id": "connect-eb-cluster-KAFKA_CONNECTORC", "offset.storage.topic": "connect-eb-offset-KAFKA_CONNECTOR_yjqC8K5ewC", "config.storage.topic": "connect-eb-config-KAFKA_CONNECTOR_yjqC8K5ewC", "status.storage.topic": "connect-eb-status-KAFKA_CONNECTOR_yjqC8K5ewC", "consumer.group.id": "connector-eb-cluster-KAFKA_CONNECTOR_yjqC8K5ewC-mongo-sink", "bootstrap.servers": "alikafka-post:9092" }
SourceOSSParameters	object	Parameter yang dikembalikan jika sumber peristiwa adalah Object Storage Service (OSS).
RoleName	string	Nama peran yang mengotorisasi EventBridge untuk membaca file OSS. Peran ini harus memiliki setidaknya izin baca-saja pada OSS.	eventbridge_oss_role
BucketName	string	Nama bucket OSS.	bucket_abc
Prefix	string	Prefiks jalur file.	fun/document/
LoadMode	string	Mode pemuatan data. Nilai single menunjukkan pemuatan dokumen tunggal, dan nilai element menunjukkan pemuatan terpotong. Nilai yang valid: single dan element. Nilai default: single.	single
LoadFormat	string	Pemuat dokumen.	TextLoader
Delimiter	string	Delimiter. Dalam mode pemuatan terpotong, delimiter ini digunakan sebagai pengenal pemotongan teks. Secara default, karakter baris baru digunakan sebagai delimiter.	\n
SourceOpenSourceRabbitMQParameters	object	Parameter yang dikembalikan jika sumber peristiwa adalah RabbitMQ sumber terbuka.
Endpoint	string	Endpoint instans.	192.168.1.1:9876
VirtualHostName	string	Nama virtual host instans RabbitMQ sumber terbuka.	Vhost1
QueueName	string	Nama antrean instans RabbitMQ sumber terbuka.	demo
BodyDataType	string	Tipe data badan pesan.	Json
Username	string	Nama pengguna yang digunakan untuk terhubung ke instans RabbitMQ sumber terbuka.	admin
Password	string	Kata sandi yang digunakan untuk terhubung ke instans RabbitMQ sumber terbuka.	****
VpcId	string	ID VPC.	vpc-m5e3sv4b12345****
VSwitchIds	string	ID vSwitch.	vsw-m5ev8asdc6h12345****
SecurityGroupId	string	ID grup keamanan.	sg-m5edtu24f12345****
NetworkType	string	Tipe jaringan.	PrivateNetwork
AuthType	string	Tipe autentikasi.	ACL
SourceEventBusParameters	object	Parameter yang dikembalikan jika sumber peristiwa adalah EventBridge.
EventBusName	string	Nama bus peristiwa.	my-event-bus
EventRuleName	string	Nama aturan peristiwa.	my-event-rule
SourceMySQLParameters	SourceMySQLParameters	Parameter yang dikembalikan jika sumber peristiwa adalah MySQL.
SourcePostgreSQLParameters	SourcePostgreSQLParameters
SourceRabbitMQMetaParameters	SourceRabbitMQMetaParameters
SourceRabbitMQMsgSyncParameters	SourceRabbitMQMsgSyncParameters
SourceFeiShuDocsParameters	SourceFeiShuDocsParameters
SourceJDBCParameters	SourceJDBCParameters
FilterPattern	string	Aturan pemfilteran peristiwa. Jika parameter ini tidak ditentukan, semua peristiwa akan dicocokkan.
Transforms	array<object>	Konfigurasi terkait Transform.
	object	ARN layanan cloud, seperti ARN fungsi di Function Compute.
Arn	string	ARN layanan cloud, seperti ARN fungsi di Function Compute.	acs:fc:cn-hangzhou:*****:services/demo-service.LATEST/functions/demo-func
DashScopeTransformParameters	DashScopeTransformParameters
BaiLianAgentTransformParameters	BaiLianAgentTransformParameters
Sink	object	Target peristiwa.
SinkMNSParameters	object	Target peristiwa Simple Message Queue (sebelumnya MNS).
QueueName	object	Tipe layanan target adalah Simple Message Queue (sebelumnya MNS).
Value	string	Nama antrean Simple Message Queue (sebelumnya MNS).	MyQueue
Form	string	Format transformasi. Nilai default: CONSTANT.	CONSTANT
Template	string	Tidak ada.
Body	object	Konten pesan.
Value	string	Nilai sebelum transformasi.	{ "key": "value" }
Form	string	Format transformasi.	TEMPLATE
Template	string	Gaya template.	The value of ${key} is ${value}!
IsBase64Encode	object	Menunjukkan apakah dekode Base64 diaktifkan.
Value	string	Menentukan apakah akan mengaktifkan enkode Base64.	true
Form	string	Format transformasi. Nilai default: CONSTANT.	CONSTANT
Template	string	Tidak ada.
SinkEventHouseParameters	object	Nama target peristiwa.
CatalogName	string	Nama katalog.	cat1
NamespaceName	string	Nama namespace.	name1
EventTableName	string	Nama tabel.	table1
MappingRules	array<object>	Aturan pemetaan field.
	array<object>	Aturan pemetaan.
ColumnValue	object	Aturan ekstraksi nilai kolom.
Value	string	Jalur ekstraksi.	$.data.value
Form	string	Metode ekstraksi.	JSONPATH
Template	string	Template.	The value of ${key} is ${value}!
ColumnName	string	Nama kolom.	age
ColumnType	string	Tipe kolom.	text
SinkFcParameters	object	Target peristiwa Function Compute.
ServiceName	object	Nama layanan.
Value	string	Nama layanan.	myService
Form	string	Format transformasi. Nilai default: CONSTANT.	CONSTANT
Template	string	Tidak ada.
FunctionName	object	Nama fungsi.
Value	string	Nama fungsi.	mFunction
Form	string	Format transformasi. Nilai default: CONSTANT.	CONSTANT
Template	string	Tidak ada.
Concurrency	object	Konkurensi pengiriman. Nilai minimum adalah 1.
Value	string	Konkurensi pengiriman. Nilai minimum adalah 1.	1
Form	string	Format transformasi. Nilai default: CONSTANT.	CONSTANT
Template	string	Tidak ada.
Qualifier	object	Alias layanan tempat fungsi berada.
Value	string	Alias layanan tempat fungsi berada.	LATEST
Form	string	Format transformasi. Nilai default: CONSTANT.	CONSTANT
Template	string	Tidak ada.
InvocationType	object	Tipe pemanggilan. Nilai yang valid: Sync: sinkron. Async: asinkron.
Value	string	Tipe pemanggilan. Nilai yang valid: Sync: sinkron. Async: asinkron.	Async
Form	string	Format transformasi. Nilai default: CONSTANT.	CONSTANT
Template	string	Tidak ada.
Body	object	Badan konten yang dikirim ke fungsi.
Value	string	Nilai sebelum transformasi.	{ "key": "value" }
Form	string	Format transformasi.	TEMPLATE
Template	string	Gaya template.	The value of ${key} is ${value}!
DataFormat	object	Aturan transformasi untuk format konten peristiwa.
Value	string	Nilai sebelum transformasi.	{ "key": "value" }
Form	string	Format transformasi. Nilai default: CONSTANT.	CONSTANT
Template	string	Gaya template.	The value of ${key} is ${value}!
SinkRabbitMQParameters	object	Parameter target peristiwa Sink RabbitMQ.
InstanceId	object	Tipe layanan target adalah ApsaraMQ for RabbitMQ.
Value	string	ID instans ApsaraMQ for RabbitMQ.	si-296cd57939a1421b****
Form	string	Format transformasi. Nilai default: CONSTANT.	CONSTANT
Template	string	Tidak ada.
VirtualHostName	object	Nama vhost instans ApsaraMQ for RabbitMQ.
Value	string	Nama vhost instans ApsaraMQ for RabbitMQ.	rabbit-host
Form	string	Format transformasi. Nilai default: CONSTANT.	CONSTANT
Template	string	Tidak ada.
TargetType	object	Tipe target.
Value	string	Tipe target. Nilai yang valid: Exchange: mode Exchange. Queue: mode Queue.	Queue
Form	string	Format transformasi. Nilai default: CONSTANT.	CONSTANT
Template	string	Tidak ada.
Exchange	object	Mode Exchange. Parameter ini diperlukan hanya ketika parameter TargetType diatur ke Exchange.
Value	string	Nama exchange instans ApsaraMQ for RabbitMQ.	a_exchange
Form	string	Format transformasi. Nilai default: CONSTANT.	CONSTANT
Template	string	Tidak ada.
RoutingKey	object	Aturan routing pesan. Parameter ini diperlukan hanya ketika parameter TargetType diatur ke Exchange.
Value	string	Aturan routing pesan.	housekeeping
Form	string	Format transformasi. Nilai default: CONSTANT.	CONSTANT
Template	string	Tidak ada.
QueueName	object	Mode Queue. Parameter ini diperlukan hanya ketika parameter TargetType diatur ke Queue.
Value	string	Nama antrean instans.	MyQueue
Form	string	Format transformasi. Nilai default: CONSTANT.	CONSTANT
Template	string	Tidak ada.
Body	object	Konten pesan.
Value	string	Nilai sebelum transformasi.	{ "key": "value" }
Form	string	Format transformasi.	TEMPLATE
Template	string	Gaya template.	The value of ${key} is ${value}!
MessageId	object	ID pesan.
Value	string	Nilai sebelum transformasi.	{ "key": "value" }
Form	string	Format transformasi.	TEMPLATE
Template	string	Gaya template.	The value of ${key} is ${value}!
Properties	object	Properti filter.
Value	string	Nilai sebelum transformasi.	{ "key": "value" }
Form	string	Format transformasi.	TEMPLATE
Template	string	Gaya template.	The value of ${key} is ${value}!
SinkKafkaParameters	object	Parameter target peristiwa Sink Kafka.
InstanceId	object	Tipe layanan target adalah ApsaraMQ for Kafka.
Value	string	ID instans.	Defaut_1283278472_sad****
Form	string	Format transformasi. Nilai default: CONSTANT.	CONSTANT
Template	string	Tidak ada.
CompressionType	string
Topic	object	Nama topik.
Value	string	Nama topik.	topic
Form	string	Format transformasi. Nilai default: CONSTANT.	CONSTANT
Template	string	Tidak ada.
DynamicTopic	object	Menentukan kebijakan routing topik tujuan untuk pesan. Jika parameter topic dan topics ditentukan, parameter topics akan diprioritaskan. Dua mode konfigurasi didukung: 1. Mode konstanta statis: Tentukan nama topik tetap (seperti "order_created"). Semua pesan dikirim ke topik ini. 2. Mode ekstraksi dinamis: Tentukan ekspresi JSONPath standar (seperti "$.user.id" atau "$.metadata.category"). Sistem mengurai badan pesan upstream dan mengekstrak nilai field yang cocok sebagai nama topik tujuan.
Value	string	Nilai.
Form	string	Tipe transformasi. Nilai yang valid: CONSTANT: nilai tetap. JSONPATH: mengekstrak nilai dari upstream berdasarkan jalur.
Template	string	Template.
Acks	object	Mode acknowledgment untuk penulisan ke Kafka. Nilai yang valid: acks=0: Tidak diperlukan respons dari server. Mode ini memberikan performa tinggi tetapi risiko kehilangan data yang tinggi. acks=1: Respons dikembalikan setelah node primer berhasil menulis. Mode ini memberikan performa sedang dan risiko kehilangan data sedang. Kehilangan data dapat terjadi jika node primer mati. acks=all: Respons dikembalikan setelah node primer berhasil menulis dan node sekunder menyelesaikan sinkronisasi. Mode ini memberikan performa lebih rendah tetapi keamanan data lebih tinggi. Kehilangan data hanya terjadi jika node primer dan sekunder mati.
Value	string	Mode acknowledgment untuk penulisan ke Kafka. Nilai yang valid: acks=0: Tidak diperlukan respons dari server. Mode ini memberikan performa tinggi tetapi risiko kehilangan data yang tinggi. acks=1: Respons dikembalikan setelah node primer berhasil menulis. Mode ini memberikan performa sedang dan risiko kehilangan data sedang. Kehilangan data dapat terjadi jika node primer mati. acks=all: Respons dikembalikan setelah node primer berhasil menulis dan node sekunder menyelesaikan sinkronisasi. Mode ini memberikan performa lebih rendah tetapi keamanan data lebih tinggi. Kehilangan data hanya terjadi jika node primer dan sekunder mati.	1
Form	string	Format transformasi. Nilai default: CONSTANT.	CONSTANT
Template	string	Tidak ada.
Key	object	Kunci pesan.
Value	string	Kunci pesan.	key
Form	string	Format transformasi. Nilai default: CONSTANT.	CONSTANT
Template	string	Tidak ada.
Value	object	Konten badan pesan.
Value	string	Nilai sebelum transformasi.	{ "key": "value" }
Form	string	Format transformasi.	TEMPLATE
Template	string	Gaya template.	The value of ${key} is ${value}!
SinkRocketMQParameters	object	Parameter target peristiwa Sink RocketMQ.
InstanceId	object	Tipe layanan target adalah ApsaraMQ for RocketMQ.
Value	string	ID instans ApsaraMQ for RocketMQ.	MQ_INST_164901546557**_BAAN**
Form	string	Format transformasi. Nilai default: CONSTANT.	CONSTANT
Template	string	Tidak ada.
Topic	object	Topik instans ApsaraMQ for RocketMQ.
Value	string	Topik instans ApsaraMQ for RocketMQ.	topic
Form	string	Format transformasi. Nilai default: CONSTANT.	CONSTANT
Template	string	Tidak ada.
Body	object	Konten pesan.
Value	string	Nilai sebelum transformasi.	{ "key": "value" }
Form	string	Format transformasi.	TEMPLATE
Template	string	Gaya template.	The value of ${key} is ${value}!
Properties	object	Properti filter.
Value	string	Nilai sebelum transformasi.	{ "key": "value" }
Form	string	Format transformasi.	TEMPLATE
Template	string	Gaya template.	The value of ${key} is ${value}!
Keys	object	Properti filter.
Value	string	Nilai sebelum transformasi.	{ "key": "value" }
Form	string	Format transformasi.	TEMPLATE
Template	string	Gaya template.	The value of ${key} is ${value}!
Tags	object	Properti filter.
Value	string	Nilai sebelum transformasi.	{ "key": "value" }
Form	string	Format transformasi.	TEMPLATE
Template	string	Gaya template.	The value of ${key} is ${value}!
InstanceType	object	Tipe instans.
Value	string	Tipe instans. Nilai yang valid: Cloud_4: instans ApsaraMQ for RocketMQ 4.0 (default) Cloud_5: instans ApsaraMQ for RocketMQ 5.0 SelfBuilt: kluster Apache RocketMQ yang dikelola sendiri.	Cloud_4
Form	string	Format transformasi. Nilai default: CONSTANT.	CONSTANT
Template	string	Tidak ada.
InstanceEndpoint	object	Endpoint instans.
Value	string	Endpoint instans.	vbr-8vbsvkkbpf3vb0zef****
Form	string	Format transformasi. Nilai default: CONSTANT.	CONSTANT
Template	string	Tidak ada.
InstanceUsername	object	Nama pengguna instans.
Value	string	Nama pengguna instans.	admin
Form	string	Format transformasi. Nilai default: CONSTANT.	CONSTANT
Template	string	Tidak ada.
InstancePassword	object	Kata sandi instans.
Value	string	Kata sandi instans.	admin******
Form	string	Format transformasi. Nilai default: CONSTANT.	CONSTANT
Template	string	Tidak ada.
VpcId	object	ID VPC.
Value	string	ID VPC.	vbr-8vb835n3zf9shwlvb****
Form	string	Format transformasi untuk peristiwa. Default.	CONSTANT
Template	string	Tidak ada.
VSwitchIds	object	ID vSwitch.
Value	string	ID vSwitch.	vbr-8vb835n3zf9shwl****mp
Form	string	Format transformasi. Nilai default: CONSTANT.	CONSTANT
Template	string	Tidak ada.
SecurityGroupId	object	ID grup keamanan.
Value	string	ID grup keamanan.	b4bf375515f6440f942e3a20c33d****
Form	string	Format transformasi. Nilai default: CONSTANT.	CONSTANT
Template	string	Tidak ada.
Network	object	Tipe jaringan. Nilai yang valid: PublicNetwork PrivateNetwork.
Value	string	Tipe jaringan. Nilai yang valid: PublicNetwork PrivateNetwork.	PublicNetwork
Form	string	Format transformasi. Nilai default: CONSTANT.	CONSTANT
Template	string	Tidak ada.
DeliveryOrderType	object	Tipe urutan pengiriman pesan.
Value	string	Tipe urutan pengiriman.	Orderly
Form	string	Format transformasi. Nilai default: CONSTANT.	CONSTANT
Template	string	Tidak ada.
ShardingKey	object	Kunci sharding pesan, yang digunakan untuk mengontrol partisi pesan.
Value	string	Nilai kunci sharding.	order_id
Form	string	Format transformasi. Nilai default: CONSTANT.	CONSTANT
Template	string	Gaya template.
SinkDorisParameters	object
QueryEndpoint	object
Value	string
Form	string
Template	string
FeHttpEndpoint	object
Value	string
Form	string
Template	string
BeHttpEndpoint	object
Value	string
Form	string
Template	string
UserName	object
Value	string
Form	string
Template	string
Password	object
Value	string
Form	string
Template	string
Database	object
Value	string
Form	string
Template	string
Table	object
Value	string
Form	string
Template	string
Body	object
Value	string
Form	string
Template	string
NetworkType	object
Value	string
Form	string
Template	string
VpcId	object
Value	string
Form	string
Template	string
VSwitchIds	object
Value	string
Form	string
Template	string
SecurityGroupId	object
Value	string
Form	string
Template	string
SinkRocketMQCheckpointParameters	object	Parameter Sink RocketMQ Checkpoint.
InstanceType	string	Tipe instans ApsaraMQ for RocketMQ.	Cloud_5
InstanceId	string	ID instans RocketMQ.	MQ_INST_1825725063814405_BZ******
Topic	object	Topik instans ApsaraMQ for RocketMQ.
Value	string	Nama topik.	myTopic
Form	string	Format transformasi. Nilai default: CONSTANT.	CONSTANT
Template	string	Gaya template.
Group	object	Informasi grup konsumen ApsaraMQ for RocketMQ.
Value	string	ID grup konsumen.	GID_******
Form	string	Format transformasi. Nilai default: CONSTANT.	CONSTANT
Template	string	Gaya template.
ConsumeTimestamp	object	Checkpoint konsumsi.
Value	string	Stempel waktu.	1636597951964
Form	string	Format transformasi. Nilai default: CONSTANT.	CONSTANT
Template	string	Gaya template.
SinkApacheRocketMQCheckpointParameters	object	Parameter Sink Apache RocketMQ Checkpoint.
Topic	object	Nama topik instans Apache RocketMQ.
Value	string	Nama topik.	myTopic
Form	string	Format transformasi. Nilai default: CONSTANT.	CONSTANT
Template	string	Gaya template.
Group	object	Informasi grup konsumen Apache RocketMQ.
Value	string	ID grup konsumen.	GID_******
Form	string	Format transformasi. Nilai default: CONSTANT.	CONSTANT
Template	string	Gaya template.
ConsumeTimestamp	object	Checkpoint konsumsi.
Value	string	Stempel waktu.	1636597951964
Form	string	Format transformasi. Nilai default: CONSTANT.	CONSTANT
Template	string	Gaya template.
InstanceEndpoint	string	Endpoint instans Apache RocketMQ.	192.168.1.1:9876
InstanceUsername	string	Nama pengguna instans Apache RocketMQ.	admin
InstancePassword	string	Kata sandi instans Apache RocketMQ.	****
NetworkType	string	Tipe jaringan.	PrivateNetwork
VpcId	string	ID VPC.	vpc-2zehizpoendb3****
VSwitchId	string	ID vSwitch.	vsw-wz9qqeovkwjxlu9uc****
SecurityGroupId	string	ID grup keamanan.	sg-2vcgdxz7o1n9zapp****
SinkSLSParameters	object	Parameter Sink SLS
Project	object	Proyek Simple Log Service.
Value	string	Proyek Simple Log Service.	test-project
Form	string	Format transformasi. Nilai default: CONSTANT.	CONSTANT
Template	string	Tidak ada.
LogStore	object	Logstore Simple Log Service.
Value	string	Logstore Simple Log Service.	test-logstore
Form	string	Format transformasi. Nilai default: CONSTANT.	CONSTANT
Template	string	Tidak ada.
Topic	object	Topik tempat log berada, yang sesuai dengan field cadangan Simple Log Service "topic".
Value	string	Topik tempat log berada, yang sesuai dengan field cadangan Simple Log Service "topic".	topic
Form	string	Format transformasi. Nilai default: CONSTANT.	CONSTANT
Template	string	Tidak ada.
Body	object	Konten yang dikirim ke Simple Log Service.
Value	string	Nilai sebelum transformasi.	{ "key": "value" }
Form	string	Format transformasi.	TEMPLATE
Template	string	Gaya template.	The value of ${key} is ${value}!
RoleName	object	Untuk mengotorisasi EventBridge menggunakan peran ini untuk membaca konten log Simple Log Service, buat peran di konsol Resource Access Management (RAM), pilih Layanan Alibaba Cloud sebagai entitas tepercaya, dan pilih EventBridge sebagai layanan tepercaya.
Value	string	Untuk mengotorisasi EventBridge menggunakan peran ini untuk membaca konten log Simple Log Service, buat peran di konsol Resource Access Management (RAM), pilih Layanan Alibaba Cloud sebagai entitas tepercaya, dan pilih EventBridge sebagai layanan tepercaya.	test-role
Form	string	Format transformasi. Nilai default: CONSTANT.	CONSTANT
Template	string	Tidak ada.
ContentType	object	Format data Simple Log Service. Anda dapat memilih format default atau mengonfigurasi pasangan kunci-nilai tertentu. Nilai yang valid: JSON KeyValue.
Value	string	Format data Simple Log Service. Anda dapat memilih format default atau mengonfigurasi pasangan kunci-nilai tertentu. Nilai yang valid: JSON KeyValue.	JSON
Form	string	Format transformasi. Nilai default: CONSTANT.	CONSTANT
Template	string	Tidak ada.
ContentSchema	object	Pasangan kunci-nilai log kustom. Parameter ini hanya berlaku ketika ContentType diatur ke KeyValue. Setiap pasangan kunci-nilai direpresentasikan oleh Key_n dan Value_n.
Value	string	Nilai sebelum transformasi.	{"Key_1":{"form":"CONSTANT","value":"demoKey"},"Value_1":{"form":"JSONPATH","value":"$.data.value"}}
Form	string	Format transformasi. Nilai default: CONSTANT.	CONSTANT
Template	string	Tidak ada.
SinkFnfParameters	object	Parameter Sink Fnf.
FlowName	object	Nama flow.
Value	string	Nama flow.	test-streaming-fnf
Form	string	Format transformasi. Nilai default: CONSTANT.	CONSTANT
Template	string	Gaya template.
ExecutionName	object	Nama eksekusi.
Value	string	Nama eksekusi.	123
Form	string	Format transformasi. Nilai default: CONSTANT.	CONSTANT
Template	string	Gaya template.
Input	object	Informasi input eksekusi.
Value	string	Informasi input eksekusi.	123
Form	string	Format transformasi. Nilai default: CONSTANT.	CONSTANT
Template	string	Gaya template.
RoleName	object	Konfigurasi peran.
Value	string	Konfigurasi peran.	Al**FNF-x**
Form	string	Format transformasi. Nilai default: CONSTANT.	CONSTANT
Template	string	Gaya template.
SinkDataHubParameters	object	Parameter Sink DataHub.
Project	object	Nama proyek DataHub.
Value	string	Nama proyek DataHub.	demo-project
Form	string	Format transformasi. Nilai default: CONSTANT.	CONSTANT
Template	string	Tidak ada.
Topic	object	Nama topik DataHub.
Value	string	Nama topik DataHub.	demo-topic
Form	string	Format transformasi. Nilai default: CONSTANT.	CONSTANT
Template	string	Tidak ada.
TopicType	object	Tipe topik. Nilai yang valid: TUPLE BLOB.
Value	string	Tipe topik. Nilai yang valid: TUPLE BLOB.	TUPLE
Form	string	Format transformasi. Nilai default: CONSTANT.	CONSTANT
Template	string	Tidak ada.
TopicSchema	object	Skema konten topik untuk tipe TUPLE.
Value	string	Skema konten topik untuk tipe TUPLE.	{"k1":"value1","k2":"value2"}
Form	string	Format transformasi. Nilai default: CONSTANT.	CONSTANT
Template	string	Tidak ada.
Body	object	Template konten rekaman untuk tipe BLOB.
Value	string	Template konten rekaman untuk tipe BLOB.
Form	string	Format transformasi.	ORIGINAL
Template	string	Tidak ada.
RoleName	object	Untuk mengotorisasi EventBridge menggunakan peran ini untuk membaca konten log Simple Log Service, buat peran di konsol Resource Access Management (RAM), pilih Layanan Alibaba Cloud sebagai entitas tepercaya, dan pilih EventBridge sebagai layanan tepercaya.
Value	string	Untuk mengotorisasi EventBridge menggunakan peran ini untuk membaca konten log Simple Log Service, buat peran di konsol Resource Access Management (RAM), pilih Layanan Alibaba Cloud sebagai entitas tepercaya, dan pilih EventBridge sebagai layanan tepercaya.	testRole
Form	string	Format transformasi. Nilai default: CONSTANT.	CONSTANT
Template	string	Tidak ada.
SinkCustomizedKafkaParameters	object	Parameter Sink Kafka.
InstanceId	string	ID instans ApsaraMQ for Kafka.	90be1f96-4229-4535-bb76-34b4f6fb2b71
SinkCustomizedKafkaConnectorParameters	object	Parameter konektor Sink Kafka.
ConnectorPackageUrl	string	URL unduhan file OSS.	"https://examplebucket.oss-cn-hangzhou.aliyuncs.com/testDoc/Old_Homebrew/2024-06-26%2022%3A34%3A08/opt/homebrew/homebrew/Library/Homebrew/test/support/fixtures/cask/AppWithBinary.zip?OSSAccessKeyId=ri&Expires=1725539627&Signature=rb8q3OpV2i3gZJ"
ConnectorParameters	object	Mengurai file properti dalam paket ZIP saat ini.
Name	string	Nama konektor.	mongo-sink
Config	object	Konfigurasi konektor.	{ "connector.class": "com.mongodb.kafka.connect.MongoSinkConnector", "tasks.max": "1", "topics": "sourceA,sourceB" }
WorkerParameters	object	Konfigurasi instans.	{ "group.id": "connect-eb-cluster-KAFKA_CONNECTORC", "offset.storage.topic": "connect-eb-offset-KAFKA_CONNECTOR_yjqC8K5ewC", "config.storage.topic": "connect-eb-config-KAFKA_CONNECTOR_yjqC8K5ewC", "status.storage.topic": "connect-eb-status-KAFKA_CONNECTOR_yjqC8K5ewC", "consumer.group.id": "connector-eb-cluster-KAFKA_CONNECTOR_yjqC8K5ewC-mongo-sink", "bootstrap.servers": "alikafka-post:9092" }
SinkDashVectorParameters	object	Parameter Sink DashVector.
InstanceId	string	ID instans.	vrs-cn-lbj3ru1***
Collection	string	Nama koleksi.	collection1
ApiKey	string	Kunci API yang dibuat di konsol DashVector.	Q34nExQH7sQ****
Operation	string	Tipe operasi database DashVector.	Upsert
Network	string	Tipe jaringan.	PublicNetwork
PrimaryKeyId	object	ID kunci primer untuk memasukkan atau menghapus rekaman. Jika field ini tidak ditentukan, ID kunci primer acak akan digunakan.
Form	string	Format transformasi.	JSONPATH
Value	string	Jika Form adalah JSONPATH: konten yang diekstrak oleh JSONPath. Jika Form adalah TEMPLATE: variabel template. Catatan: Field Value tidak boleh melebihi 10.240 karakter.	$.data.requestId
Template	string	Template ID kunci primer. Parameter ini diperlukan hanya ketika Form diatur ke TEMPLATE.	${ID}
Partition	object	Partisi. Nilai default: default.
Form	string	Format transformasi.	CONSTANT
Value	string	Jika Form adalah CONSTANT: nilai konstanta. Jika Form adalah JSONPATH: konten yang diekstrak oleh JSONPath. Catatan: Field Value tidak boleh melebihi 10.240 karakter.	default
Template	string	Tidak ada.
Vector	object	Vektor rekaman yang akan dimasukkan ke DashVector.
Form	string	Format transformasi.	JSONPATH
Value	string	Konten yang diekstrak oleh JSONPath. Catatan: Field Value tidak boleh melebihi 10.240 karakter.	$.data.messageBody
Template	string	Tidak ada.
DashVectorSchemaParameters	array<object>	Definisi field skema untuk entri tabel saat memasukkan ke DashVector. Hasil setelah transformasi konten peristiwa harus dalam format JSON.
	array<object>
Name	object
Form	string
Value	string
Template	string
Type	object
Form	string
Value	string
Template	string
Value	object
Form	string
Value	string
Template	string
SinkOpenSourceRabbitMQParameters	object	Parameter Sink RabbitMQ sumber terbuka.
Endpoint	string	Endpoint instans RabbitMQ.	192.168.1.1:9876
VirtualHostName	string	Nama virtual host instans RabbitMQ.	Vhost1
TargetType	string	Tipe target.	exchange
Exchange	string	Nama exchange yang digunakan untuk routing pesan.	my_exchange
QueueName	string	Nama antrean yang digunakan untuk menyimpan pesan.	my_queue
Username	string	Nama pengguna yang digunakan untuk autentikasi.	admin
Password	string	Kata sandi yang digunakan untuk autentikasi.	****
VpcId	string	ID VPC.	vpc-2zehizpoendb3****
VSwitchIds	string	ID vSwitch.	vsw-wz9qqeovkwjxlu9uc****
SecurityGroupId	string	ID grup keamanan.	sg-2vcgdxz7o1n9zapp****
NetworkType	string	Tipe jaringan.	PrivateNetwork
AuthType	string	Tipe autentikasi.	ACL
RoutingKey	object	Aturan routing pesan. Parameter ini diperlukan hanya ketika parameter TargetType diatur ke Exchange.
Form	string	Format data. Nilai default: JSONPATH.	JSONPATH
Value	string	Aturan routing pesan.	housekeeping
Template	string	Gaya template.	The value of ${key} is ${value}!
Body	object	Konten pesan.
Form	string	Format transformasi.	TEMPLATE
Value	string	Nilai sebelum transformasi.	{ "key": "value" }
Template	string	Gaya template.	The value of ${key} is ${value}!
MessageId	object	ID pesan.
Form	string	Format transformasi.	TEMPLATE
Value	string	Nilai sebelum transformasi.	{ "key": "value" }
Template	string	Gaya template.	The value of ${key} is ${value}!
Properties	object	Properti filter.
Form	string	Format transformasi.	TEMPLATE
Value	string	Nilai sebelum transformasi.	{ "key": "value" }
Template	string	Gaya template.	The value of ${key} is ${value}!
SinkBaiLianParameters	SinkBaiLianParameters	Parameter Sink BaiLian.
SinkHttpsParameters	SinkHttpsParameters	Parameter target peristiwa HTTPS.
SinkApiDestinationParameters	SinkApiDestinationParameters	Parameter target peristiwa ApiDestination.
SinkOSSParameters	SinkOSSParameters
SinkRabbitMQMetaParameters	SinkRabbitMQMetaParameters
SinkRabbitMQMsgSyncParameters	SinkRabbitMQMsgSyncParameters
SinkMQTTParameters	SinkMQTTParameters
SinkAgentRunParameters	SinkAgentRunParameters
RunOptions	object	Parameter runtime.
MaximumTasks	integer	Konkurensi.	2
RetryStrategy	object	Kebijakan percobaan ulang saat pengiriman peristiwa gagal.
PushRetryStrategy	string	Kebijakan percobaan ulang. Nilai yang valid: BACKOFF_RETRY (percobaan ulang backoff) dan EXPONENTIAL_DECAY_RETRY (percobaan ulang peluruhan eksponensial).	EXPONENTIAL_DECAY_RETRY
ErrorsTolerance	string	Kebijakan toleransi kesalahan. Nilai yang valid: NONE (tanpa toleransi kesalahan) dan ALL (toleransi semua kesalahan).	ALL
DeadLetterQueue	object	Menentukan apakah akan mengaktifkan antrean dead-letter. Secara default, antrean dead-letter dinonaktifkan. Pesan yang melebihi kebijakan percobaan ulang akan dibuang.
Arn	string	ARN antrean dead-letter.	acs:ram::159787121179****:role/aliyunsaedefaultrole
Network	string	Tipe jaringan antrean dead-letter.	PrivateNetwork
VpcId	string	ID VPC antrean dead-letter.	vpc-2zehizpoendb3****
VSwitchIds	string	ID vSwitch antrean dead-letter.	vsw-m5ev8asdc6h12345****
SecurityGroupId	string	ID grup keamanan instans antrean dead-letter.	sg-2vcgdxz7o1n9zapp****
BatchWindow	object	Jendela batch.
CountBasedWindow	integer	Jumlah maksimum peristiwa yang dapat ditampung oleh jendela. Ketika ambang batas ini tercapai, data dalam jendela didorong ke downstream. Jika terdapat beberapa jendela, dorongan dipicu ketika salah satu jendela memenuhi ambang batas.	100
TimeBasedWindow	integer	Rentang waktu maksimum peristiwa yang dapat ditampung oleh jendela, dalam detik. Ketika ambang batas ini tercapai, data dalam jendela didorong ke downstream. Jika terdapat beberapa jendela, dorongan dipicu ketika salah satu jendela memenuhi ambang batas.	10
BusinessOption	object
BusinessMode	string
MinCapacityUnitCount	integer
MaxCapacityUnitCount	integer
Throttling	integer
Status	string	Status streaming peristiwa.	RUNNING
Metadata	string
NextToken	string	Indicates the position from which the current call returns. An empty value indicates that all data has been read. Set this value to the NextToken input parameter in the next invoke.	177
Total	integer	The total number of records.	10
Code	string	The return code. Valid values: Success: The request was successful. Other values: A fault occurred. For more details, see error codes.	Success
Success	boolean	Indicates whether the operation was successful. A value of true is returned if the operation was successful.	true.

Contoh

Respons sukses

JSONformat

{
  "Message": "The event streaming [xxxx] not existed!\n",
  "RequestId": "283FF852-C4B8-58C9-9777-F88A5A16****",
  "Data": {
    "EventStreamings": [
      {
        "EventStreamingName": "name",
        "Description": "demo",
        "Source": {
          "SourceMNSParameters": {
            "RegionId": "cn-zhangjiakou",
            "QueueName": "work4",
            "IsBase64Decode": true
          },
          "SourceRabbitMQParameters": {
            "RegionId": "cn-zhangjiakou",
            "InstanceId": "dbaudit-cn-7mz2hqo****",
            "VirtualHostName": "eb-connect\n",
            "QueueName": "liuyang"
          },
          "SourceRocketMQParameters": {
            "RegionId": "cn-chengdu",
            "InstanceId": "i-f8zbher64dlm58pl****\n",
            "Topic": "topic_add_anima",
            "Tag": "v1",
            "Offset": "CONSUMEFROMTIMESTAMP",
            "GroupID": "GID_group1",
            "Timestamp": 1670742074043,
            "InstanceType": "Cloud_4\n",
            "InstanceEndpoint": "registry-vpc.cn-hangzhou.aliyuncs.com",
            "AuthType": "ACL",
            "InstanceUsername": "admin**",
            "InstancePassword": "123",
            "InstanceVpcId": "vpc-bp1a4gmlk31hy***l3ss",
            "InstanceVSwitchIds": "vsw-m5ev8asdc6h123456****\n",
            "InstanceSecurityGroupId": "sg-m5edtu24f12345****\n",
            "InstanceNetwork": "PublicNetwork",
            "BodyDataType": "JSON\n",
            "Network": "PublicNetwork",
            "FilterType": "Tag\n",
            "FilterSql": "index > 10\n",
            "VpcId": "vpc-m5e3sv4b12345****\n",
            "VSwitchIds": "vsw-m5ev8asdc6h12345****\n",
            "SecurityGroupId": "sg-m5edtu24f12345****\n"
          },
          "SourceRocketMQCheckpointParameters": {
            "RegionId": "cn-hangzhou",
            "InstanceType": "Cloud_5",
            "InstanceId": "\nrmq-cn-jte3w******",
            "Topics": [
              "myTopic"
            ]
          },
          "SourceApacheRocketMQCheckpointParameters": {
            "RegionId": "cn-hangzhou",
            "Topics": [
              "myTopic"
            ],
            "InstanceEndpoint": "192.168.1.1:9876",
            "InstanceUsername": "admin",
            "InstancePassword": "****",
            "NetworkType": "PrivateNetwork",
            "VpcId": "vpc-adw1awdw*****",
            "VSwitchId": "vsw-dwaafds****",
            "SecurityGroupId": "sg-mw43*****"
          },
          "SourceKafkaParameters": {
            "RegionId": "cn-chengdu",
            "InstanceId": "bastionhost-cn-i7m2gwt****",
            "Topic": "topic_empower_1642473600414\n",
            "ConsumerGroup": "GID_TEST",
            "OffsetReset": "latest",
            "Network": "Default",
            "VpcId": "vpc-wz9ki1qdlx3cx5cbf****",
            "VSwitchIds": "vsw-bp1rmi8rind7eo50c****",
            "SecurityGroupId": "sg-5ud5f3p0rqqis69****eho7cp",
            "ValueDataType": "JSON\n"
          },
          "SourceMQTTParameters": {
            "RegionId": "cn-qingdao",
            "InstanceId": "bastionhost-cn-zvp27kc****",
            "Topic": "migration_instance",
            "BodyDataType": "JSON\n",
            "NetworkType": "",
            "VpcId": "",
            "VSwitchIds": "",
            "SecurityGroupId": ""
          },
          "SourceDTSParameters": {
            "TaskId": "1611b337285f44e2936a2c4170****",
            "BrokerUrl": "",
            "Topic": "TP_TEST_UNDERWRITE_ISSUE\n",
            "Sid": "HG9",
            "Username": "admin",
            "Password": "123456",
            "InitCheckPoint": "1620962769"
          },
          "SourceSLSParameters": {
            "Project": "dmmzk",
            "LogStore": "waf-logstore\n",
            "ConsumerGroup": "go-dts-shelf-group",
            "ConsumePosition": "begin",
            "RoleName": "testRole"
          },
          "SourcePrometheusParameters": {
            "RegionId": "cn-beijing",
            "ClusterId": "c83555068b6******ad213f565f209\n",
            "DataType": "JSON\n",
            "Labels": "__name__=.*\n",
            "RoleName": "testRole",
            "ExternalLabels": "{\"source\":\"prometheus-prod\"}"
          },
          "SourceCustomizedKafkaParameters": {
            "InstanceId": "gtm-cn-k2c2yfg****\n"
          },
          "SourceCustomizedKafkaConnectorParameters": {
            "ConnectorPackageUrl": "\"https://examplebucket.oss-cn-hangzhou.aliyuncs.com/testDoc/Old_Homebrew/2024-06-26%2022%3A34%3A08/opt/homebrew/homebrew/Library/Homebrew/test/support/fixtures/cask/AppWithBinary.zip?OSSAccessKeyId=ri&Expires=1725539627&Signature=rb8q3OpV2i3gZJ\"",
            "ConnectorParameters": {
              "Name": "test-name\n",
              "Config": {
                "connector.class": "com.mongodb.kafka.connect.MongoSinkConnector",
                "tasks.max": "1",
                "topics": "sourceA,sourceB"
              }
            },
            "WorkerParameters": {
              "group.id": "connect-eb-cluster-KAFKA_CONNECTORC",
              "offset.storage.topic": "connect-eb-offset-KAFKA_CONNECTOR_yjqC8K5ewC",
              "config.storage.topic": "connect-eb-config-KAFKA_CONNECTOR_yjqC8K5ewC",
              "status.storage.topic": "connect-eb-status-KAFKA_CONNECTOR_yjqC8K5ewC",
              "consumer.group.id": "connector-eb-cluster-KAFKA_CONNECTOR_yjqC8K5ewC-mongo-sink",
              "bootstrap.servers": "alikafka-post:9092"
            }
          },
          "SourceOSSParameters": {
            "RoleName": "eventbridge_oss_role\n",
            "BucketName": "bucket_abc\n",
            "Prefix": "fun/document/\n",
            "LoadMode": "single\n",
            "LoadFormat": "TextLoader\n",
            "Delimiter": "\\n\n"
          },
          "SourceOpenSourceRabbitMQParameters": {
            "Endpoint": "192.168.1.1:9876",
            "VirtualHostName": "Vhost1",
            "QueueName": "demo",
            "BodyDataType": "Json",
            "Username": "admin",
            "Password": "****",
            "VpcId": "vpc-m5e3sv4b12345****",
            "VSwitchIds": "vsw-m5ev8asdc6h12345****",
            "SecurityGroupId": "sg-m5edtu24f12345****",
            "NetworkType": "PrivateNetwork",
            "AuthType": "ACL"
          },
          "SourceEventBusParameters": {
            "EventBusName": "my-event-bus",
            "EventRuleName": "my-event-rule"
          },
          "SourceMySQLParameters": {
            "RegionId": "",
            "HostName": "",
            "User": "",
            "Password": "",
            "DatabaseName": "",
            "TableNames": "",
            "NetworkType": "",
            "VpcId": "",
            "VSwitchIds": "",
            "SecurityGroupId": "",
            "Port": 0,
            "SnapshotMode": "",
            "IncludeSchemaChanges": ""
          },
          "SourcePostgreSQLParameters": {
            "RegionId": "",
            "HostName": "",
            "Port": 0,
            "User": "",
            "Password": "",
            "DatabaseName": "",
            "SchemaName": "",
            "TableNames": "",
            "NetworkType": "",
            "VpcId": "",
            "VSwitchIds": "",
            "SecurityGroupId": "",
            "SnapshotMode": ""
          },
          "SourceRabbitMQMetaParameters": {
            "InstanceType": "",
            "InstanceId": "",
            "Endpoint": "",
            "VirtualHostName": "",
            "Regex": "",
            "Username": "",
            "Password": "",
            "VpcId": "",
            "VSwitchIds": "",
            "SecurityGroupId": "",
            "NetworkType": "",
            "MaxHops": "",
            "OrderConsume": "",
            "InnerNameSuffix": "",
            "SyncMetaType": ""
          },
          "SourceRabbitMQMsgSyncParameters": {
            "InstanceType": "",
            "InstanceId": "",
            "Endpoint": "",
            "VirtualHostName": "",
            "OrderConsume": "",
            "BodyDataType": "",
            "PrefetchCount": "",
            "Username": "",
            "Password": "",
            "VpcId": "",
            "VSwitchIds": "",
            "SecurityGroupId": "",
            "NetworkType": "",
            "SyncMetaType": "",
            "Regex": "",
            "SrcClusterType": "",
            "SrcClusterHost": "",
            "DstClusterType": "",
            "DstClusterHost": "",
            "CloudMigrationTaskId": ""
          },
          "SourceFeiShuDocsParameters": {
            "AppId": "",
            "AppSecret": "",
            "KnowledgeSpaceName": "",
            "LoadMode": ""
          },
          "SourceJDBCParameters": {
            "JdbcUrl": "",
            "Username": "",
            "Password": "",
            "QueryMode": "",
            "TableName": "",
            "IncrementingColumn": "",
            "TimestampColumn": "",
            "PollingInterval": 0,
            "BatchSize": 0,
            "QueryTimeout": 0,
            "CustomQuery": "",
            "Network": "",
            "VpcId": "",
            "VSwitchIds": "",
            "SecurityGroupId": ""
          }
        },
        "FilterPattern": "",
        "Transforms": [
          {
            "Arn": "acs:fc:cn-hangzhou:*****:services/demo-service.LATEST/functions/demo-func\n",
            "DashScopeTransformParameters": {
              "Model": "",
              "ApiKey": "",
              "StructuredOutputJsonSchema": "",
              "RequestPerMinute": 0,
              "TokenPerMinute": 0,
              "Messages": [
                {
                  "Role": "",
                  "Form": "",
                  "Value": "",
                  "Template": ""
                }
              ]
            },
            "BaiLianAgentTransformParameters": {
              "ApplicationId": "",
              "Prompt": {
                "Form": "",
                "Value": "",
                "Template": ""
              },
              "ApiKey": "",
              "RequestPerMinute": 0,
              "TokenPerMinute": 0
            }
          }
        ],
        "Sink": {
          "SinkMNSParameters": {
            "QueueName": {
              "Value": "MyQueue",
              "Form": "CONSTANT",
              "Template": ""
            },
            "Body": {
              "Value": "{\n      \"key\": \"value\"\n}",
              "Form": "TEMPLATE",
              "Template": "The value of ${key} is ${value}!\n"
            },
            "IsBase64Encode": {
              "Value": "true",
              "Form": "CONSTANT",
              "Template": ""
            }
          },
          "SinkEventHouseParameters": {
            "CatalogName": "cat1",
            "NamespaceName": "name1",
            "EventTableName": "table1",
            "MappingRules": [
              {
                "ColumnValue": {
                  "Value": "$.data.value",
                  "Form": "JSONPATH",
                  "Template": "The value of ${key} is ${value}!"
                },
                "ColumnName": "age",
                "ColumnType": "text"
              }
            ]
          },
          "SinkFcParameters": {
            "ServiceName": {
              "Value": "myService",
              "Form": "CONSTANT",
              "Template": ""
            },
            "FunctionName": {
              "Value": "mFunction",
              "Form": "CONSTANT",
              "Template": ""
            },
            "Concurrency": {
              "Value": "1",
              "Form": "CONSTANT",
              "Template": ""
            },
            "Qualifier": {
              "Value": "LATEST",
              "Form": "CONSTANT",
              "Template": ""
            },
            "InvocationType": {
              "Value": "Async",
              "Form": "CONSTANT",
              "Template": ""
            },
            "Body": {
              "Value": "{\n      \"key\": \"value\"\n}",
              "Form": "TEMPLATE",
              "Template": "The value of ${key} is ${value}!\n"
            },
            "DataFormat": {
              "Value": "{\n      \"key\": \"value\"\n}",
              "Form": "CONSTANT",
              "Template": "The value of ${key} is ${value}!\n"
            }
          },
          "SinkRabbitMQParameters": {
            "InstanceId": {
              "Value": "si-296cd57939a1421b****",
              "Form": "CONSTANT",
              "Template": ""
            },
            "VirtualHostName": {
              "Value": "rabbit-host\n",
              "Form": "CONSTANT",
              "Template": ""
            },
            "TargetType": {
              "Value": "Queue",
              "Form": "CONSTANT",
              "Template": ""
            },
            "Exchange": {
              "Value": "a_exchange",
              "Form": "CONSTANT",
              "Template": ""
            },
            "RoutingKey": {
              "Value": "housekeeping",
              "Form": "CONSTANT",
              "Template": ""
            },
            "QueueName": {
              "Value": "MyQueue",
              "Form": "CONSTANT",
              "Template": ""
            },
            "Body": {
              "Value": "{\n      \"key\": \"value\"\n}",
              "Form": "TEMPLATE",
              "Template": "The value of ${key} is ${value}!\n"
            },
            "MessageId": {
              "Value": "{\n      \"key\": \"value\"\n}",
              "Form": "TEMPLATE",
              "Template": "The value of ${key} is ${value}!\n"
            },
            "Properties": {
              "Value": "{\n      \"key\": \"value\"\n}",
              "Form": "TEMPLATE",
              "Template": "The value of ${key} is ${value}!\n"
            }
          },
          "SinkKafkaParameters": {
            "InstanceId": {
              "Value": "Defaut_1283278472_sad****",
              "Form": "CONSTANT",
              "Template": ""
            },
            "CompressionType": "",
            "Topic": {
              "Value": "topic",
              "Form": "CONSTANT",
              "Template": ""
            },
            "DynamicTopic": {
              "Value": "",
              "Form": "",
              "Template": ""
            },
            "Acks": {
              "Value": "1",
              "Form": "CONSTANT",
              "Template": ""
            },
            "Key": {
              "Value": "key",
              "Form": "CONSTANT",
              "Template": ""
            },
            "Value": {
              "Value": "{\n      \"key\": \"value\"\n}",
              "Form": "TEMPLATE",
              "Template": "The value of ${key} is ${value}!\n"
            }
          },
          "SinkRocketMQParameters": {
            "InstanceId": {
              "Value": "MQ_INST_164901546557****_BAAN****\n",
              "Form": "CONSTANT",
              "Template": ""
            },
            "Topic": {
              "Value": "topic",
              "Form": "CONSTANT",
              "Template": ""
            },
            "Body": {
              "Value": "{\n      \"key\": \"value\"\n}",
              "Form": "TEMPLATE",
              "Template": "The value of ${key} is ${value}!\n"
            },
            "Properties": {
              "Value": "{\n      \"key\": \"value\"\n}",
              "Form": "TEMPLATE",
              "Template": "The value of ${key} is ${value}!\n"
            },
            "Keys": {
              "Value": "{\n      \"key\": \"value\"\n}",
              "Form": "TEMPLATE",
              "Template": "The value of ${key} is ${value}!\n"
            },
            "Tags": {
              "Value": "{\n      \"key\": \"value\"\n}",
              "Form": "TEMPLATE",
              "Template": "The value of ${key} is ${value}!\n"
            },
            "InstanceType": {
              "Value": "Cloud_4",
              "Form": "CONSTANT\n",
              "Template": ""
            },
            "InstanceEndpoint": {
              "Value": "vbr-8vbsvkkbpf3vb0zef****\n",
              "Form": "CONSTANT\n",
              "Template": ""
            },
            "InstanceUsername": {
              "Value": "admin\n",
              "Form": "CONSTANT\n",
              "Template": ""
            },
            "InstancePassword": {
              "Value": "admin******\n",
              "Form": "CONSTANT\n",
              "Template": ""
            },
            "VpcId": {
              "Value": "vbr-8vb835n3zf9shwlvb****\n",
              "Form": "CONSTANT\n",
              "Template": ""
            },
            "VSwitchIds": {
              "Value": "vbr-8vb835n3zf9shwl****mp\n",
              "Form": "CONSTANT\n\n",
              "Template": ""
            },
            "SecurityGroupId": {
              "Value": "b4bf375515f6440f942e3a20c33d****\n",
              "Form": "CONSTANT\n",
              "Template": ""
            },
            "Network": {
              "Value": "PublicNetwork\n",
              "Form": "CONSTANT\n",
              "Template": ""
            },
            "DeliveryOrderType": {
              "Value": "Orderly",
              "Form": "CONSTANT",
              "Template": ""
            },
            "ShardingKey": {
              "Value": "order_id",
              "Form": "CONSTANT",
              "Template": ""
            }
          },
          "SinkDorisParameters": {
            "QueryEndpoint": {
              "Value": "",
              "Form": "",
              "Template": ""
            },
            "FeHttpEndpoint": {
              "Value": "",
              "Form": "",
              "Template": ""
            },
            "BeHttpEndpoint": {
              "Value": "",
              "Form": "",
              "Template": ""
            },
            "UserName": {
              "Value": "",
              "Form": "",
              "Template": ""
            },
            "Password": {
              "Value": "",
              "Form": "",
              "Template": ""
            },
            "Database": {
              "Value": "",
              "Form": "",
              "Template": ""
            },
            "Table": {
              "Value": "",
              "Form": "",
              "Template": ""
            },
            "Body": {
              "Value": "",
              "Form": "",
              "Template": ""
            },
            "NetworkType": {
              "Value": "",
              "Form": "",
              "Template": ""
            },
            "VpcId": {
              "Value": "",
              "Form": "",
              "Template": ""
            },
            "VSwitchIds": {
              "Value": "",
              "Form": "",
              "Template": ""
            },
            "SecurityGroupId": {
              "Value": "",
              "Form": "",
              "Template": ""
            }
          },
          "SinkRocketMQCheckpointParameters": {
            "InstanceType": "Cloud_5",
            "InstanceId": "MQ_INST_1825725063814405_BZ******",
            "Topic": {
              "Value": "myTopic",
              "Form": "CONSTANT",
              "Template": ""
            },
            "Group": {
              "Value": "GID_******",
              "Form": "CONSTANT",
              "Template": ""
            },
            "ConsumeTimestamp": {
              "Value": "1636597951964",
              "Form": "CONSTANT",
              "Template": ""
            }
          },
          "SinkApacheRocketMQCheckpointParameters": {
            "Topic": {
              "Value": "myTopic",
              "Form": "CONSTANT",
              "Template": ""
            },
            "Group": {
              "Value": "GID_******",
              "Form": "CONSTANT",
              "Template": ""
            },
            "ConsumeTimestamp": {
              "Value": "1636597951964",
              "Form": "CONSTANT",
              "Template": ""
            },
            "InstanceEndpoint": "192.168.1.1:9876",
            "InstanceUsername": "admin",
            "InstancePassword": "****",
            "NetworkType": "PrivateNetwork",
            "VpcId": "vpc-2zehizpoendb3****",
            "VSwitchId": "vsw-wz9qqeovkwjxlu9uc****",
            "SecurityGroupId": "sg-2vcgdxz7o1n9zapp****"
          },
          "SinkSLSParameters": {
            "Project": {
              "Value": "test-project\n",
              "Form": "CONSTANT",
              "Template": ""
            },
            "LogStore": {
              "Value": "test-logstore\n",
              "Form": "CONSTANT",
              "Template": ""
            },
            "Topic": {
              "Value": "topic",
              "Form": "CONSTANT",
              "Template": ""
            },
            "Body": {
              "Value": "{\n      \"key\": \"value\"\n}",
              "Form": "TEMPLATE",
              "Template": "The value of ${key} is ${value}!\n"
            },
            "RoleName": {
              "Value": "test-role",
              "Form": "CONSTANT",
              "Template": ""
            },
            "ContentType": {
              "Value": "JSON\n",
              "Form": "CONSTANT",
              "Template": ""
            },
            "ContentSchema": {
              "Value": "{\"Key_1\":{\"form\":\"CONSTANT\",\"value\":\"demoKey\"},\"Value_1\":{\"form\":\"JSONPATH\",\"value\":\"$.data.value\"}}",
              "Form": "CONSTANT\n",
              "Template": ""
            }
          },
          "SinkFnfParameters": {
            "FlowName": {
              "Value": "test-streaming-fnf\n",
              "Form": "CONSTANT",
              "Template": ""
            },
            "ExecutionName": {
              "Value": "123",
              "Form": "CONSTANT",
              "Template": ""
            },
            "Input": {
              "Value": "123",
              "Form": "CONSTANT",
              "Template": ""
            },
            "RoleName": {
              "Value": "Al****FNF-x****\n",
              "Form": "CONSTANT",
              "Template": ""
            }
          },
          "SinkDataHubParameters": {
            "Project": {
              "Value": "demo-project\n",
              "Form": "CONSTANT\n",
              "Template": ""
            },
            "Topic": {
              "Value": "demo-topic\n",
              "Form": "CONSTANT\n",
              "Template": ""
            },
            "TopicType": {
              "Value": "TUPLE\n",
              "Form": "CONSTANT\n",
              "Template": ""
            },
            "TopicSchema": {
              "Value": "{\"k1\":\"value1\",\"k2\":\"value2\"}\n",
              "Form": "CONSTANT",
              "Template": ""
            },
            "Body": {
              "Value": "",
              "Form": "ORIGINAL\n",
              "Template": ""
            },
            "RoleName": {
              "Value": "testRole\n",
              "Form": "CONSTANT\n",
              "Template": ""
            }
          },
          "SinkCustomizedKafkaParameters": {
            "InstanceId": "90be1f96-4229-4535-bb76-34b4f6fb2b71\n"
          },
          "SinkCustomizedKafkaConnectorParameters": {
            "ConnectorPackageUrl": "\"https://examplebucket.oss-cn-hangzhou.aliyuncs.com/testDoc/Old_Homebrew/2024-06-26%2022%3A34%3A08/opt/homebrew/homebrew/Library/Homebrew/test/support/fixtures/cask/AppWithBinary.zip?OSSAccessKeyId=ri&Expires=1725539627&Signature=rb8q3OpV2i3gZJ\"",
            "ConnectorParameters": {
              "Name": "mongo-sink\n",
              "Config": {
                "connector.class": "com.mongodb.kafka.connect.MongoSinkConnector",
                "tasks.max": "1",
                "topics": "sourceA,sourceB"
              }
            },
            "WorkerParameters": {
              "group.id": "connect-eb-cluster-KAFKA_CONNECTORC",
              "offset.storage.topic": "connect-eb-offset-KAFKA_CONNECTOR_yjqC8K5ewC",
              "config.storage.topic": "connect-eb-config-KAFKA_CONNECTOR_yjqC8K5ewC",
              "status.storage.topic": "connect-eb-status-KAFKA_CONNECTOR_yjqC8K5ewC",
              "consumer.group.id": "connector-eb-cluster-KAFKA_CONNECTOR_yjqC8K5ewC-mongo-sink",
              "bootstrap.servers": "alikafka-post:9092"
            }
          },
          "SinkDashVectorParameters": {
            "InstanceId": "vrs-cn-lbj3ru1***\n",
            "Collection": "collection1\n",
            "ApiKey": "Q34nExQH7sQ****\n",
            "Operation": "Upsert\n",
            "Network": "PublicNetwork\n",
            "PrimaryKeyId": {
              "Form": "JSONPATH\n",
              "Value": "$.data.requestId\n",
              "Template": "${ID}\n"
            },
            "Partition": {
              "Form": "CONSTANT\n",
              "Value": "default\n",
              "Template": ""
            },
            "Vector": {
              "Form": "JSONPATH\n",
              "Value": "$.data.messageBody\n",
              "Template": ""
            },
            "DashVectorSchemaParameters": [
              {
                "Name": {
                  "Form": "",
                  "Value": "",
                  "Template": ""
                },
                "Type": {
                  "Form": "",
                  "Value": "",
                  "Template": ""
                },
                "Value": {
                  "Form": "",
                  "Value": "",
                  "Template": ""
                }
              }
            ]
          },
          "SinkOpenSourceRabbitMQParameters": {
            "Endpoint": "192.168.1.1:9876",
            "VirtualHostName": "Vhost1",
            "TargetType": "exchange",
            "Exchange": "my_exchange",
            "QueueName": "my_queue",
            "Username": "admin",
            "Password": "****",
            "VpcId": "vpc-2zehizpoendb3****",
            "VSwitchIds": "vsw-wz9qqeovkwjxlu9uc****",
            "SecurityGroupId": "sg-2vcgdxz7o1n9zapp****",
            "NetworkType": "PrivateNetwork",
            "AuthType": "ACL",
            "RoutingKey": {
              "Form": "JSONPATH",
              "Value": "housekeeping\n",
              "Template": "The value of ${key} is ${value}!\n"
            },
            "Body": {
              "Form": "TEMPLATE\n",
              "Value": "{\n      \"key\": \"value\"\n}",
              "Template": "The value of ${key} is ${value}!\n"
            },
            "MessageId": {
              "Form": "TEMPLATE\n",
              "Value": "{\n      \"key\": \"value\"\n}",
              "Template": "The value of ${key} is ${value}!"
            },
            "Properties": {
              "Form": "TEMPLATE",
              "Value": "\t\n{\n      \"key\": \"value\"\n}",
              "Template": "The value of ${key} is ${value}!"
            }
          },
          "SinkBaiLianParameters": {
            "WorkspaceId": "",
            "ApplicationType": "",
            "Before": {
              "Form": "",
              "Value": "",
              "Template": ""
            },
            "After": {
              "Form": "",
              "Value": "",
              "Template": ""
            },
            "Context": "",
            "Extend": "",
            "Op": {
              "Form": "",
              "Value": "",
              "Template": ""
            },
            "Partition": {
              "Form": "",
              "Value": "",
              "Template": ""
            },
            "Offset": {
              "Form": "",
              "Value": "",
              "Template": ""
            }
          },
          "SinkHttpsParameters": {
            "URL": {
              "Form": "",
              "Value": "",
              "Template": ""
            },
            "Method": "",
            "Body": {
              "Form": "",
              "Value": "",
              "Template": ""
            },
            "Token": "",
            "NetworkType": "",
            "VpcId": "",
            "VSwitchIds": "",
            "SecurityGroupId": ""
          },
          "SinkApiDestinationParameters": {
            "Name": "",
            "HeaderParameters": {
              "Form": "",
              "Value": "",
              "Template": ""
            },
            "BodyParameters": {
              "Form": "",
              "Value": "",
              "Template": ""
            },
            "QueryStringParameters": {
              "Form": "",
              "Value": "",
              "Template": ""
            },
            "Timeout": 0
          },
          "SinkOSSParameters": {
            "BucketName": "",
            "RegionId": "",
            "Endpoint": "",
            "RoleArn": "",
            "RotateSizeBytes": "",
            "RotateIntervalMs": "",
            "PathFormat": "",
            "CompressionType": "",
            "TaskConcurrency": "",
            "TimeZone": "",
            "SSLEnabled": false,
            "ContentTransform": {
              "Form": "",
              "Value": "",
              "Template": ""
            }
          },
          "SinkRabbitMQMetaParameters": {
            "InstanceType": "",
            "InstanceId": "",
            "Endpoint": "",
            "VirtualHostName": "",
            "Username": "",
            "Password": "",
            "VpcId": "",
            "VSwitchIds": "",
            "SecurityGroupId": "",
            "NetworkType": ""
          },
          "SinkRabbitMQMsgSyncParameters": {
            "InstanceType": "",
            "InstanceId": "",
            "Endpoint": "",
            "VirtualHostName": "",
            "Body": {
              "Form": "",
              "Value": "",
              "Template": ""
            },
            "MessageId": {
              "Form": "",
              "Value": "",
              "Template": ""
            },
            "Properties": {
              "Form": "",
              "Value": "",
              "Template": ""
            },
            "Exchange": {
              "Form": "",
              "Value": "",
              "Template": ""
            },
            "RoutingKey": {
              "Form": "",
              "Value": "",
              "Template": ""
            },
            "MaxHops": "",
            "Username": "",
            "Password": "",
            "VpcId": "",
            "VSwitchIds": "",
            "SecurityGroupId": "",
            "NetworkType": ""
          },
          "SinkMQTTParameters": {
            "InstanceId": "",
            "ParentTopic": "",
            "SubTopic": {
              "Form": "",
              "Value": "",
              "Template": ""
            },
            "Payload": {
              "Form": "",
              "Value": "",
              "Template": ""
            },
            "Mqtt5UserProperty": {
              "Form": "",
              "Value": "",
              "Template": ""
            }
          },
          "SinkAgentRunParameters": {
            "AgentRuntimeName": "",
            "EndpointName": "",
            "RoleName": "",
            "Body": {
              "Value": "",
              "Form": "",
              "Template": ""
            },
            "Timeout": ""
          }
        },
        "RunOptions": {
          "MaximumTasks": 2,
          "RetryStrategy": {
            "PushRetryStrategy": "EXPONENTIAL_DECAY_RETRY"
          },
          "ErrorsTolerance": "ALL",
          "DeadLetterQueue": {
            "Arn": "acs:ram::159787121179****:role/aliyunsaedefaultrole",
            "Network": "PrivateNetwork",
            "VpcId": "vpc-2zehizpoendb3****",
            "VSwitchIds": "vsw-m5ev8asdc6h12345****",
            "SecurityGroupId": "sg-2vcgdxz7o1n9zapp****"
          },
          "BatchWindow": {
            "CountBasedWindow": 100,
            "TimeBasedWindow": 10
          },
          "BusinessOption": {
            "BusinessMode": "",
            "MinCapacityUnitCount": 0,
            "MaxCapacityUnitCount": 0
          },
          "Throttling": 0
        },
        "Status": "RUNNING",
        "Metadata": ""
      }
    ],
    "NextToken": "177",
    "Total": 10
  },
  "Code": "Success",
  "Success": true
}

Kode kesalahan

HTTP status code	Error code	Error message	Description
403	ServiceNotEnable	Service not enable

Lihat Error Codes untuk daftar lengkap.

Catatan rilis

Lihat Release Notes untuk daftar lengkap.