All Products
Search
Document Center

EventBridge:UpdateEventStreaming

Last Updated:Jul 21, 2026

Mengubah informasi dasar, informasi sumber event, pola filter event, atau informasi target event dari aliran acara.

Deskripsi operasi

Mengubah informasi dasar, informasi sumber event, pola filter event, atau informasi target event dari 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:UpdateEventStreaming

update

*EventStreaming

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

None None

Parameter permintaan

Parameter

Type

Required

Description

Example

EventStreamingName

string

Yes

Nama aliran acara.

myeventstreaming

Description

string

No

Deskripsi aliran acara.

rocketmq2mns.

FilterPattern

string

No

Aturan filter event. Jika Anda tidak menentukan parameter ini, semua event akan dicocokkan. Untuk informasi lebih lanjut, lihat https://www.alibabacloud.com/help/en/eventbridge/user-guide/event-patterns

{ "source": [ { "prefix": "acs:mns" } ], "type": [ { "prefix": "mns:Queue" } ], "subject": [ { "prefix": "acs:mns:cn-hangzhou:123456789098****:queues/zeus" } ] }

Source

object

No

Penyedia event. Anda harus memilih satu dan hanya satu tipe Sumber.

SourceMNSParameters

object

No

Parameter sumber Antrian Pesan (sebelumnya MNS).

RegionId

string

No

ID wilayah.

cn-hangzhou.

QueueName

string

No

Nama antrian.

queue_api_1642474203601

IsBase64Decode

boolean

No

Apakah akan mengaktifkan dekode Base64. Nilai default: true.

true.

SourceRabbitMQParameters

object

No

Sumber RabbitMQ sumber.

RegionId

string

No

ID wilayah.

cn-hangzhou.

InstanceId

string

No

ID instans ApsaraMQ for RabbitMQ.

i-f8z9lqkldlb4oxsxwwub.

VirtualHostName

string

No

Nama vhost dari instans ApsaraMQ for RabbitMQ.

eb-connect.

QueueName

string

No

Nama antrian dari instans ApsaraMQ for RabbitMQ.

demo.

SourceKafkaParameters

object

No

Sumber Kafka sumber.

RegionId

string

No

ID wilayah.

cn-zhangjiakou.

InstanceId

string

No

ID instans.

i-8vbh4a5b9yfhgkkzm****

Topic

string

No

Nama topik.

topic_empower_1641539400786

ConsumerGroup

string

No

ID kelompok konsumen yang berlangganan topik.

DEFAULT_GROUP.

OffsetReset

string

No

Offset.

latest.

Network

string

No

Konfigurasi jaringan. Nilai default: Default. Atur ke PublicNetwork untuk jaringan VPC.

Default.

VpcId

string

No

ID virtual private cloud (VPC).

vpc-2ze6p0o345nykmekxt****

VSwitchIds

string

No

ID vSwitch.

vsw-wz9t1l1e8eu2om****

SecurityGroupId

string

No

ID grup keamanan.

sg-uf6jcm3y5hcs7hkl****

ValueDataType

string

No

Metode encoding dan decoding. Nilai valid:

  • Json: mendekode byte menjadi string menggunakan encoding UTF-8 dan mengurai string ke format JSON.

  • Text: mendekode byte menjadi string menggunakan encoding UTF-8 dan langsung menempatkan string ke dalam muatan.

  • Binary: mengencode byte menjadi string menggunakan encoding Base64 dan menempatkan string ke dalam muatan.

Text.

SourceRocketMQParameters

object

No

Sumber RocketMQ sumber.

RegionId

string

No

ID wilayah dari instans ApsaraMQ for RocketMQ.

cn-shanghai.

InstanceId

string

No

ID instans dari instans ApsaraMQ for RocketMQ.

i-f8z9a9mcgwri1c1id****

Topic

string

No

Nama topik.

TOPIC-cainiao-pcs-order-process-inBoundConditionCheck

Tag

string

No

Tag filter Paket.

test.

Offset

string

No

Offset konsumsi Paket. Nilai valid:

  • CONSUMEFROMLASTOFFSET: Konsumsi dimulai dari offset terbaru.

  • CONSUMEFROMFIRSTOFFSET: Konsumsi dimulai dari offset paling awal.

  • CONSUMEFROMTIMESTAMP: Konsumsi dimulai dari offset pada pengatur waktu yang ditentukan.

Nilai default: CONSUMEFROMLAST_OFFSET.

CONSUMEFROMLASTOFFSET.

GroupID

string

No

ID kelompok dari instans ApsaraMQ for RocketMQ.

GID_test.

Timestamp

integer

No

Stempel waktu UNIX. Parameter ini hanya berlaku jika parameter Offset diatur ke CONSUMEFROMTIMESTAMP.

1670656652009

InstanceType

string

No

Tipe instans. Nilai valid:

  • Cloud_4 (default): Instans Alibaba Cloud RocketMQ 4.0

  • Cloud_5: Instans Alibaba Cloud RocketMQ 5.0

  • SelfBuilt: Instans Apache RocketMQ yang dikelola sendiri

Cloud_5

InstanceEndpoint

string

No

Titik akhir instans.

reg****-vpc.cn-zhangjiakou.aliyuncs.com.

InstanceUsername

string

No

Nama pengguna instans.

admin.

InstancePassword

string

No

Kata sandi instans.

admin.

AuthType

string

No

Tipe otentikasi.

ACL.

InstanceVpcId

string

No

Informasi VPC instans.

vpc-m5e3sv4b12345****

InstanceVSwitchIds

string

No

Informasi vSwitch instans.

vsw-m5ev8asdc6h12****

InstanceSecurityGroupId

string

No

Informasi grup keamanan instans.

sg-m5edtu24f12345****

InstanceNetwork

string

No

Informasi jaringan instans. Nilai valid:

  • PublicNetwork

  • PrivateNetwork

PublicNetwork.

BodyDataType

string

No

Format encoding Paket. Nilai valid:

  • Json

  • Text

  • Binary

Json.

FilterType

string

No

Tipe filter Paket.

Tag.

FilterSql

string

No

Pernyataan filter SQL.

index > 10

VpcId

string

No

ID VPC instans.

vpc-m5e3sv4b12345****

VSwitchIds

string

No

ID vSwitch.

vsw-m5ev8asdc6h12345****

SecurityGroupId

string

No

ID grup keamanan.

sg-m5edtu24f12345****

Network

string

No

Jenis jaringan. Nilai valid:

  • PublicNetwork

  • PrivateNetwork

PublicNetwork.

SourceRocketMQCheckpointParameters

object

No

Sumber RocketMQ Checkpoint sumber.

RegionId

string

No

ID wilayah.

cn-hangzhou.

InstanceType

string

No

Tipe instans ApsaraMQ for RocketMQ.

Cloud_5

InstanceId

string

No

ID instans dari instans ApsaraMQ for RocketMQ.

rmq-cn-jte3w******

Topics

array

No

Topik dari instans ApsaraMQ for RocketMQ.

string

No

Topik dari instans ApsaraMQ for RocketMQ.

myTopic.

SourceApacheRocketMQCheckpointParameters

object

No

Sumber RocketMQ Checkpoint sumber.

RegionId

string

No

ID wilayah.

cn-hangzhou.

Topics

array

No

Topik dari instans Apache RocketMQ.

string

No

Topik dari instans Apache RocketMQ.

myTopic.

InstanceEndpoint

string

No

