All Products
Search

This Product

    EventBridge:CreateEventStreaming

    Document Center

    EventBridge:CreateEventStreaming

    Last Updated:Jul 21, 2026

    Membuat aliran event.

    Deskripsi operasi

    Membuat aliran event.

    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:CreateEventStreaming

    create

    *EventStreaming

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

    		 None None

    Parameter permintaan

    Parameter

    Type

    Required

    Description

    Example
    EventStreamingName

    string

    Yes

    Nama aliran event.

    myeventstreaming
    Description

    string

    No

    Deskripsi aliran event.

    rocketmq2mns.
    FilterPattern

    string

    No

    Aturan pemfilteran event. Jika tidak ditentukan, semua event akan dicocokkan.

    { "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 tepat satu tipe Sumber.

    SourceMNSParameters

    object

    No

    Parameter MNS sumber.

    RegionId

    string

    No

    ID wilayah.

    cn-beijing.
    QueueName

    string

    No

    Nama antrian.

    queue_api_1642474203601
    IsBase64Decode

    boolean

    No

    Apakah akan mengaktifkan dekode Base64. Nilai default: true.

    true.
    SourceRabbitMQParameters

    object

    No

    Parameter RabbitMQ sumber.

    RegionId

    string

    No

    ID wilayah.

    cn-hangzhou.
    InstanceId

    string

    No

    ID instans dari instans ApsaraMQ for RabbitMQ.

    gtm-cn-k2c2yfg****
    VirtualHostName

    string

    No

    Nama vhost dari instans ApsaraMQ for RabbitMQ.

    eb-connect.
    QueueName

    string

    No

    Nama antrian dari instans ApsaraMQ for RabbitMQ.

    demo.
    VpcId

    string

    No

    VSwitchIds

    string

    No

    SecurityGroupId

    string

    No

    NetworkType

    string

    No

    SourceKafkaParameters

    object

    No

    Parameter Kafka sumber.

    RegionId

    string

    No

    ID wilayah.

    cn-hangzhou.
    InstanceId

    string

    No

    ID instans.

    r-8vb64581862c****
    Topic

    string

    No

    Nama topik.

    popvip_center_robot_order.
    ConsumerGroup

    string

    No

    ID kelompok konsumen yang berlangganan topik.

    DEFAULT_GROUP.
    OffsetReset

    string

    No

    Offset.

    latest.
    Network

    string

    No

    Konfigurasi jaringan. Nilai default: Default. Untuk jaringan VPC, gunakan PublicNetwork.

    Default.
    VpcId

    string

    No

    ID VPC.

    vpc-8vblalsi0vbhizr77****
    VSwitchIds

    string

    No

    ID vSwitch.

    vsw-bp179l3llg3jjxwrq72****
    SecurityGroupId

    string

    No

    ID grup keamanan.

    sg-bp1iv19sp1msc7zot4****
    ValueDataType

    string

    No

    Format encoding dan decoding isi Paket. Nilai valid:

    • JSON

    • Text

    • Binary

    JSON.
    SourceRocketMQParameters

    object

    No

    Parameter RocketMQ sumber.

    RegionId

    string

    No

    ID wilayah.

    cn-qingdao.
    InstanceId

    string

    No

    Wilayah tempat instans ApsaraMQ for RocketMQ berada.

    default_C56C36026****
    Topic

    string

    No

    Topik layanan perpesanan.

    Topic_publicRule_api_1667273421288
    Tag

    string

    No

    Tag filter Paket.

    test.
    Offset

    string

    No

    Offset konsumsi Paket. Nilai valid:

    • CONSUME_FROM_LAST_OFFSET: memulai konsumsi dari offset terbaru.

    • CONSUME_FROM_FIRST_OFFSET: memulai konsumsi dari offset paling awal.

    • CONSUME_FROM_TIMESTAMP: memulai konsumsi dari offset pada titik waktu tertentu.

    Nilai default: CONSUME_FROM_LAST_OFFSET.

    CONSUMEFROMLAST_OFFSET.
    GroupID

    string

    No

    ID Kelompok dari instans ApsaraMQ for RocketMQ.

    GID_group1
    Timestamp

    integer

    No

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

    1670656652009
    InstanceType

    string

    No

    Tipe instans. Nilai valid:

    • Cloud_4: Instans Alibaba Cloud ApsaraMQ for RocketMQ 4.0 (default)

    • Cloud_5: Instans Alibaba Cloud ApsaraMQ for RocketMQ 5.0

    • SelfBuilt: Kluster Apache RocketMQ yang dikelola sendiri

    Cloud_4
    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.
    Network

    string

    No

    Jenis jaringan. Nilai valid:

    • PublicNetwork

    • PrivateNetwork

    Valid values:

    • PrivateNetwork :

      PrivateNetwork.

    • PublicNetwork :

      PublicNetwork.

    PrivateNetwork.
    FilterType

    string

    No

    Tipe filter Paket.

    Tag.
    FilterSql

    string

    No

    Pernyataan filter SQL.

    index > 10
    AuthType

    string

    No

    Tipe otentikasi.

    ACL.
    VpcId

    string

    No

    ID VPC untuk tugas lintas batas.

    vpc-m5e3sv4b12345****
    VSwitchIds

    string

    No

    ID vSwitch untuk tugas lintas batas.

    vsw-m5ev8asdc6h12345****
    SecurityGroupId

    string

    No

    Grup keamanan untuk tugas lintas batas.

    sg-m5edtu24f12345****
    InstanceVpcId

    string

    No

    Informasi VPC instans.

    vpc-m5e3sv4b12345****
    InstanceVSwitchIds

    string

    No

    Informasi vSwitch instans.

    vsw-m5ev8asdc6h123456****
    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.
    SourceRocketMQCheckpointParameters

    object

    No

    Parameter checkpoint RocketMQ sumber.

    RegionId

    string

    No

    ID wilayah.

    InstanceType

    string

    No

    Tipe instans.

    InstanceId

    string

    No

    ID instans.

    Topics

    array

    No

    Topik Paket.

    string

    No

    Topik Paket.

    SourceApacheRocketMQCheckpointParameters

    object

    No

    Parameter checkpoint RocketMQ sumber.

    RegionId

    string

    No

    ID wilayah.

    Topics

    array

    No

    Topik Paket.

    string

    No

    Topik Paket.

    InstanceEndpoint

    string

    No

    Titik akhir instans.

    InstanceUsername

    string

    No

    Nama pengguna instans.

    InstancePassword

    string

    No

    Kata sandi instans.

    NetworkType

    string

    No

    Jenis jaringan.

    VpcId

    string

    No

    ID VPC.

    VSwitchId

    string

    No

    ID vSwitch.

    SecurityGroupId

    string

    No

    ID grup keamanan.

    SourceMQTTParameters

    object

    No

    Parameter MQTT sumber.

    RegionId

    string

    No

    ID wilayah.

    cn-shenzhen.
    InstanceId

    string

    No

    ID instans.

    r-bp1b5ncun5lqer****
    Topic

    string

    No

    Topik Paket.

    CANAL_VICUTU_UAT.
    BodyDataType

    string

    No

    Format encoding Paket. Nilai valid:

    • JSON

    • Text

    • Binary

    JSON.
    NetworkType

    string

    No

    VpcId

    string

    No

    VSwitchIds

    string

    No

    SecurityGroupId

    string

    No

    SourceDTSParameters

    object

    No

    Parameter 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 saluran langganan data.

    LTC_CACHE_PRD.
    Sid

    string

    No

    ID kelompok konsumen.

    HD3
    Username

    string

    No

    Akun kelompok konsumen.

    admin.
    Password

    string

    No

    Kata sandi akun kelompok konsumen.

    admin.
    InitCheckPoint

    integer

    No

    Offset konsumsi, yaitu stempel waktu UNIX saat klien SDK mengonsumsi Catatan data pertama. Nilainya adalah stempel waktu UNIX.

    1620962769
    SourceSLSParameters

    object

    No

    Parameter SLS sumber.

    Project

    string

    No

    Proyek Simple Log Service.

    test.
    LogStore

    string

    No

    Penyimpanan log Simple Log Service.

    sas-log.
    ConsumePosition

    string

    No

    Offset awal konsumsi. Anda dapat memilih offset paling awal atau terbaru, yang masing-masing sesuai dengan "begin" atau "end". Anda juga dapat memulai konsumsi dari waktu tertentu dalam detik.

    end.
    RoleName

    string

    No

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

    testRole.
    SourcePrometheusParameters

    object

    No

    Sumber event Prometheus sumber.

    RegionId

    string

    No

    ID wilayah.

    cn-hangzhou.
    ClusterId

    string

    No

    ID kluster.

    c83555068b6******ad213f565f209
    DataType

    string

    No

    Tipe data.

    JSON.
    Labels

    string

    No

    Label.

    __name__=.*
    RoleName

    string

    No

    ExternalLabels

    string

    No

    SourceCustomizedKafkaParameters

    object

    No

    Sumber event Kafka kustom.

    InstanceId

    string

    No

    ID instans dari instans ApsaraMQ for Kafka.

    r-8vb64581862c****

    SourceCustomizedKafkaConnectorParameters

    object

    No

    Sumber event konektor 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"
    WorkerParameters

    object

    No

    Konfigurasi instans Kafka.

    { "group.id": "connect-eb-cluster-KAFKA_CONNECTORC", "offset.storage.topic": "connect-eb-offset-KAFKA_CONNECTOR_yjqC8K5ewC", "config.storage.topic": "connect-eb-config-KAFKA_CONNECTOR_yjqC8K5ewC", "status.storage.topic": "connect-eb-status-KAFKA_CONNECTOR_yjqC8K5ewC", "consumer.group.id": "connector-eb-cluster-KAFKA_CONNECTOR_yjqC8K5ewC-mongo-sink", "bootstrap.servers": "alikafka-post:9092" }
    ConnectorParameters

    object

    No

    Parameter konektor.

    Name

    string

    No

    Nama konektor.

    test-name
    Config

    object

    No

    Konfigurasi konektor.

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

    object

    No

    Pengaturan parameter Kafka open-source.

    Bootstraps

    string

    No

    Server bootstrap.

    Topic

    string

    No

    Nama topik.

    ConsumerGroup

    string

    No

    Nama kelompok konsumen.

    OffsetReset

    string

    No

    Offset konsumsi. latest: sistem membaca data dari offset terbaru. earliest: sistem membaca data dari offset paling awal. Konfigurasi ini hanya berlaku untuk inisialisasi pertama Kelompok yang belum digunakan.

    ValueDataType

    string

    No

    Tipe data. Nilai valid: Text, Binary, Json.

    VpcId

    string

    No

    ID VPC sumber Kafka.

    VSwitchIds

    string

    No

    Daftar ID vSwitch sumber Kafka.

    SecurityGroupId

    string

    No

    ID grup keamanan sumber Kafka.

    NetworkType

    string

    No

    Jenis jaringan Kafka.

    SecurityProtocol

    string

    No

    Tipe protokol keamanan Kafka. Nilai valid: SASL_SSL, PLAINTEXT, SASL_PLAINTEXT.

    SaslMechanism

    string

    No

    Mekanisme otentikasi SASL Kafka.

    SaslUser

    string

    No

    Nama pengguna otentikasi SASL Kafka.

    SaslPassword

    string

    No

    Kata sandi otentikasi SASL Kafka.

    SslKeystoreCertificateChain

    string

    No

    [Wajib untuk otentikasi timbal balik] Rantai sertifikat klien Kafka. Parameter ini diperlukan ketika server Kafka mengaktifkan otentikasi SSL timbal balik (ssl.client.auth=required). Format: format PEM yang dienkode Base64, berisi sertifikat klien dan rantai sertifikat lengkap (sertifikat klien terlebih dahulu, lalu sertifikat CA perantara, sertifikat CA akar opsional). 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 ketika kunci privat klien dienkripsi (file PEM berisi penanda 'Proc-Type: 4,ENCRYPTED' atau 'ENCRYPTED'). Biarkan parameter ini kosong jika kunci privat tidak dienkripsi. Kata sandi ini hanya digunakan untuk mendekripsi kunci privat dan tidak terkait dengan otentikasi Kafka.

    SslTruststoreCertificates

    string

    No

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

    SslKeystoreKey

    object

    No

    [Wajib untuk autentikasi dua arah] Objek konfigurasi kunci privat SSL. Ketika server Kafka mengaktifkan autentikasi SSL dua arah, berikan kunci privat klien. Hanya pola KMS yang didukung: tentukan Sumber daya EPS Key Management Service yang menyimpan kunci privat melalui KmsArn. Sistem mengambil konten kunci privat dari KMS hanya di memori, yang memberikan keamanan lebih tinggi. Contoh konfigurasi: {"KmsArn": "acs:kms:cn-hangzhou:123456789:secret/ssl-key-xxxx", "KmsSecretValueKey": "keystore_private_key"}

    KmsArn

    string

    No

    [Wajib] Nama Sumber Daya Alibaba Cloud resource KMS yang menyimpan kunci privat SSL. ARN ini digunakan untuk menemukan instans KMS yang menyimpan kunci privat klien. Contoh format: 'acs:kms:ap-southeast-1:123456789:secret/ssl-keystore-key-xxxx'. Anda dapat melihat informasi ARN kunci yang sesuai di konsol KMS.

    KmsSecretValueKey

    string

    No

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

    SourceOSSParameters

    object

    No

    Sumber event OSS sumber.

    RoleName

    string

    No

    Nama peran yang digunakan untuk mengotorisasi EventBridge agar 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. single menunjukkan pemuatan dokumen tunggal, dan element menunjukkan pemuatan terpotong-potong. Nilai valid: single/element. Nilai default: single.

    Valid values:

    • single :

      single.

    • element :

      element.

    single.
    LoadFormat

    string

    No

    Pemuat dokumen.

    Valid values:

    • TextLoader :

      TextLoader.

    TextLoader.
    Delimiter

    string

    No

    Pemisah. Dalam mode pemuatan terpotong-potong, pemisah ini digunakan sebagai pengidentifikasi pemotongan teks. Pemisah default adalah karakter baris baru \n.

    \n
    SourceOpenSourceRabbitMQParameters

    object

    No

    Endpoint

    string

    No

    VirtualHostName

    string

    No

    QueueName

    string

    No

    BodyDataType

    string

    No

    Username

    string

    No

    Password

    string

    No

    VpcId

    string

    No

    VSwitchIds

    string

    No

    SecurityGroupId

    string

    No

    NetworkType

    string

    No

    AuthType

    string

    No

    SourceEventBusParameters

    object

    No

    EventBusName

    string

    No

    EventRuleName

    string

    No

    SourceMySQLParameters SourceMySQLParameters

    No

    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 tepat satu tipe Sink.

    SinkMNSParameters

    object

    No

    Target event MNS.

    QueueName

    object

    No

    Tipe layanan target adalah Antrian Pesan (sebelumnya MNS).

    Value

    string

    No

    Nama antrian MNS.

    MyQueue
    Form

    string

    No

    Format transformasi. Nilai default: CONSTANT.

    Valid values:

    • CONSTANT :

      CONSTANT.

    CONSTANT
    Template

    string

    No

    Templat.

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

    Body

    object

    No

    Konten Paket.

    Value

    string

    No

    Nilai sebelum transformasi.

    { "key": "value" }
    Form

    string

    No

    Format transformasi.

    Valid values:

    • JSONPATH :

      JSONPATH.

    • CONSTANT :

      CONSTANT.

    • TEMPLATE :

      TEMPLATE.

    TEMPLATE
    Template

    string

    No

    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.

    Valid values:

    • CONSTANT :

      CONSTANT.

    CONSTANT
    Template

    string

    No

    Templat.

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

    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
    SinkRabbitMQParameters

    object

    No

    Parameter RabbitMQ Sink.

    InstanceId

    object

    No

    Tipe layanan target adalah ApsaraMQ for RabbitMQ.

    Value

    string

    No

    ID instans dari instans ApsaraMQ for RabbitMQ.

    a5ff91ad4f3f24947887fe184fc2****
    Form

    string

    No

    Format transformasi. Nilai default: CONSTANT.

    Valid values:

    • CONSTANT :

      CONSTANT.

    CONSTANT
    Template

    string

    No

    Templat.

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

    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.

    Valid values:

    • CONSTANT :

      CONSTANT.

    CONSTANT
    Template

    string

    No

    Templat.

    TargetType

    object

    No

    Tipe target.

    Value

    string

    No

    Tipe target. Nilai valid:

    • Exchange: Mode Exchange.

    • Queue: Mode Antrian.

    Exchange/Queue
    Form

    string

    No

    Format transformasi. Nilai default: CONSTANT.

    CONSTANT
    Template

    string

    No

    Templat.

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

    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

    Templat.

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

    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

    Templat.

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

    QueueName

    object

    No

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

    Value

    string

    No

    Nama antrian dalam instans.

    MyQueue
    Form

    string

    No

    Format transformasi. Nilai default: CONSTANT.

    CONSTANT
    Template

    string

    No

    Templat.

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

    Body

    object

    No

    Konten Paket.

    Value

    string

    No

    Nilai sebelum transformasi.

    { "key": "value" }
    Form

    string

    No

    Format transformasi.

    TEMPLATE
    Template

    string

    No

    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

    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

    Templat.

    The value of ${key} is ${value}!
    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

    SinkKafkaParameters

    object

    No

    Parameter Kafka Sink.

    InstanceId

    object

    No

    Tipe target event adalah MSMQ for Apache Kafka.

    Value

    string

    No

    ID instans.

    Defaut_1283278472_s****
    Form

    string

    No

    Format transformasi. Nilai default: CONSTANT.

    CONSTANT
    Template

    string

    No

    Templat.

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

    Topic

    object

    No

    Nama topik.

    Value

    string

    No

    Nama topik.

    test
    Form

    string

    No

    Format transformasi. Nilai default: CONSTANT.

    CONSTANT
    Template

    string

    No

    Templat.

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

    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: langsung 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 badan Paket upstream dan mengekstrak nilai bidang yang cocok sebagai nama Topik target.

    Value

    string

    No

    Nilai.

    Form

    string

    No

    Tipe transformasi. Nilai valid:

    • CONSTANT: konstanta.

    • JSONPATH: ekstrak dari upstream berdasarkan jalur.

    Template

    string

    No

    Templat.

    Acks

    object

    No

    Mode acknowledgment untuk penulisan ke Kafka:

    • acks=0: Tidak ada tanggapan yang diperlukan dari server. Mode ini memberikan kinerja tinggi tetapi risiko loss data yang tinggi.

    • acks=1: Tanggapan dikembalikan setelah node utama berhasil menulis. Mode ini memberikan 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. Mode ini memberikan kinerja lebih rendah tetapi keamanan data lebih tinggi. Loss data hanya terjadi jika node utama dan sekunder mati.

    Value

    string

    No

    Mode acknowledgment untuk penulisan ke Kafka:

    • acks=0: Tidak ada tanggapan yang diperlukan dari server. Mode ini memberikan kinerja lebih tinggi tetapi risiko loss data lebih tinggi.

    • acks=1: Tanggapan dikembalikan setelah node utama berhasil menulis. Mode ini memberikan 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. Mode ini memberikan kinerja lebih rendah tetapi keamanan data lebih tinggi. Loss data hanya terjadi jika node utama dan sekunder mati.

    1
    Form

    string

    No

    Format transformasi. Nilai default: CONSTANT.

    CONSTANT
    Template

    string

    No

    Templat.

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

    Key

    object

    No

    Kunci pesan.

    Value

    string

    No

    Kunci pesan.

    key
    Form

    string

    No

    Format transformasi. Nilai default: CONSTANT.

    CONSTANT
    Template

    string

    No

    Templat.

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

    Value

    object

    No

    Badan Paket.

    Value

    string

    No

    Nilai sebelum transformasi.

    { "key": "value" }
    Form

    string

    No

    Format transformasi.

    TEMPLATE
    Template

    string

    No

    Templat.

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

    Headers

    object

    No

    Value

    string

    No

    Form

    string

    No

    Template

    string

    No

    CompressionType

    string

    No

    SinkApacheKafkaParameters

    object

    No

    Deskripsi.

    Bootstraps

    string

    No

    Titik akhir awal kluster Kafka.

    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: directly 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.

    • JSONPATH: extract from upstream based on a path.

    Template

    string

    No

    Templat.

    Topic

    string

    No

    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

    Headers

    object

    No

    Value

    string

    No

    Form

    string

    No

    Template

    string

    No

    SecurityProtocol

    string

    No

    SaslMechanism

    string

    No

    SaslUser

    string

    No

    SslKeystoreCertificateChain

    string

    No

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

    SslKeyPassword

    string

    No

    [Required for encrypted private key] The Kafka client private key password. This parameter is required when the client private key is encrypted (the PEM file contains 'Proc-Type: 4,ENCRYPTED' or 'ENCRYPTED' markers). Leave this parameter empty if the private key is not encrypted. This password is used only to decrypt the private key and is unrelated to Kafka authentication.

    SslTruststoreCertificates

    string

    No

    [Required for SSL] The Kafka server trust certificate. Used to authenticate the validity of the Kafka Broker SSL certificate and 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 it.

    SslKeystoreKey

    object

    No

    [Required for bidirectional authentication] The SSL private key configuration object. When the Kafka server enables bidirectional SSL authentication, you must provide the client private key. Only KMS pattern is supported: specify the Key Management EPS resource that stores the private key by using KmsArn. The system retrieves the private key content from KMS only in memory, which provides higher security. Configuration example: {"KmsArn": "acs:kms:ap-southeast-1:123456789:secret/ssl-key-xxxx", "KmsSecretValueKey": "keystore_private_key"}

    KmsArn

    string

    No

    [Required] The KMS resource ARN that stores the SSL private key. This ARN is used to locate the KMS instance that stores the client private key. Format example: 'acs:kms:ap-southeast-1:123456789:secret/ssl-keystore-key-xxxx'. You can view the ARN information of the corresponding key in the KMS console.

    KmsSecretValueKey

    string

    No

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

    CompressionType

    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

    SaslPassword

    string

    No

    SinkFcParameters

    object

    No

    Target fungsi.

    ServiceName

    object

    No

    Nama layanan.

    Value

    string

    No

    Nama layanan.

    myService
    Form

    string

    No

    Format transformasi. Nilai default: CONSTANT.

    Valid values:

    • CONSTANT :

      CONSTANT.

    CONSTANT
    Template

    string

    No

    Templat.

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

    FunctionName

    object

    No

    Nama fungsi.

    Value

    string

    No

    Nama fungsi.

    myFunction
    Form

    string

    No

    Format transformasi. Nilai default: CONSTANT.

    Valid values:

    • CONSTANT :

      CONSTANT.

    CONSTANT
    Template

    string

    No

    Templat.

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

    Concurrency

    object

    No

    Konkurensi pengiriman. Nilai minimum adalah 1.

    Value

    string

    No

    Konkurensi pengiriman. Nilai minimum: 1.

    1
    Form

    string

    No

    Format transformasi. Nilai default: CONSTANT.

    Valid values:

    • CONSTANT :

      CONSTANT.

    CONSTANT
    Template

    string

    No

    Templat.

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

    Qualifier

    object

    No

    Versi layanan.

    Value

    string

    No

    Versi layanan.

    LATEST
    Form

    string

    No

    Format transformasi. Nilai default: CONSTANT.

    Valid values:

    • CONSTANT :

      CONSTANT.

    CONSTANT
    Template

    string

    No

    Templat.

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

    InvocationType

    object

    No

    Tipe pemanggilan. Nilai valid:

    • Sync: Sinkron.

    • Async: Asinkron.

    Value

    string

    No

    Tipe pemanggilan. Nilai valid:

    • Sync: sinkron.

    • Async: asinkron.

    Valid values:

    • Async :

      Async.

    • Sync :

      Sync.

    Async
    Form

    string

    No

    Format transformasi. Nilai default: CONSTANT.

    Valid values:

    • CONSTANT :

      CONSTANT.

    CONSTANT
    Template

    string

    No

    Templat.

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

    Body

    object

    No

    Konten badan yang dikirim ke fungsi.

    Value

    string

    No

    The value before transformation.

    { "key": "value" }
    Form

    string

    No

    Format transformasi. Nilai valid:

    • ORIGINAL: event lengkap.

    • JSONPATH: event parsial.

    • CONSTANT: konstanta.

    • TEMPLATE: templat.

    Untuk informasi lebih lanjut, lihat Transformasi event.

    Valid values:

    • JSONPATH :

      JSONPATH.

    • CONSTANT :

      CONSTANT.

    • ORIGINAL :

      ORIGINAL.

    • TEMPLATE :

      TEMPLATE.

    TEMPLATE
    Template

    string

    No

    Templat.

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

    DataFormat

    object

    No

    Value

    string

    No

    Form

    string

    No

    Template

    string

    No

    SinkRocketMQParameters

    object

    No

    Parameter RocketMQ Sink.

    InstanceId

    object

    No

    The event target type is MSMQ 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

    Templat.

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

    Topic

    object

    No

    Topik instans MSMQ 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

    Templat.

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

    Body

    object

    No

    The message content.

    Value

    string

    No

    The value before transformation.

    { "key": "value" }
    Form

    string

    No

    Format transformasi.

    TEMPLATE
    Template

    string

    No

    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

    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

    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

    Templat.

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

    object

    No

    Tipe instans.

    Value

    string

    No

    Tipe instans. Nilai valid:

    • Cloud_4: Instans ApsaraMQ for RocketMQ 4.0 (default)

    • Cloud_5: Instans ApsaraMQ for RocketMQ 5.0

    • SelfBuilt: Kluster Apache RocketMQ yang dikelola sendiri

    Cloud_4
    Form

    string

    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

    Value

    string

    No

    Form

    string

    No

    Template

    string

    No

    ShardingKey

    object

    No

    Value

    string

    No

    Form

    string

    No

    Template

    string

    No

    SinkDorisParameters

    object

    No

    The event source type.

    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

    Table

    object

    No

    Value

    string

    No

    Form

    string

    No

    Template

    string

    No

    Body

    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

    The event source type.

    InstanceType

    string

    No

    InstanceId

    string

    No

    Topic

    object

    No

    Value

    string

    No

    Form

    string

    No

    Template

    string

    No

    ConsumeTimestamp

    object

    No

    Value

    string

    No

    Form

    string

    No

    Template

    string

    No

    Group

    object

    No

    Value

    string

    No

    Form

    string

    No

    Template

    string

    No

    SinkApacheRocketMQCheckpointParameters

    object

    No

    The event source type.

    Topic

    object

    No

    Value

    string

    No

    Form

    string

    No

    Template

    string

    No

    ConsumeTimestamp

    object

    No

    Value

    string

    No

    Form

    string

    No

    Template

    string

    No

    Group

    object

    No

    Value

    string

    No

    Form

    string

    No

    Template

    string

    No

    InstanceEndpoint

    string

    No

    InstanceUsername

    string

    No

    InstancePassword

    string

    No

    NetworkType

    string

    No

    VpcId

    string

    No

    VSwitchId

    string

    No

    SecurityGroupId

    string

    No

    SinkSLSParameters

    object

    No

    Parameter SLS Sink.

    Project

    object

    No

    Proyek Simple Log Service.

    Value

    string

    No

    Proyek SLS.

    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.

    Value

    string

    No

    The Logstore of SLS.

    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 reservasi Simple Log Service "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 Simple Log Service.

    Value

    string

    No

    The value before transformation.

    { "key": "value" }
    Form

    string

    No

    Format transformasi.

    TEMPLATE
    Template

    string

    No

    Templat.

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

    RoleName

    object

    No

    Untuk memberikan otorisasi kepada EventBridge agar menggunakan peran ini untuk membaca konten log Simple Log Service, kondisi berikut harus dipenuhi: saat membuat peran yang digunakan oleh layanan di konsol Resource Access Management (RAM), pilih "Alibaba Cloud Service", dan atur "Layanan tepercaya" ke "event bus".

    Value

    string

    No

    Peran yang memberikan otorisasi bagi EventBridge untuk membaca konten log SLS. Saat membuat peran yang digunakan oleh layanan 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 Simple Log Service. Anda dapat memilih format default atau mengonfigurasi pasangan key-value tertentu. Nilai valid:

    • JSON

    • KeyValue

    Value

    string

    No

    The value before transformation.

    JSON
    Form

    string

    No

    Format transformasi.

    CONSTANT
    Template

    string

    No

    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

    Templat.

    CONSTANT
    Template

    string

    No

    Templat.

    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

    Tipe topik. Nilai valid:

    • TUPLE

    • BLOB

    TUPLE
    Form

    string

    No

    Format transformasi. Nilai default: CONSTANT.

    CONSTANT
    Template

    string

    No

    Tidak ada.

    TopicSchema

    object

    No

    Skema konten topik untuk tipe TUPLE.

    Value

    string

    No

    Skema konten topik untuk tipe TUPLE.

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

    string

    No

    Format transformasi.

    TEMPLATE
    Template

    string

    No

    Templat.

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

    object

    No

    Templat konten Record untuk tipe BLOB.

    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.

    SinkFnfParameters

    object

    No

    Parameter Fnf Sink.

    FlowName

    object

    No

    Nama alur.

    Value

    string

    No

    Nama alur.

    test-streaming-fnf
    Form

    string

    No

    Format transformasi. Nilai default: CONSTANT.

    Valid values:

    • CONSTANT :

      CONSTANT.

    CONSTANT
    Template

    string

    No

    Templat.

    ExecutionName

    object

    No

    Nama eksekusi.

    Value

    string

    No

    Nama eksekusi.

    123
    Form

    string

    No

    Format transformasi. Nilai default: CONSTANT. Nilai valid:

    • JSONPATH: event parsial.

    • CONSTANT: konstanta.

    • TEMPLATE: templat.

    Untuk informasi lebih lanjut, lihat Transformasi event.

    Valid values:

    • JSONPATH :

      JSONPATH.

    • CONSTANT :

      CONSTANT.

    • TEMPLATE :

      TEMPLATE.

    CONSTANT
    Template

    string

    No

    Templat.

    Input

    object

    No

    The execution input information.

    Value

    string

    No

    The execution input information.

    123
    Form

    string

    No

    Format transformasi. Nilai valid:

    • ORIGINAL: event lengkap.

    • JSONPATH: event parsial.

    • CONSTANT: konstanta.

    • TEMPLATE: templat.

    Untuk informasi lebih lanjut, lihat Transformasi event.

    Valid values:

    • JSONPATH :

      JSONPATH.

    • CONSTANT :

      CONSTANT.

    • ORIGINAL :

      ORIGINAL.

    • TEMPLATE :

      TEMPLATE.

    CONSTANT
    Template

    string

    No

    Templat.

    RoleName

    object

    No

    Konfigurasi peran.

    Value

    string

    No

    Konfigurasi peran.

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

    string

    No

    Format transformasi. Nilai default: CONSTANT.

    Valid values:

    • CONSTANT :

      CONSTANT.

    CONSTANT
    Template

    string

    No

    Templat.

    SinkPrometheusParameters

    object

    No

    Parameter Prometheus Sink.

    URL

    object

    No

    Alamat 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.

    Valid values:

    • CONSTANT :

      CONSTANT.

    CONSTANT
    Template

    string

    No

    Gaya templat. Parameter ini kosong jika Form disetel ke CONSTANT.

    HeaderParameters

    object

    No

    Struktur data parameter header permintaan.

    Value

    string

    No

    • If Form is set to CONSTANT: the constant value.

    • If Form is set to JSONPATH: the content extracted by using JSONPath.

    • If Form is set to TEMPLATE: the template variable.

    Catatan

    The Value field cannot exceed 10,240 characters.

    name
    Form

    string

    No

    Format transformasi.

    Valid values:

    • JSONPATH :

      JSONPATH.

    • CONSTANT :

      CONSTANT.

    • TEMPLATE :

      TEMPLATE.

    TEMPLATE
    Template

    string

    No

    The HTTP request header template style. Specify this parameter when Form is set to TEMPLATE. The result of the event content transformation must be in JSON format.

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

    object

    No

    The authentication method.

    Value

    string

    No

    Tipe otentikasi.

    Valid values:

    • BASIC_AUTH :

      BASIC_AUTH

    BASIC_AUTH
    Form

    string

    No

    Format transformasi. Nilai default: CONSTANT.

    Valid values:

    • CONSTANT :

      CONSTANT.

    CONSTANT
    Template

    string

    No

    Tidak ada.

    Username

    object

    No

    The username.

    Value

    string

    No

    The username.

    ****admin
    Form

    string

    No

    Format transformasi. Nilai default: CONSTANT.

    CONSTANT
    Template

    string

    No

    Tidak ada.

    Password

    object

    No

    The password.

    Value

    string

    No

    The password.

    *****
    Form

    string

    No

    Format transformasi. Nilai default: CONSTANT.

    Valid values:

    • CONSTANT :

      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.

    JSAONPATH
    Template

    string

    No

    Templat.

    NetworkType

    object

    No

    Jenis jaringan.

    Value

    string

    No

    Jenis jaringan.

    Valid values:

    • PrivateNetwork :

      PrivateNetwork.

    • PublicNetwork :

      PublicNetwork.

    PrivateNetwork
    Form

    string

    No

    Format transformasi. Nilai default: CONSTANT.

    Valid values:

    • CONSTANT :

      CONSTANT.

    CONSTANT
    Template

    string

    No

    Tidak ada.

    VpcId

    object

    No

    ID VPC.

    Value

    string

    No

    ID VPC.

    i-2ze7u5i17mbqtx1p****
    Form

    string

    No

    Format transformasi. Nilai default: CONSTANT.

    Valid values:

    • CONSTANT :

      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.

    Valid values:

    • CONSTANT :

      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.

    Valid values:

    • CONSTANT :

      CONSTANT.

    CONSTANT
    Template

    string

    No

    Tidak ada.

    SinkCustomizedKafkaParameters

    object

    No

    Parameter Kafka Sink.

    InstanceId

    string

    No

    The instance ID of MSMQ for Apache 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 konektor.

    mongo-sink
    Config

    object

    No

    Konfigurasi konektor.

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

    object

    No

    The instance configuration.

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

      Delete

    • Upsert :

      Upsert

    Upsert
    Network

    string

    No

    Jenis jaringan.

    Valid values:

    • PrivateNetwork :

      PrivateNetwork.

    • PublicNetwork :

      PublicNetwork.

    PublicNetwork.
    PrimaryKeyId

    object

    No

    The primary key ID for inserting or deleting records.

    Catatan

    If this field is not specified, a random primary key ID is used.

    Form

    string

    No

    Format transformasi.

    Valid values:

    • JSONPATH :

      JSONPATH.

    • TEMPLATE :

      TEMPLATE.

    JSONPATH
    Value

    string

    No

    • If Form is set to JSONPATH: the content extracted by using JSONPath.

    • If Form is set to TEMPLATE: the 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

    Format transformasi.

    Valid values:

    • JSONPATH :

      JSONPATH.

    • CONSTANT :

      CONSTANT.

    CONSTANT
    Value

    string

    No

    • If Form is set to CONSTANT: the constant value.

    • If Form is set to JSONPATH: the content extracted by using JSONPath.

    Catatan

    The Value field cannot exceed 10,240 characters.

    default
    Template

    string

    No

    Tidak ada.

    ${partition}
    Vector

    object

    No

    The vector of the record to be inserted into DashVector.

    Form

    string

    No

    Format transformasi.

    Valid values:

    • JSONPATH :

      JSONPATH.

    JSONPATH
    Value

    string

    No

    The content extracted by using JSONPath.

    Catatan

    The Value field cannot exceed 10,240 characters.

    $.data.messageBody
    Template

    string

    No

    Tidak ada.

    ${vector}
    DashVectorSchemaParameters

    array<object>

    No

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

    array<object>

    No

    The property column.

    Name

    object

    No

    The property name.

    Form

    string

    No

    Form

    CONSTANT
    Value

    string

    No

    Value

    content
    Template

    string

    No

    Template

    Type

    object

    No

    The DashVector property type.

    Form

    string

    No

    Form

    CONSTANT
    Value

    string

    No

    Value

    STRING
    Template

    string

    No

    Template

    Value

    object

    No

    The property value.

    Form

    string

    No

    Form

    JSONPATH
    Value

    string

    No

    Value

    $.data.content
    Template

    string

    No

    Template

    ${content}
    SinkOpenSourceRabbitMQParameters

    object

    No

    Endpoint

    string

    No

    VirtualHostName

    string

    No

    TargetType

    string

    No

    Exchange

    string

    No

    QueueName

    string

    No

    Username

    string

    No

    Password

    string

    No

    VpcId

    string

    No

    VSwitchIds

    string

    No

    SecurityGroupId

    string

    No

    NetworkType

    string

    No

    AuthType

    string

    No

    RoutingKey

    object

    No

    Form

    string

    No

    Value

    string

    No

    Template

    string

    No

    Body

    object

    No

    Form

    string

    No

    Value

    string

    No

    Template

    string

    No

    MessageId

    object

    No

    Form

    string

    No

    Value

    string

    No

    Template

    string

    No

    Properties

    object

    No

    Form

    string

    No

    Value

    string

    No

    Template

    string

    No

    SinkBaiLianParameters SinkBaiLianParameters

    No

    SinkDataWorksTriggerParameters SinkDataWorksTriggerParameters

    No

    SinkHttpsParameters

    SinkHttpsParameters

    No

    SinkApiDestinationParameters SinkApiDestinationParameters

    No

    SinkOSSParameters SinkOSSParameters

    No

    SinkRabbitMQMetaParameters SinkRabbitMQMetaParameters

    No

    SinkRabbitMQMsgSyncParameters SinkRabbitMQMsgSyncParameters

    No

    SinkMQTTParameters SinkMQTTParameters

    No

    SinkAgentRunParameters SinkAgentRunParameters

    No

    RunOptions

    object

    No

    The runtime environment parameters.

    MaximumTasks

    integer

    No

    The concurrency.

    2
    ErrorsTolerance

    string

    No

    The exception tolerance policy. Valid values:

    • NONE: No tolerance for exceptions.

    • ALL: Tolerate all exceptions.

    ALL
    RetryStrategy

    object

    No

    The retry policy when event delivery fails.

    PushRetryStrategy

    string

    No

    The retry policy. Valid values:

    • BACKOFF_RETRY: Backoff retry.

    • 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. By default, the dead-letter queue is disabled, and 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

    VpcId

    string

    No

    VSwitchIds

    string

    No

    SecurityGroupId

    string

    No

    BatchWindow

    object

    No

    The batch window.

    CountBasedWindow

    integer

    No

    The maximum number of events that the window can contain. 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) of events that the window can contain. 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 Alibaba Cloud Resource Name (ARN) of the cloud service, such as the ARN of a function in Function Compute.

    Arn

    string

    No

    The Alibaba Cloud Resource Name (ARN) of the cloud service, 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

    EmbeddingTransformParameters

    EmbeddingTransformParameters

    No

    Tags

    array<object>

    No

    The tag list. A maximum of 20 items are supported.

    object

    No

    Key

    string

    No

    The tag key.

    Value

    string

    No

    The tag value.

    Elemen respons

    Element

    Type

    Description

    Example

    object

    The request parameters.

    Message

    string

    The error message.

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

    string

    The request ID.

    B896B484-F16D-59DE-9E23-DD0E5C36****
    Data

    object

    The returned data.

    EventStreamingARN

    string

    The Alibaba Cloud Resource Name (ARN) of the event stream.

    acs:eventbridge:cn-hangzhou:164901546557****:eventstreaming/myeventstreaming
    Code

    string

    The returned code. Valid values:

    • Success: The request was successful.

    • Other values: An error occurred. For more information, see Error codes.

    Success
    Success

    boolean

    Indicates whether the operation was successful. The value true is returned if the operation was successful.

    true.

    Contoh

    Respons sukses

    JSONformat

    {
  "Message": "The name [xxxx] of event streaming in request is already exist!",
  "RequestId": "B896B484-F16D-59DE-9E23-DD0E5C36****",
  "Data": {
    "EventStreamingARN": "acs:eventbridge:cn-hangzhou:164901546557****:eventstreaming/myeventstreaming"
  },
  "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.