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
Test
RAM authorization
|
Action |
Access level |
Resource type |
Condition key |
Dependent action |
|
eventbridge:UpdateEventStreaming |
update |
*EventStreaming
|
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:
|
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:
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_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. |
| BodyDataType |
string |
No |
Format encoding Paket. Nilai valid:
|
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. |
| 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:
|
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. |
| 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:
|
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:
|
|
| 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:
|
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/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:
|
|
| 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:
|
CONSTANT |
| Template |
string |
No |
Gaya templat. |
The value of ${key} is ${value}! |
| Acks |
object |
No |
Mode acknowledgment tulis Kafka. Nilai valid:
|
|
| Value |
string |
No |
Mode acknowledgment untuk penulisan ke Kafka:
|
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:
|
|
| 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 |
| 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:
|
|
| Value |
string |
No |
Jenis jaringan. Nilai valid:
|
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:
|
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 |
| 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:
|
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:
|
|
| 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 |
Catatan: Bidang Value tidak boleh melebihi 10.240 karakter. |
name |
| Form |
string |
No |
Format transformasi. Nilai valid:
|
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:
|
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:
|
|
| Value |
string |
No |
The topic type. Valid values:
|
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:
|
|
| 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:
|
Upsert |
| Network |
string |
No |
The network type. Valid values:
|
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 |
| Value |
string |
No |
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:
|
CONSTANT |
| Value |
string |
No |
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 |
| 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:
|
PublicNetwork. |
| AuthType |
string |
No |
The authentication type. Valid values:
|
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. |
| 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.