Titik akhir dari instans Apache RocketMQ.

192.168.1.1:9876

InstanceUsername

string

No

Nama pengguna dari instans Apache RocketMQ.

admin.

InstancePassword

string

No

Kata sandi dari instans Apache RocketMQ.

****

NetworkType

string

No

Jenis jaringan. Nilai valid:

  • PublicNetwork

  • PrivateNetwork

PrivateNetwork.

VpcId

string

No

ID VPC.

vpc-adw1awdw*****

VSwitchId

string

No

ID vSwitch.

vsw-dwaafds****

SecurityGroupId

string

No

ID grup keamanan.

sg-mw43*****

SourceMQTTParameters

object

No

Sumber MQTT sumber.

RegionId

string

No

ID wilayah.

cn-shanghai.

InstanceId

string

No

ID instans.

i-bp1dsudbecqwt61j****

Topic

string

No

Nama topik.

topic_empower_1642400400779

BodyDataType

string

No

Format encoding Paket. Nilai valid:

  • JSON

  • Text

  • Binary

JSON.

NetworkType

string

No

Jenis jaringan.

VpcId

string

No

ID VPC.

VSwitchIds

string

No

ID vSwitch.

SecurityGroupId

string

No

ID grup keamanan.

SourceDTSParameters

object

No

Sumber DTS sumber.

TaskId

string

No

ID tugas.

f86e5814-b223-482c-b768-3b873297****

BrokerUrl

string

No

Alamat jaringan dan nomor port saluran langganan data.

Topic

string

No

Topik langganan dari saluran langganan data.

LTC_CACHE_PRD.

Sid

string

No

ID kelompok konsumen.

hkprdb.

Username

string

No

Akun dari kelompok konsumen.

admin.

Password

string

No

Kata sandi akun kelompok konsumen.

admin.

InitCheckPoint

integer

No

Offset konsumsi, yaitu Stempel waktu UNIX ketika klien SDK mengonsumsi Catatan data pertama.

1620962769

SourceSLSParameters

object

No

Sumber SLS sumber.

RoleName

string

No

Nama peran yang digunakan untuk otorisasi agar EventBridge dapat membaca konten log Simple Log Service. Saat membuat peran di konsol Resource Access Management (RAM), pilih "Alibaba Cloud Service" dan atur "Layanan tepercaya" ke "event bus".

testRole.

SourcePrometheusParameters

object

No

Sumber event Prometheus sumber.

RegionId

string

No

ID wilayah instans.

cn-hangzhou.

ClusterId

string

No

ID kluster.

c83555068b6******ad213f565f209

DataType

string

No

Tipe data.

Json.

Labels

string

No

Label.

__name__=.*

RoleName

string

No

Nama peran tugas.

test-role

ExternalLabels

string

No

Label eksternal yang ditambahkan ke aliran acara.

{"env":"test"}

SourceCustomizedKafkaParameters

object

No

Sumber event Kafka kustom.

InstanceId

string

No

ID instans dari instans ApsaraMQ for Kafka.

r-8vb64581862c****

SourceCustomizedKafkaConnectorParameters

object

No

Sumber event connector Apache Kafka kustom.

ConnectorPackageUrl

string

No

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

No

Parameter connector.

Name

string

No

Nama connector.

test-name

Config

object

No

Konfigurasi connector.

{ "connector.class": "com.mongodb.kafka.connect.MongoSinkConnector", "tasks.max": "1", "topics": "sourceA,sourceB" }

WorkerParameters

object

No

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

SourceApacheKafkaParameters

object

No

Bootstraps

string

No

SslKeystoreCertificateChain

string

No

[Wajib untuk otentikasi timbal balik] Rantai sertifikat klien Kafka. Parameter ini diperlukan saat server Kafka mengaktifkan otentikasi SSL timbal balik (ssl.client.auth=required). Format: format PEM yang diencode Base64 berisi sertifikat klien dan rantai sertifikat lengkap (sertifikat klien terlebih dahulu, sertifikat CA perantara berikutnya, sertifikat CA root opsional). Catatan: Pastikan setiap konten file PEM dimulai dengan '-----BEGIN CERTIFICATE-----' dan diakhiri dengan '-----END CERTIFICATE-----', lalu encode konten yang digabungkan dengan Base64.

SslKeyPassword

string

No

[Wajib untuk kunci privat terenkripsi] Kata sandi kunci privat klien Kafka. Parameter ini diperlukan saat kunci privat klien dilindungi kata sandi (file PEM berisi penanda 'Proc-Type: 4,ENCRYPTED' atau 'ENCRYPTED'). Biarkan kosong jika kunci privat tidak dienkripsi. Catatan: Kata sandi ini hanya digunakan untuk mendekripsi kunci privat dan tidak terkait dengan otentikasi Kafka.

SslTruststoreCertificates

string

No

[Wajib untuk SSL] Sertifikat tepercaya server Kafka. Digunakan untuk mengautentikasi validitas sertifikat SSL Kafka Broker dan mencegah serangan man-in-the-middle. Format: Encoding Base64 dari format PEM, biasanya berisi sertifikat CA atau sertifikat server dari server Kafka. Contoh: Encode konten file PEM sertifikat CA dengan Base64 (pastikan konten dimulai dengan '-----BEGIN CERTIFICATE-----' dan diakhiri dengan '-----END CERTIFICATE-----'). Jika Kafka menggunakan sertifikat self-signed, berikan sertifikat CA yang menerbitkan sertifikat tersebut.

SslKeystoreKey

object

No

[Wajib untuk otentikasi dua arah] Objek konfigurasi kunci privat SSL. Saat server Kafka mengaktifkan otentikasi SSL dua arah, Anda harus menyediakan kunci privat klien. Hanya pola KMS yang didukung untuk kunci: tentukan Sumber daya Key Management EPS yang menyimpan kunci privat menggunakan KmsArn. Sistem mengambil konten kunci privat dari KMS hanya di memori, yang memberikan keamanan lebih tinggi. Contoh konfigurasi: {"KmsArn": "acs:kms:ap-southeast-1:123456789:secret/ssl-key-xxxx", "KmsSecretValueKey": "keystore_private_key"}\n"

KmsArn

string

No

[Wajib] Nama Sumber Daya Alibaba Cloud resource KMS yang menyimpan kunci privat SSL. Digunakan untuk menemukan instans Key Management Service yang menyimpan kunci privat klien. Contoh format: 'acs:kms:cn-hangzhou:123456789:secret/ssl-keystore-key-xxxx'. Dapatkan nilai ini dari informasi ARN kunci yang sesuai di konsol KMS.

KmsSecretValueKey

string

No

[Mode KV KMS] Nama kunci dalam kredensial KMS. Ketika kredensial KMS disimpan sebagai struktur key-value (KV), tentukan parameter ini untuk menunjukkan kunci yang sesuai dengan kunci privat SSL. Contoh: jika kredensial KMS adalah '{"ssl_keystore_key":"-----BEGIN PRIVATE KEY-----...","ssl_truststore_key":"..."}', masukkan 'ssl_keystore_key'. Biarkan kosong jika kredensial KMS dalam mode teks biasa (langsung menyimpan konten PEM kunci privat).

Topic

string

No

ConsumerGroup

string

No

OffsetReset

string

No

ValueDataType

string

No

VpcId

string

No

VSwitchIds

string

No

SecurityGroupId

string

No

NetworkType

string

No

SecurityProtocol

string

No

SaslMechanism

string

No

SaslUser

string

No

SaslPassword

string

No

SourceOSSParameters

object

No

Sumber event OSS sumber.

RoleName

string

No

Nama peran yang digunakan untuk otorisasi agar EventBridge dapat membaca file OSS. Peran harus memiliki setidaknya izin baca-saja pada OSS.

eventbridge_oss_role

BucketName

string

No

Nama bucket di Object Storage Service (OSS).

bucket_abc.

Prefix

string

No

Awalan jalur file.

fun/document/

LoadMode

string

No

Mode pemuatan data. Nilai valid: single (pemuatan dokumen tunggal) dan element (pemuatan terpotong). Nilai default: single.

single.

LoadFormat

string

No

Pemuat dokumen.

TextLoader.

Delimiter

string

No

Delimiter. Dalam mode pemuatan terpotong, delimiter ini digunakan sebagai pengidentifikasi pemotongan teks. Delimiter default adalah karakter baris baru \n.

\n

SourceEventBusParameters

object

No

Sumber EventBus sumber.

EventBusName

string

No

Nama EventBridge.

my-event-bus.

EventRuleName

string

No

Nama aturan event.

my-event-rule.

SourceOpenSourceRabbitMQParameters

object

No

Sumber Open Source RabbitMQ sumber.

Endpoint

string

No

Titik akhir instans.

192.168.1.1:9876

VirtualHostName

string

No

Nama host virtual dari instans RabbitMQ open source.

Vhost1

QueueName

string

No

Nama antrian dari instans RabbitMQ open source.

demo.

BodyDataType

string

No

Tipe data body Paket.

Json.

Username

string

No

Nama pengguna yang digunakan untuk terhubung ke instans RabbitMQ open source.

admin.

Password

string

No

Kata sandi yang digunakan untuk terhubung ke instans RabbitMQ open source.

****

VpcId

string

No

ID VPC.

vpc-m5e3sv4b12345****

VSwitchIds

string

No

ID vSwitch.

vsw-m5ev8asdc6h12345****

SecurityGroupId

string

No

ID grup keamanan.

sg-m5edtu24f12345****

NetworkType

string

No

Jenis jaringan. Nilai valid:

  • PublicNetwork

  • PrivateNetwork

PrivateNetwork.

AuthType

string

No

Tipe otentikasi.

ACL.

SourceMySQLParameters SourceMySQLParameters

No

Sumber MySQL sumber.

SourcePostgreSQLParameters SourcePostgreSQLParameters

No

SourceRabbitMQMetaParameters SourceRabbitMQMetaParameters

No

SourceRabbitMQMsgSyncParameters SourceRabbitMQMsgSyncParameters

No

SourceFeiShuDocsParameters SourceFeiShuDocsParameters

No

SourceJDBCParameters SourceJDBCParameters

No

Metadata

string

No

Sink

object

No

Target event. Anda harus memilih satu dan hanya satu tipe Sink.

SinkMNSParameters

object

No

Target event Antrian Pesan (sebelumnya MNS).

QueueName

object

No

Tipe layanan target adalah Antrian Pesan (sebelumnya MNS).

Value

string

No

Nama antrian di Antrian Pesan (sebelumnya MNS).

MyQueue

Form

string

No

Format transformasi. Nilai default: CONSTANT.

CONSTANT

Template

string

No

Tidak ada.

Body

object

No

Konten Paket.

Value

string

No

Nilai sebelum transformasi.

{ "key": "value" }

Form

string

No

Format transformasi.

TEMPLATE

Template

string

No

Gaya templat.

The value of ${key} is ${value}!

IsBase64Encode

object

No

Apakah akan mengaktifkan encoding Base64.

Value

string

No

Apakah akan mengaktifkan encoding Base64.

true

Form

string

No

Format transformasi event. Nilai default: CONSTANT.

CONSTANT

Template

string

No

Tidak ada.

SinkEventHouseParameters

object

No

Nama target event.

CatalogName

string

No

Nama katalog.

demo.

NamespaceName

string

No

Namespace tabel target.

name1

EventTableName

string

No

Nama tabel target.

demo-table.

MappingRules

array<object>

No

Aturan pemetaan bidang.

array<object>

No

Aturan pemetaan bidang.

ColumnValue

object

No

Aturan ekstraksi nilai kolom.

Value

string

No

Jalur ekstraksi, seperti $.data.value.name.

$.data.value

Form

string

No

Metode transformasi, seperti JSONPATH.

JSONPATH

Template

string

No

Konfigurasi templat.

The value of ${key} is ${value}!

ColumnName

string

No

Nama kolom.

age

ColumnType

string

No

Tipe kolom.

text

SinkFcParameters

object

No

Target fungsi.

ServiceName

object

No

Nama layanan.

Value

string

No

Nama layanan.

myService

Form

string

No

Format transformasi. Nilai default: CONSTANT.

CONSTANT

Template

string

No

Tidak ada.

FunctionName

object

No

Nama fungsi.

Value

string

No

Nama fungsi.

mFunction

Form

string

No

Format transformasi. Nilai default: CONSTANT.

CONSTANT

Template

string

No

Tidak ada.

Concurrency

object

No

Konkurensi pengiriman. Nilai minimum: 1.

Value

string

No

Konkurensi pengiriman. Nilai minimum: 1.

1

Form

string

No

Format transformasi. Nilai default: CONSTANT.

CONSTANT

Template

string

No

Tidak ada.

Qualifier

object

No

Alias layanan tempat fungsi berada.

Value

string

No

Alias layanan tempat fungsi berada.

LATEST

Form

string

No

Format transformasi. Nilai default: CONSTANT.

CONSTANT

Template

string

No

Tidak ada.

InvocationType

object

No

Tipe pemanggilan. Nilai valid:

  • Sync: sinkron.

  • Async: asinkron.

Value

string

No

Tipe pemanggilan.

Async

Form

string

No

Format transformasi. Nilai default: CONSTANT.

CONSTANT

Template

string

No

Tidak ada.

Body

object

No

Body konten yang dikirim ke fungsi.

Value

string

No

Nilai sebelum transformasi.

{ "key": "value" }

Form

string

No

Format transformasi.

TEMPLATE

Template

string

No

Gaya templat.

The value of ${key} is ${value}!

DataFormat

object

No

Aturan konversi format untuk konten event.

Value

string

No

Nilai sebelum transformasi.

{ "key": "value" }

Form

string

No

Format transformasi. Nilai valid:

  • ORIGINAL: event lengkap

  • JSONPATH: event parsial

  • CONSTANT: konstanta

  • TEMPLATE: templat

JSONPATH

Template

string

No

Gaya templat.

$.data.key

SinkRabbitMQParameters

object

No

Parameter Sink RabbitMQ.

InstanceId

object

No

Tipe layanan target adalah ApsaraMQ for RabbitMQ.

Value

string

No

ID instans MSMQ for RabbitMQ.

amqp-cn-2r42e73o****

Form

string

No

Format transformasi. Nilai default: CONSTANT.

CONSTANT

Template

string

No

Tidak ada.

VirtualHostName

object

No

Nama vhost dari instans ApsaraMQ for RabbitMQ.

Value

string

No

Nama vhost dari instans MSMQ for RabbitMQ.

rabbit-host

Form

string

No

Format transformasi. Nilai default: CONSTANT.

CONSTANT

Template

string

No

Tidak ada.

TargetType

object

No

Tipe target.

Value

string

No

Tipe target. Nilai valid:

  • Exchange: Mode Exchange.

  • Queue: Mode Queue.

Exchange/Queue

Form

string

No

Format transformasi. Nilai default: CONSTANT.

CONSTANT

Template

string

No

Tidak ada.

Exchange

object

No

Mode Exchange. Parameter ini hanya diperlukan jika TargetType diatur ke Exchange.

Value

string

No

Nama exchange dari instans MSMQ for RabbitMQ.

a_exchange

Form

string

No

Format transformasi. Nilai default: CONSTANT.

CONSTANT

Template

string

No

Tidak ada.

RoutingKey

object

No

Aturan routing Paket. Parameter ini hanya diperlukan jika TargetType diatur ke Exchange.

Value

string

No

Aturan routing Paket.

housekeeping

Form

string

No

Format transformasi. Nilai default: CONSTANT.

CONSTANT

Template

string

No

Tidak ada.

QueueName

object

No

Mode Queue. Parameter ini hanya diperlukan jika TargetType diatur ke Queue.

Value

string

No

Nama antrian dari instans.

MyQueue

Form

string

No

Format transformasi. Nilai default: CONSTANT.

CONSTANT

Template

string

No

Tidak ada.

Body

object

No

Konten Paket.

Value

string

No

Nilai sebelum transformasi.

{ "key": "value" }

Form

string

No

Format transformasi.

TEMPLATE

Template

string

No

Gaya templat.

The value of ${key} is ${value}!

MessageId

object

No

ID Paket.

Value

string

No

Nilai sebelum transformasi.

{ "key": "value" }

Form

string

No

Format transformasi.

TEMPLATE

Template

string

No

Gaya templat.

The value of ${key} is ${value}!

Properties

object

No

Properti filter.

Value

string

No

Nilai sebelum transformasi.

{ "key": "value" }

Form

string

No

Format transformasi.

TEMPLATE

Template

string

No

Gaya templat.

The value of ${key} is ${value}!

SinkKafkaParameters

object

No

Parameter Sink Kafka.

InstanceId

object

No

Tipe layanan target adalah ApsaraMQ for Kafka.

Value

string

No

ID instans.

Defaut_1283278472_s****

Form

string

No

Format transformasi. Nilai default: CONSTANT.

CONSTANT

Template

string

No

Tidak ada.

CompressionType

string

No

Topic

object

No

Nama topik.

Value

string

No

Nama topik.

test

Form

string

No

Format transformasi. Nilai default: CONSTANT.

CONSTANT

Template

string

No

Tidak ada.

DynamicTopic

object

No

Menentukan strategi routing Topik target untuk Paket. Jika parameter Topic dan parameter DynamicTopic keduanya ditentukan, parameter DynamicTopic akan diutamakan. Dua mode konfigurasi didukung: 1. Mode konstanta statis: Tentukan string nama Topik tetap (misalnya, "order_created"). Semua Paket dikirim ke Topik ini. 2. Mode ekstraksi dinamis: Tentukan ekspresi JSONPath standar (misalnya, "$.user.id" atau "$.metadata.category"). Sistem mengurai body Paket upstream dan mengekstrak nilai bidang yang cocok sebagai nama Topik target.

Value

string

No

Nilai.

Form

string

No

Tipe transformasi. Nilai valid:

  • CONSTANT: nilai konstan.

  • JSONPATH: ekstrak dari upstream berdasarkan jalur.

Template

string

No

Templat.

Headers

object

No

Metadata tambahan Paket Kafka.

Value

string

No

Nilai sebelum transformasi.

{ "key": "value" }

Form

string

No

Format transformasi. Nilai valid:

  • ORIGINAL: event lengkap

  • JSONPATH: event parsial

  • CONSTANT: konstanta

  • TEMPLATE: templat

CONSTANT

Template

string

No

Gaya templat.

The value of ${key} is ${value}!

Acks

object

No

Mode acknowledgment tulis Kafka. Nilai valid:

  • acks=0: Tidak diperlukan tanggapan dari server. Performa tinggi, tetapi risiko loss data tinggi.

  • acks=1: Tanggapan dikembalikan setelah node utama berhasil menulis. Performa sedang, dan risiko loss data sedang. Loss data dapat terjadi jika node utama mati.

  • acks=all: Tanggapan dikembalikan setelah node utama berhasil menulis dan node sekunder berhasil menyinkronkan. Performa rendah, tetapi data lebih aman. Loss data hanya terjadi jika node utama dan sekunder mati.

Value

string

No

Mode acknowledgment untuk penulisan ke Kafka:

  • acks=0: Tidak diperlukan tanggapan dari server. Kinerja tinggi, tetapi risiko loss data tinggi.

  • acks=1: Tanggapan dikembalikan setelah node utama berhasil menulis. Kinerja sedang, dan risiko loss data sedang. Loss data dapat terjadi jika node utama mati.

  • acks=all: Tanggapan dikembalikan hanya setelah node utama berhasil menulis dan node sekunder menyelesaikan sinkronisasi. Kinerja rendah, tetapi data lebih aman. Loss data hanya terjadi jika node utama dan sekunder mati.

1

Form

string

No

Format transformasi. Nilai default: CONSTANT.

CONSTANT

Template

string

No

Tidak ada.

Key

object

No

Pengidentifikasi Paket.

Value

string

No

Pengenal Paket.

key

Form

string

No

Format transformasi. Nilai default: CONSTANT.

CONSTANT

Template

string

No

Tidak ada.

Value

object

No

K

Value

string

No

The value before transformation.

{ "key": "value" }

Form

string

No

Format transformasi.

TEMPLATE

Template

string

No

Gaya templat.

The value of ${key} is ${value}!

SinkApacheKafkaParameters

object

No

Deskripsi.

Bootstraps

string

No

Topic

string

No

DynamicTopic

object

No

Specifies the target Topic routing strategy for messages. If both the Topic parameter and the DynamicTopic parameter are specified, the DynamicTopic parameter takes precedence. Two configuration modes are supported: 1. Static constant mode: Specify a fixed Topic name string (for example, "order_created"). All messages are sent to this Topic. 2. Dynamic extraction mode: Specify a standard JSONPath expression (for example, "$.user.id" or "$.metadata.category"). The system parses the upstream message body and extracts the matching field value as the target Topic name.

Value

string

No

Nilai.

Form

string

No

The transformation type. Valid values:

  • CONSTANT: constant value.

  • JSONPATH: extract from upstream based on path.

Template

string

No

Templat.

Acks

string

No

Key

object

No

Value

string

No

Form

string

No

Template

string

No

Value

object

No

Value

string

No

Form

string

No

Template

string

No

CompressionType

string

No

SecurityProtocol

string

No

SaslMechanism

string

No

SaslUser

string

No

VpcId

object

No

Value

string

No

Form

string

No

Template

string

No

VSwitchIds

object

No

Value

string

No

Form

string

No

Template

string

No

SecurityGroupId

object

No

Value

string

No

Form

string

No

Template

string

No

NetworkType

object

No

Value

string

No

Form

string

No

Template

string

No

Headers

object

No

Value

string

No

Form

string

No

Template

string

No

SaslPassword

string

No

SslKeystoreCertificateChain

string

No

[Wajib untuk otentikasi timbal balik] Rantai sertifikat klien Kafka. Parameter ini diperlukan saat server Kafka mengaktifkan otentikasi SSL timbal balik (ssl.client.auth=required). Format: format PEM yang diencode Base64 berisi sertifikat klien dan rantai sertifikat lengkap (sertifikat klien terlebih dahulu, sertifikat CA perantara berikutnya, sertifikat CA root opsional). Catatan: Pastikan setiap konten file PEM dimulai dengan '-----BEGIN CERTIFICATE-----' dan diakhiri dengan '-----END CERTIFICATE-----', lalu encode konten yang digabungkan dengan Base64.

SslKeyPassword

string

No

[Wajib untuk kunci privat terenkripsi] Kata sandi kunci privat klien Kafka. Parameter ini diperlukan saat kunci privat klien dilindungi kata sandi (file PEM berisi penanda 'Proc-Type: 4,ENCRYPTED' atau 'ENCRYPTED'). Biarkan kosong jika kunci privat tidak dienkripsi. Catatan: Kata sandi ini hanya digunakan untuk mendekripsi kunci privat dan tidak terkait dengan otentikasi Kafka.

SslTruststoreCertificates

string

No

[Required for SSL] The Kafka server trust certificate. Used to authenticate the SSL certificate of the Kafka Broker to prevent man-in-the-middle attacks. Format: Base64 encoding of PEM format, typically containing the CA certificate or the server certificate of the Kafka server. Example: Base64-encode the PEM file content of the CA certificate (ensure it starts with '-----BEGIN CERTIFICATE-----' and ends with '-----END CERTIFICATE-----'). If Kafka uses a self-signed certificate, provide the CA certificate that issued the certificate.

SslKeystoreKey

object

No

[Required for mutual authentication] The SSL private key configuration object. This parameter is required when the Kafka server enables mutual SSL authentication. Only KMS mode is supported: specify the Key Management Service resource that stores the private key through KmsArn. The system retrieves the private key content from KMS only in memory for higher security. Configuration example: {"KmsArn": "acs:kms:cn-hangzhou:123456789:secret/ssl-key-xxxx", "KmsSecretValueKey": "keystore_private_key"}

KmsArn

string

No

[Required] The KMS resource ARN that stores the SSL private key. Used to locate the Key Management Service instance that stores the client private key. Format example: 'acs:kms:cn-hangzhou:123456789:secret/ssl-keystore-key-xxxx'. Obtain this value from the ARN information of the corresponding key in the KMS console.

KmsSecretValueKey

string

No

[Mode KV KMS] Nama kunci dalam kredensial KMS. Ketika kredensial KMS disimpan sebagai struktur key-value (KV), tentukan parameter ini untuk menunjukkan kunci yang sesuai dengan kunci privat SSL. Contoh: jika kredensial KMS adalah '{"ssl_keystore_key":"-----BEGIN PRIVATE KEY-----...","ssl_truststore_key":"..."}', masukkan 'ssl_keystore_key'. Biarkan kosong jika kredensial KMS dalam mode teks biasa (langsung menyimpan konten PEM kunci privat).

SinkRocketMQParameters

object

No

Parameter Sink RocketMQ.

InstanceId

object

No

Tipe layanan target adalah ApsaraMQ for RocketMQ.

Value

string

No

ID instans MSMQ for RocketMQ.

MQ_INST_164901546557****_BAAN****

Form

string

No

Format transformasi. Nilai default: CONSTANT.

CONSTANT

Template

string

No

Tidak ada.

Topic

object

No

Topik dari instans ApsaraMQ for RocketMQ.

Value

string

No

Topik dari instans MSMQ for RocketMQ.

Mytopic

Form

string

No

Format transformasi. Nilai default: CONSTANT.

CONSTANT

Template

string

No

Tidak ada.

Body

object

No

The message content.

Value

string

No

The value before transformation.

{ "key": "value" }

Form

string

No

Format transformasi.

TEMPLATE

Template

string

No

Gaya templat.

The value of ${key} is ${value}!

Properties

object

No

Properti filter.

Value

string

No

The value before transformation.

{ "key": "value" }

Form

string

No

Format transformasi.

TEMPLATE

Template

string

No

Gaya templat.

The value of ${key} is ${value}!

Keys

object

No

Properti filter.

Value

string

No

The value before transformation.

{ "key": "value" }

Form

string

No

Format transformasi.

TEMPLATE

Template

string

No

Gaya templat.

The value of ${key} is ${value}!

Tags

object

No

Properti filter.

Value

string

No

The value before transformation.

{ "key": "value" }

Form

string

No

Format transformasi.

TEMPLATE

Template

string

No

Gaya templat.

The value of ${key} is ${value}!

InstanceType

object

No

Tipe instans.

Value

string

No

Tipe instans. Nilai valid:

  • Cloud_4: Instans Alibaba Cloud RocketMQ 4.0 (default)

  • Cloud_5: Instans Alibaba Cloud RocketMQ 5.0

  • SelfBuilt: Kluster Apache RocketMQ yang dikelola sendiri

Cloud_4

Form

string

No

Format transformasi. Nilai default: CONSTANT.

CONSTANT

Template

string

No

Tidak ada.

InstanceEndpoint

object

No

Titik akhir instans.

Value

string

No

Titik akhir instans.

vbr-8vbsvkkbpf3vb0zef****

Form

string

No

Format transformasi. Nilai default: CONSTANT.

CONSTANT

Template

string

No

Tidak ada.

InstanceUsername

object

No

Nama pengguna instans.

Value

string

No

Nama pengguna instans.

admin

Form

string

No

Format transformasi. Nilai default: CONSTANT.

CONSTANT

Template

string

No

Tidak ada.

InstancePassword

object

No

Kata sandi instans.

Value

string

No

Kata sandi instans.

admin****

Form

string

No

Format transformasi. Nilai default: CONSTANT.

CONSTANT

Template

string

No

Tidak ada.

VpcId

object

No

ID VPC.

Value

string

No

ID VPC.

vbr-8vb835n3zf9shwlvb****

Form

string

No

Format transformasi event. Nilai default: CONSTANT.

CONSTANT

Template

string

No

Tidak ada.

VSwitchIds

object

No

ID vSwitch.

Value

string

No

ID vSwitch.

vbr-8vb835n3zf9shwl****mp

Form

string

No

Format transformasi. Nilai default: CONSTANT.

CONSTANT

Template

string

No

Tidak ada.

SecurityGroupId

object

No

The security group ID.

Value

string

No

The security group ID.

b4bf375515f6440f942e3a20c33d****

Form

string

No

Format transformasi. Nilai default: CONSTANT.

CONSTANT

Template

string

No

Tidak ada.

Network

object

No

Jenis jaringan. Nilai valid:

  • PublicNetwork

  • PrivateNetwork

Value

string

No

Jenis jaringan. Nilai valid:

  • PublicNetwork

  • PrivateNetwork

PublicNetwork

Form

string

No

Format transformasi. Nilai default: CONSTANT.

CONSTANT

Template

string

No

Tidak ada.

DeliveryOrderType

object

No

The delivery order type of the message. This parameter is optional. Default value: concurrent delivery.

Value

string

No

The delivery order type. Valid values:

  • Orderly: ordered delivery.

  • Concurrently: concurrent delivery.

Concurrently

Form

string

No

Format transformasi. Nilai default: CONSTANT.

CONSTANT

Template

string

No

Gaya templat.

ShardingKey

object

No

The sharding key of the message.

Catatan

When DeliveryOrderType is set to Orderly, this parameter specifies the event content transformation rule for the ShardingKey property when writing messages downstream. When Source is RocketMQ, ShardingKey can be empty. In this case, the upstream BrokerName and QueueId are concatenated to generate the message ShardingKey.

Value

string

No

Nilai kunci sharding.

order_id

Form

string

No

Format transformasi. Nilai default: CONSTANT.

CONSTANT

Template

string

No

Gaya templat.

SinkDorisParameters

object

No

Tipe sumber event.

QueryEndpoint

object

No

Value

string

No

Form

string

No

Template

string

No

FeHttpEndpoint

object

No

Value

string

No

Form

string

No

Template

string

No

BeHttpEndpoint

object

No

Value

string

No

Form

string

No

Template

string

No

UserName

object

No

Value

string

No

Form

string

No

Template

string

No

Password

object

No

Value

string

No

Form

string

No

Template

string

No

Database

object

No

Value

string

No

Form

string

No

Template

string

No

Body

object

No

Value

string

No

Form

string

No

Template

string

No

Table

object

No

Value

string

No

Form

string

No

Template

string

No

NetworkType

object

No

Value

string

No

Form

string

No

Template

string

No

VpcId

object

No

Value

string

No

Form

string

No

Template

string

No

VSwitchIds

object

No

Value

string

No

Form

string

No

Template

string

No

SecurityGroupId

object

No

Value

string

No

Form

string

No

Template

string

No

SinkRocketMQCheckpointParameters

object

No

Parameter Sink RocketMQ Checkpoint.

InstanceType

string

No

Tipe instans. Nilai valid:

  • Cloud_4: Instans Alibaba Cloud RocketMQ 4.0

  • Cloud_5: Instans Alibaba Cloud RocketMQ 5.0

Cloud_4

InstanceId

string

No

ID instans.

MQ_INST_164901546557****_BAAN****

Topic

object

No

Topik dari instans ApsaraMQ for RocketMQ.

Value

string

No

Nama topik dari instans MSMQ for RocketMQ.

Mytopic

Form

string

No

Format transformasi. Nilai default: CONSTANT.

CONSTANT

Template

string

No

Gaya templat.

ConsumeTimestamp

object

No

The timestamp of message consumption.

Value

string

No

The timestamp.

1570761026400

Form

string

No

Format transformasi. Nilai default: CONSTANT.

CONSTANT

Template

string

No

Gaya templat.

Group

object

No

ID kelompok dari kelompok konsumen.

Value

string

No

ID Kelompok.

GID_EVENTBRIDGE_1736234******

Form

string

No

Format transformasi. Nilai default: CONSTANT.

CONSTANT

Template

string

No

Gaya templat.

SinkApacheRocketMQCheckpointParameters

object

No

Parameter Sink Apache RocketMQ Checkpoint.

Topic

object

No

Topik dari instans RocketMQ.

Value

string

No

Nama topik dari instans RocketMQ.

Mytopic

Form

string

No

Format transformasi. Nilai default: CONSTANT.

CONSTANT

Template

string

No

Gaya templat.

ConsumeTimestamp

object

No

The timestamp of message consumption.

Value

string

No

The timestamp.

1570761026400

Form

string

No

Format transformasi. Nilai default: CONSTANT.

CONSTANT

Template

string

No

Gaya templat.

Group

object

No

ID kelompok dari kelompok konsumen.

Value

string

No

ID Kelompok.

GID_EVENTBRIDGE_1736234******

Form

string

No

Format transformasi. Nilai default: CONSTANT.

CONSTANT

Template

string

No

Gaya templat.

InstanceEndpoint

string

No

Titik akhir instans.

192.168.1.1:9876

InstanceUsername

string

No

Nama pengguna yang diperlukan untuk otentikasi.

admin.

InstancePassword

string

No

Kata sandi nama pengguna.

****

NetworkType

string

No

Jenis jaringan. Nilai valid:

  • PublicNetwork

  • PrivateNetwork

PrivateNetwork.

VpcId

string

No

ID VPC.

vpc-2zeccak5pb0j3ay******

VSwitchId

string

No

ID vSwitch.

vsw-uf62oqt1twuevrt******

SecurityGroupId

string

No

The security group ID.

sg-2ze5bmpw6adn0q******

SinkSLSParameters

object

No

Parameter Sink SLS.

Project

object

No

Proyek log Simple Log Service (SLS).

Value

string

No

Proyek Simple Log Service.

test-project

Form

string

No

Format transformasi. Nilai default: CONSTANT.

CONSTANT

Template

string

No

Tidak ada.

LogStore

object

No

The Logstore of Simple Log Service (SLS).

Value

string

No

The Logstore of Simple Log Service.

test-logstore

Form

string

No

Format transformasi. Nilai default: CONSTANT.

CONSTANT

Template

string

No

Tidak ada.

Topic

object

No

Topik tempat log berada, sesuai dengan bidang cadangan SLS "topic".

Value

string

No

Topik tempat log berada, sesuai dengan bidang cadangan SLS "topic".

testTopic

Form

string

No

Format transformasi. Nilai default: CONSTANT.

CONSTANT

Template

string

No

Tidak ada.

Body

object

No

Konten yang dikirim ke SLS.

Value

string

No

The value before transformation.

{ "key": "value" }

Form

string

No

Format transformasi.

TEMPLATE

Template

string

No

Gaya templat.

The value of ${key} is ${value}!

RoleName

object

No

Nama peran yang digunakan untuk mengotorisasi EventBridge agar dapat membaca konten log SLS. Saat membuat peran di konsol Resource Access Management (RAM), pilih "Alibaba Cloud Service" dan atur "Layanan tepercaya" ke "EventBridge".

Value

string

No

Peran yang memberikan otorisasi bagi EventBridge untuk membaca konten log SLS. Saat membuat peran di konsol Resource Access Management (RAM), pilih "Alibaba Cloud Service" dan setel "Trusted Service" ke "event bus".

testRole

Form

string

No

Format transformasi. Nilai default: CONSTANT.

CONSTANT

Template

string

No

Tidak ada.

ContentType

object

No

Format data SLS. Anda dapat memilih format default atau mengonfigurasi pasangan key-value tertentu. Nilai valid:

  • JSON

  • KeyValue

Value

string

No

Format data SLS.

JSON

Form

string

No

Format transformasi.

CONSTANT

Template

string

No

Gaya templat.

ContentSchema

object

No

Pasangan key-value log kustom. Parameter ini hanya berlaku jika ContentType diatur ke KeyValue. Setiap pasangan key-value direpresentasikan oleh Key_n dan Value_n.

Value

string

No

Pasangan key-value kustom.

{"Key_1":{"form":"CONSTANT","value":"demoKey"},"Value_1":{"form":"JSONPATH","value":"$.data.value"}}

Form

string

No

Format transformasi.

CONSTANT

Template

string

No

Gaya templat.

SinkFnfParameters

object

No

Parameter Sink Fnf.

FlowName

object

No

Nama alur.

Value

string

No

Nama alur.

test-streaming-fnf

Form

string

No

Format transformasi. Nilai default: CONSTANT.

CONSTANT

Template

string

No

Gaya templat.

ExecutionName

object

No

Nama eksekusi.

Value

string

No

Nama eksekusi.

123

Form

string

No

Format transformasi. Nilai default: CONSTANT.

CONSTANT

Template

string

No

Gaya templat.

Input

object

No

The execution input information.

Value

string

No

The execution input information.

123

Form

string

No

Format transformasi. Nilai default: CONSTANT.

CONSTANT

Template

string

No

Gaya templat.

RoleName

object

No

Konfigurasi peran.

Value

string

No

Konfigurasi peran.

Al****FNF-x****

Form

string

No

Format transformasi. Nilai default: CONSTANT.

CONSTANT

Template

string

No

Gaya templat.

SinkPrometheusParameters

object

No

Parameter Sink Prometheus.

URL

object

No

URL Remote Write Prometheus.

Value

string

No

URL Remote Write Prometheus.

https://cn-hangzhou.arms.aliyuncs.com/prometheus/167275****/c5b7faeb2e8994641*****d5c559f/cn-hangzhou/api/v3/write

Form

string

No

Format transformasi. Nilai default: CONSTANT.

CONSTANT

Template

string

No

Tidak ada.

HeaderParameters

object

No

Struktur data parameter header permintaan.

Value

string

No

  • Jika Form adalah CONSTANT: nilai konstan.

  • Jika Form adalah JSONPATH: konten diekstrak menggunakan JSONPath.

  • Jika Form adalah TEMPLATE: variabel templat.

Catatan: Bidang Value tidak boleh melebihi 10.240 karakter.

name

Form

string

No

Format transformasi. Nilai valid:

  • JSONPATH: JSONPATH.

  • CONSTANT: CONSTANT.

  • TEMPLATE: TEMPLATE.

TEMPLATE

Template

string

No

The HTTP request header template. Specify this parameter when Form is set to TEMPLATE. The transformed event content must be in JSON format.

{ "user_name":"${name}" }

AuthorizationType

object

No

Tipe otorisasi.

Value

string

No

Tipe otentikasi.

BASIC_AUTH

Form

string

No

Format transformasi. Nilai default: CONSTANT.

CONSTANT

Template

string

No

Tidak ada.

Username

object

No

Nama pengguna.

Value

string

No

The username.

***admin

Form

string

No

Format transformasi. Nilai default: CONSTANT.

CONSTANT

Template

string

No

Tidak ada.

Password

object

No

Kata sandi.

Value

string

No

The password.

abc

Form

string

No

Format transformasi. Nilai default: CONSTANT.

CONSTANT

Template

string

No

Tidak ada.

Data

object

No

The metric content.

Value

string

No

The metric content.

$.data

Form

string

No

The transformation format. Default value: JSONPATH.

JSONPATH

Template

string

No

Tidak ada.

NetworkType

object

No

Jenis jaringan.

Value

string

No

Jenis jaringan. Nilai valid:

  • PublicNetwork

  • PrivateNetwork

PrivateNetwork

Form

string

No

Format transformasi. Nilai default: CONSTANT.

CONSTANT

Template

string

No

Tidak ada.

VpcId

object

No

ID VPC.

Value

string

No

ID VPC.

vpc-adw1awdw*****

Form

string

No

Format transformasi. Nilai default: CONSTANT.

CONSTANT

Template

string

No

Tidak ada.

VSwitchId

object

No

ID vSwitch.

Value

string

No

ID vSwitch.

vsw-dwaafds****

Form

string

No

Format transformasi. Nilai default: CONSTANT.

CONSTANT

Template

string

No

Tidak ada.

SecurityGroupId

object

No

The security group ID.

Value

string

No

The security group ID.

sg-mw43*****

Form

string

No

Format transformasi. Nilai default: CONSTANT.

CONSTANT

Template

string

No

Tidak ada.

SinkDataHubParameters

object

No

The Sink DataHub parameters.

Project

object

No

The DataHub project name.

Value

string

No

The DataHub project name.

demo-project

Form

string

No

Format transformasi. Nilai default: CONSTANT.

CONSTANT

Template

string

No

Tidak ada.

Topic

object

No

The DataHub topic name.

Value

string

No

The DataHub topic name.

demo-topic

Form

string

No

Format transformasi. Nilai default: CONSTANT.

CONSTANT

Template

string

No

Tidak ada.

TopicType

object

No

Tipe topik. Nilai valid:

  • TUPLE

  • BLOB

Value

string

No

The topic type. Valid values:

  • TUPLE

  • BLOB

TUPLE

Form

string

No

Format transformasi. Nilai default: CONSTANT.

CONSTANT

Template

string

No

Tidak ada.

TopicSchema

object

No

Skema konten topik tipe TUPLE. [_single.params.Sink.props.SinkDataHubParameters

Value

string

No

The topic content schema for the TUPLE type.

{"k1":"value1","k2":"value2"}

Form

string

No

Format transformasi.

TEMPLATE

Template

string

No

Gaya templat.

{"k1":"${k1}","k2":"${k2}"}

Body

object

No

The BLOB type Record content template.

Value

string

No

The record content template for the BLOB type.

Form

string

No

Format transformasi.

ORIGINAL

Template

string

No

Tidak ada.

RoleName

object

No

Nama peran tugas.

Value

string

No

Nama peran tugas.

test-role

Form

string

No

Format transformasi. Nilai default: CONSTANT.

CONSTANT

Template

string

No

Tidak ada.

ContentType

object

No

The data format. You can select the default format or configure specified key-value pairs. Valid values:

  • JSON

  • KeyValue

Value

string

No

The value before transformation.

JSON

Form

string

No

Format transformasi.

CONSTANT

Template

string

No

Gaya templat.

ContentSchema

object

No

Pasangan key-value log kustom. Parameter ini hanya berlaku jika ContentType diatur ke KeyValue. Setiap pasangan key-value direpresentasikan oleh Key_n dan Value_n.

Value

string

No

The value before transformation.

{"Key_1":{"form":"CONSTANT","value":"demoKey"},"Value_1":{"form":"JSONPATH","value":"$.data.value"}}

Form

string

No

Gaya templat.

CONSTANT

Template

string

No

Gaya templat.

SinkCustomizedKafkaParameters

object

No

Parameter Sink Kafka.

InstanceId

string

No

ID instans dari instans ApsaraMQ for Kafka.

90be1f96-4229-4535-bb76-34b4f6fb2b71

SinkCustomizedKafkaConnectorParameters

object

No

The Sink Kafka connector parameters.

ConnectorPackageUrl

string

No

The OSS file download URL.

"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

No

Parses the properties file in the current ZIP package.

Name

string

No

Nama connector.

mongo-sink

Config

object

No

Konfigurasi connector.

{ "connector.class": "com.mongodb.kafka.connect.MongoSinkConnector", "tasks.max": "1", "topics": "sourceA,sourceB" }

WorkerParameters

object

No

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

No

The Sink DashVector parameters.

InstanceId

string

No

ID instans.

vrs-cn-lbj3ru1***

Collection

string

No

The collection name.

collection1

ApiKey

string

No

The API key created in the DashVector console.

Q34nExQH7sQ****

Operation

string

No

The DashVector database operation type. Valid values:

  • Delete

  • Upsert

Upsert

Network

string

No

The network type. Valid values:

  • PrivateNetwork

  • PublicNetwork

PublicNetwork.

PrimaryKeyId

object

No

The primary key ID when inserting or deleting records. If this field is not specified, a random primary key ID is used.

Form

string

No

The transformation format. Valid values:

  • JSONPATH

  • TEMPLATE

JSONPATH

Value

string

No

  • If Form is JSONPATH: content extracted using JSONPath.

  • If Form is TEMPLATE: a template variable.

Catatan

The Value field cannot exceed 10,240 characters.

$.data.requestId

Template

string

No

The primary key ID template. Specify this parameter only when Form is set to TEMPLATE.

${ID}

Partition

object

No

The partition. Default value: default.

Form

string

No

The transformation format. Valid values:

  • JSONPATH

  • CONSTANT

CONSTANT

Value

string

No

  • If Form is CONSTANT: a constant value.

  • If Form is JSONPATH: content extracted using JSONPath.

Catatan

The Value field cannot exceed 10,240 characters.

default

Template

string

No

Tidak ada.

Vector

object

No

The vector of the record inserted into DashVector.

Form

string

No

Format transformasi.

JSONPATH

Value

string

No

The content extracted using JSONPath.

Catatan

The Value field cannot exceed 10,240 characters.

$.data.messageBody

Template

string

No

Tidak ada.

DashVectorSchemaParameters

array<object>

No

The Schema field definition of the table entry when inserting into DashVector. The event content transformation result must be in JSON format.

array<object>

No

Name

object

No

Form

string

No

Value

string

No

Template

string

No

Type

object

No

Form

string

No

Value

string

No

Template

string

No

Value

object

No

Form

string

No

Value

string

No

Template

string

No

SinkOpenSourceRabbitMQParameters

object

No

Sink Open Source RabbitMQ Parameters

Endpoint

string

No

The endpoint.

192.168.1.1:9876

VirtualHostName

string

No

The virtual host name of the RabbitMQ instance.

Vhost1

TargetType

string

No

The target type for message delivery. Valid values:

  • Exchange: Messages are routed through an exchange.

  • Queue: Messages are delivered directly to the specified queue.

Exchange

Exchange

string

No

The Exchange name in RabbitMQ. This parameter takes effect when TargetType is set to Exchange.

my-exchange

QueueName

string

No

The queue name in RabbitMQ. This parameter takes effect only when TargetType is set to Queue.

my-queue

Username

string

No

The username used to access the RabbitMQ instance.

admin.

Password

string

No

The password used to access the RabbitMQ instance.

****

VpcId

string

No

ID VPC.

vpc-uf6of9452b2pba82c ****

VSwitchIds

string

No

ID vSwitch.

vsw-uf6of9452b2pba82c ****

SecurityGroupId

string

No

The security group ID.

sg-uf6of9452b2pba82c ****

NetworkType

string

No

The network type. Valid values:

  • PrivateNetwork

  • PublicNetwork

PublicNetwork.

AuthType

string

No

The authentication type. Valid values:

  • ACL

  • No configuration required

ACL.

RoutingKey

object

No

The message routing key.

Form

string

No

Format transformasi. Nilai default: CONSTANT.

CONSTANT

Value

string

No

The routing key value.

{"Form": "CONSTANT", "Value": "my-routing-key"}

Template

string

No

Gaya templat.

The value of ${key} is ${value}!

Body

object

No

The message body content.

Form

string

No

Format transformasi. Nilai default: CONSTANT.

CONSTANT

Value

string

No

The raw data value.

{"key": "value"}

Template

string

No

Gaya templat.

The value of ${key} is ${value}!

MessageId

object

No

The unique identifier of the message.

Form

string

No

Format transformasi. Nilai default: CONSTANT.

CONSTANT

Value

string

No

The message ID value.

12345

Template

string

No

Gaya templat.

Properties

object

No

The additional properties of the message.

Form

string

No

Format transformasi. Nilai default: CONSTANT.

CONSTANT

Value

string

No

The property content.

{"env": "prod"}

Template

string

No

Gaya templat.

The value of ${key} is ${value}!

SinkBaiLianParameters SinkBaiLianParameters

No

Sink BaiLian Parameters

SinkDataWorksTriggerParameters SinkDataWorksTriggerParameters

No

SinkHttpsParameters

SinkHttpsParameters

No

The HTTPS target parameters.

SinkApiDestinationParameters SinkApiDestinationParameters

No

The ApiDestination target parameters.

SinkOSSParameters SinkOSSParameters

No

SinkRabbitMQMetaParameters SinkRabbitMQMetaParameters

No

SinkRabbitMQMsgSyncParameters SinkRabbitMQMsgSyncParameters

No

SinkMQTTParameters SinkMQTTParameters

No

SinkAgentRunParameters SinkAgentRunParameters

No

RunOptions

object

No

The runtime parameters.

MaximumTasks

integer

No

The concurrency.

2

ErrorsTolerance

string

No

The error tolerance policy: NONE (no error tolerance) or ALL (tolerate all errors).

ALL

RetryStrategy

object

No

The retry strategy when event push fails.

PushRetryStrategy

string

No

The retry strategy: BACKOFF_RETRY (backoff retry) or EXPONENTIAL_DECAY_RETRY (exponential decay retry).

BACKOFF_RETRY

MaximumEventAgeInSeconds

integer

No

The maximum retry time.

512

MaximumRetryAttempts

integer

No

The maximum number of retry attempts.

2

DeadLetterQueue

object

No

Specifies whether to enable the dead-letter queue. The dead-letter queue is disabled by default. Messages that exceed the retry policy are discarded.

Arn

string

No

The ARN of the dead-letter queue.

acs:ram::131733464781****:role/rdstoecsassumekms

Network

string

No

The network type of the dead-letter queue. Valid values:

  • PrivateNetwork

  • PublicNetwork

PrivateNetwork.

VpcId

string

No

The VPC ID of the dead-letter queue.

vpc-2zehizpoendb3****

VSwitchIds

string

No

The vSwitch ID of the dead-letter queue.

vsw-m5ev8asdc6h12345****

SecurityGroupId

string

No

The security group ID of the dead-letter queue instance.

sg-2vcgdxz7o1n9zapp****

BatchWindow

object

No

The batching window.

CountBasedWindow

integer

No

The maximum number of events that can be contained in the window. When this threshold is reached, the data in the window is pushed downstream. If multiple windows exist, a push is triggered when any window meets the threshold.

100

TimeBasedWindow

integer

No

The maximum time range (in seconds) for events in the window. When this threshold is reached, the data in the window is pushed downstream. If multiple windows exist, a push is triggered when any window meets the threshold.

10

BusinessOption

object

No

BusinessMode

string

No

MinCapacityUnitCount

integer

No

MaxCapacityUnitCount

integer

No

Throttling

integer

No

Transforms

array<object>

No

The Transform-related configurations.

object

No

The ARN of the cloud product, such as the ARN of a function in Function Compute.

Arn

string

No

The ARN of the cloud product, such as the ARN of a function in Function Compute.

acs:fc:cn-hangzhou:*****:services/demo-service.LATEST/functions/demo-func

DashScopeTransformParameters

DashScopeTransformParameters

No

BaiLianAgentTransformParameters

BaiLianAgentTransformParameters

No

Elemen respons

Element

Type

Description

Example

object

The response parameters.

Message

string

The error message.

The name [xxxx] of event streaming in request is already exist!

RequestId

string

The request ID generated by Alibaba Cloud for this request.

0FDD73AA-7A2D-5BD4-B4C0-88AFEBF5F0F5

Code

string

The response code. Success indicates a successful call. Other values indicate error codes. For more information, see Error codes.

Success

Success

boolean

Returns true if the operation is successful.

true.

Contoh

Respons sukses

JSONformat

{
  "Message": "The name [xxxx] of event streaming in request is already exist!",
  "RequestId": "0FDD73AA-7A2D-5BD4-B4C0-88AFEBF5F0F5",
  "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.