使用 GetEventStreaming 擷取事件流詳情 - 事件匯流排 - 阿里雲 - EventBridge

object

返回資訊。

Message

string

錯誤資訊。

The event streaming [xxxx] not existed!

RequestId

string

阿里雲為該請求生成的唯一識別碼。

7892F480-58C9-5067-AB35-8A7BEF****

Data

object

返回資料。

EventStreamingName

string

取得到的事件流的名稱。

rocketmq-sync

Description

string

取得到的事件流的描述。

RocketMQ-to-RocketMQ

Source

object

事件提供方。

SourceMNSParameters

object

Source 輕量訊息佇列（原 MNS）參數。

RegionId

string

地域 ID。

cn-hangzhou

QueueName

string

輕量訊息佇列（原 MNS）的 Queue 的名稱。

demo

IsBase64Decode

boolean

是否開啟 Base64 編碼。

true

SourceRabbitMQParameters

object

Source RabbitMQ 源。

RegionId

string

地域 ID。

cn-hangzhou

InstanceId

string

訊息佇列 RabbitMQ 版的執行個體的 ID。

i-f8z9a9mcgwri1c1i****

VirtualHostName

string

訊息佇列 RabbitMQ 版執行個體的 Vhost 的名稱。

eb-connect

QueueName

string

訊息佇列 RabbitMQ 版執行個體的 Queue 的名稱。

comp

SourceRocketMQParameters

object

Source RocketMQ 源。

RegionId

string

訊息佇列 RocketMQ 版的地域 ID。

cn-hangzhou

InstanceId

string

訊息佇列 RocketMQ 版的執行個體 ID。

i-f8zbher64dlm58pl****

Topic

string

訊息的 Topic。

topic_add_anima

Tag

string

訊息的過濾標籤。

v1

Offset

string

訊息的消費位點。取值說明如下： CONSUME_FROM_LAST_OFFSET：從最新位點開始消費。 CONSUME_FROM_FIRST_OFFSET：從最早位點開始消費。 CONSUME_FROM_TIMESTAMP：從指定時間點的位點開始消費。

CONSUMEFROMLASTOFFSET

GroupID

string

訊息佇列 RocketMQ 版的 Group ID。

GID_group1

Timestamp

integer

時間戳記。僅當參數 Offset 取值為 CONSUME_FROM_TIMESTAMP 時，該參數有效。

1636597951964

InstanceType

string

執行個體類型。取值說明如下：

Cloud_4：阿里雲 RocketMQ 4.0 版本執行個體（預設選項）
Cloud_5：阿里雲 RocketMQ 5.0 版本執行個體
SelfBuilt：自建 Apache RocketMQ 叢集

Cloud_4

InstanceEndpoint

string

執行個體接入點。

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

AuthType

string

鑑權類型。

ACL

InstanceUsername

string

執行個體使用者名稱。

xxxa

InstancePassword

string

執行個體密碼。

xxxa

InstanceVpcId

string

執行個體 VPC 資訊。

vpc-m5e3sv4b12345****

InstanceVSwitchIds

string

執行個體交換機資訊。

vsw-m5ev8asdc6h12****

InstanceSecurityGroupId

string

執行個體安全性群組資訊。

sg-m5edtu24f12345****

InstanceNetwork

string

執行個體網路資訊：

PublicNetwork
PrivateNetwork

PublicNetwork

BodyDataType

string

訊息編碼格式：

Json
Text
Binary

Json

FilterType

string

訊息過濾類型。

Tag

FilterSql

string

sql 過濾語句。

index > 10

VpcId

string

VPC 的 ID。

vpc-m5e3sv4b12345****

VSwitchIds

string

交換機 ID。

vsw-m5ev8asdc6h12345****

SecurityGroupId

string

安全性群組 ID。

sg-m5edtu24f12345****

Network

string

網路類型。

PublicNetwork
PrivateNetwork

PublicNetwork

SourceRocketMQCheckpointParameters

object

Source RocketMQ Checkpoint 源。

RegionId

string

地域 ID。

cn-hangzhou

InstanceType

string

執行個體類型。取值說明如下：

Cloud_4：阿里雲 RocketMQ 4.0 版本執行個體（預設選項）
Cloud_5：阿里雲 RocketMQ 5.0 版本執行個體
SelfBuilt：自建 Apache RocketMQ 叢集

Cloud_4

InstanceId

string

執行個體 ID。

rmp-cn-jte3w******

Topics

array

訊息 Topic。

string

訊息 Topic。

opic_add_anima

SourceApacheRocketMQCheckpointParameters

object

Source RocketMQ Checkpoint 源。

RegionId

string

地域 ID。

cn-hangzhou

InstanceId

string

RocketMQ 執行個體 ID。

MQ_INST_164901546557****_BAAN****

Topics

array

Topic 列表。

string

需要消費的 Topic 列表。

["Topic_1","Topic_2"]

InstanceEndpoint

string

執行個體接入點。

registry-vpc.cn-hangzhou.aliyuncs.com

InstanceUsername

string

執行個體使用者名稱。

admin

InstancePassword

string

執行個體密碼。

123456

NetworkType

string

網路類型。

PrivateNetwork

VpcId

string

VPC ID。

vpc-adw1awdw*****

VSwitchId

string

交換機 ID。

vsw-dwaafds****

SecurityGroupId

string

安全性群組 ID。

sg-mw43*****

SourceKafkaParameters

object

Source Kafka 源。

RegionId

string

執行個體所在地域 ID。

cn-hangzhou

InstanceId

string

執行個體 ID。

i-bp1fbtrnqmjvgq66****

Topic

string

Topic 名稱。

topic_empower_1642473600414

ConsumerGroup

string

訂閱該 Topic 的消費者所對應的 Group ID。

GID_TEST

OffsetReset

string

偏移量。

latest

Network

string

網路配置：預設值 Default，vpc 網路是 PublicNetwork。

Default

VpcId

string

VPC ID

vpc-2zehizpoendb3****

VSwitchIds

string

虛擬交換機 ID。

vsw-wz9qqeovkwjxlu9uc****

SecurityGroupId

string

安全性群組 ID。

sg-2vcgdxz7o1n9zapp****

ValueDataType

string

編解碼參數列舉值，有 3 個列舉值，命名如下

JSON：現有邏輯，bytes 按 utf8 解碼成字串，解析為 JSON。
Text：bytes 按 utf8 解碼成字串，直接放入 payload。
Binary：bytes 按 base64 編碼成字串，放入 payload。

Text

SourceMQTTParameters

object

Source MQTT 源。

RegionId

string

地域 ID。

cn-shanghai

InstanceId

string

執行個體 ID。

i-2ze06wqdwk0uq14k****

Topic

string

Topic 名稱。

TOPIC-cainiao-pcs-wms-instock-noPrealertPrintLabel

BodyDataType

string

訊息編碼格式：

JSON
Text
Binary

JSON

NetworkType

string

網路類型。

VpcId

string

VPC ID。

VSwitchIds

string

虛擬交換機 ID。

SecurityGroupId

string

安全性群組 ID。

SourceDTSParameters

object

Source DTS 源。

TaskId

string

任務 ID。

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

BrokerUrl

string

資料訂閱通道的網路位址及連接埠號資訊。

Topic

string

資料訂閱通道的訂閱 Topic。

TP_TEST_UNDERWRITE_ISSUE

Sid

string

消費組 ID。

HD1

Username

string

消費組的帳號。

admin

Password

string

消費組的帳號密碼。

admin****

InitCheckPoint

string

消費位點，即 SDK 用戶端消費第一筆資料的時間戳記，格式為 Unix 時間戳記。

1620962769

SourceSLSParameters

object

Source SLS 源。

Project

string

日誌服務 SLS 的日誌專案。

dmmzk

LogStore

string

日誌服務 SLS 的日誌庫。

waf-logstore

ConsumerGroup

string

消費組。

ConsumePosition

string

起始消費位點，可以選擇最早或最新位點，分別對應「begin」、「end」，也可以從指定時間開始消費，以秒為單位。

begin

RoleName

string

授權事件匯流排 EventBridge 使用此角色讀取 SLS 日誌內容時，需滿足條件：在 RAM 主控台建立服務所使用的角色時，需要選擇「阿里雲服務」，並且「受信服務」需要選擇「事件匯流排」。

testRole

SourcePrometheusParameters

object

Source Prometheus 事件源。

RegionId

string

地域 ID。

cn-hangzhou

ClusterId

string

叢集 ID。

c83555068b6******ad213f565f209

DataType

string

資料類型。

Json

Labels

string

標籤。

__name__=.*

RoleName

string

任務角色名稱。

test-role

ExternalLabels

string

附加到事件流中的外部標籤。

{"env":"test"}

SourceCustomizedKafkaParameters

object

自訂 Kafka 事件源。

InstanceId

string

訊息佇列 Kafka 版的執行個體 ID。

r-8vb64581862c****

SourceCustomizedKafkaConnectorParameters

object

自訂連接器 Apache Kafka 事件源。

ConnectorPackageUrl

string

OSS 資源 ZIP 包下載連結。

"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

連接器參數。

Name

string

連接器名稱。

test-name

Config

object

連接器配置。

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

WorkerParameters

object

執行個體配置。

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

Bootstraps

string

Topic

string

ConsumerGroup

string

OffsetReset

string

ValueDataType

string

VpcId

string

VSwitchIds

string

SecurityGroupId

string

NetworkType

string

SecurityProtocol

string

SaslMechanism

string

SaslUser

string

SaslPassword

string

SslTruststoreCertificates

string

【SSL 場景必填】Kafka 伺服器端信任憑證。用於驗證 Kafka Broker 的 SSL 憑證合法性，防止中間人攻擊。格式要求：Base64 編碼的 PEM 格式，通常包含 Kafka 伺服器端的 CA 憑證或伺服器端憑證本身。示例：將 CA 憑證的 PEM 檔案內容（確保開頭和結尾分別是 '-----BEGIN CERTIFICATE-----' 和 '-----END CERTIFICATE-----' ），進行 Base64 編碼。若 Kafka 使用自簽名憑證，需提供簽發該憑證的 CA 憑證。

SslKeystoreCertificateChain

string

【雙向認證必填】Kafka 用戶端憑證鏈。當 Kafka 伺服器端開啟雙向 SSL 認證（ssl.client.auth=required）時，需提供此參數。格式要求：Base64 編碼的 PEM 格式，包含用戶端憑證及完整的憑證鏈（用戶端憑證在前，中間 CA 憑證在後，根 CA 憑證可選）。注意：確保每個 PEM 檔案內容的開頭和結尾分別是 '-----BEGIN CERTIFICATE-----' 和 '-----END CERTIFICATE-----' ，拼接後進行 Base64 編碼。

SslKeyPassword

string

【加密私鑰必填】Kafka 用戶端私鑰密碼。當用戶端私鑰使用密碼加密保護時（即 PEM 檔案中包含 'Proc-Type: 4,ENCRYPTED' 或 'ENCRYPTED' 標記），需提供解密密碼。若私鑰未加密則留空。注意：此密碼僅用於解密私鑰，與 Kafka 認證無關。

SslKeystoreKey

object

【雙向認證必填】SSL 私鑰配置物件。當 Kafka 伺服器端開啟雙向 SSL 認證時，需提供用戶端私鑰。密鑰僅支援 KMS 模式：透過 KmsArn 指定儲存私鑰的密鑰管理服務資源，系統只在記憶體態從 KMS 取得私鑰內容，安全性更高；配置示例：{"KmsArn": "acs:kms:cn-hangzhou:123456789:secret/ssl-key-xxxx", "KmsSecretValueKey": "keystore_private_key"}\n"

KmsArn

string

【必填】儲存 SSL 私鑰的 KMS 資源 ARN。用於定位存放用戶端私鑰的密鑰管理服務執行個體。格式示例： 'acs:kms:cn-hangzhou:123456789:secret/ssl-keystore-key-xxxx'。取得方式：在 KMS 主控台查看對應密鑰的 ARN 資訊。

KmsSecretValueKey

string

【kms KV 模式】KMS 憑據中的密鑰鍵名。當 KMS 儲存的憑據為鍵值對（KV）結構時，填寫此參數以指定 SSL 私鑰對應的 key。示例：若 KMS 憑據為 '{"ssl_keystore_key":"-----BEGIN PRIVATE KEY-----...","ssl_truststore_key":"..."}'，則填寫 'ssl_keystore_key'。若 KMS 憑據為純文字模式（直接儲存私鑰的 PEM 內容），則留空此參數。

SourceOSSParameters

object

Source OSS 事件源。

RoleName

string

授權事件匯流排 EventBridge 讀取 OSS 檔案的角色名稱，要求該角色至少具有 OSS 的唯讀權限。

eventbridge_oss_role

BucketName

string

物件儲存 OSS 中的儲存空間名稱。

bucket_abc

Prefix

string

檔案路徑前綴。

fun/document/

LoadMode

string

資料載入模式，single 表示單文件載入，element 表示分塊載入。取值：single/element，預設為 single。

single

LoadFormat

string

文件載入器。

TextLoader

Delimiter

string

分隔符，在分塊載入模式下，以該分隔符作為文字的分塊識別碼，預設以換行符作為分隔符。

\n

SourceOpenSourceRabbitMQParameters

object

Source 開源 RabbitMQ 源。

Endpoint

string

開源版 RabbitMQ 執行個體接入點。

192.168.1.100:5672

VirtualHostName

string

開源版 RabbitMQ 執行個體的 Vhost 的名稱。

eb-connect

QueueName

string

開源版 RabbitMQ 執行個體的 Queue 的名稱。

demo

BodyDataType

string

訊息編碼格式：

JSON
Text
Binary

Json

Username

string

使用者名稱。

admin

Password

string

密碼。

******

VpcId

string

VPC 的 ID。

vpc-bp1vllc1lnw1v657******

VSwitchIds

string

交換機 ID。

vsw-uf65zhil5oukof5******

SecurityGroupId

string

安全性群組 ID。

sg-2ze65razphjfz3******

NetworkType

string

網路類型：

公網：PublicNetwork
專有網路：PrivateNetwork

PrivateNetwork

AuthType

string

鑑權類型。

ACL

SourceEventBusParameters

object

Source Event Bus 源。

EventBusName

string

事件匯流排的名稱。

demo

EventRuleName

string

事件規則名稱。

test

SourceMySQLParameters

Source MySQL 源。

SourcePostgreSQLParameters

SourceRabbitMQMetaParameters

SourceRabbitMQMsgSyncParameters

SourceFeiShuDocsParameters

Metadata

string

FilterPattern

string

事件過濾規則，如果不指定表示比對全部事件。

Transforms

array<object>

Transform 相關配置。

object

雲端產品的 ARN，例如函數計算中函數的 ARN。

Arn

string

雲端產品的 ARN，例如函數計算中函數的 ARN。

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

DashScopeTransformParameters

BaiLianAgentTransformParameters

Sink

object

事件目標。

SinkMNSParameters

object

輕量訊息佇列（原 MNS）事件目標。

QueueName

object

目標服務類型為輕量訊息佇列（原 MNS）。

Value

string

輕量訊息佇列（原 MNS）的 Queue 的名稱。

MyQueue

Form

string

轉換的格式。預設為 CONSTANT。

CONSTANT

Template

string

範本樣式。

Body

object

訊息內容。

Value

string

轉換前的值。

{ "key": "value" }

Form

string

轉換的格式。

TEMPLATE

Template

string

範本樣式。

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

IsBase64Encode

object

是否開啟 Base64 編碼。

Value

string

開啟 Base64 編碼。

true

Form

string

事件轉換的格式。預設為 CONSTANT。

CONSTANT

Template

string

範本樣式。

SinkRabbitMQParameters

object

Sink RabbitMQ 的參數。 [responses.200.schema.properties.Data.properties.Sink.properties.SinkRabbitMQ

InstanceId

object

目標服務類型為訊息佇列 RabbitMQ 版。

Value

string

訊息佇列 RabbitMQ 版的執行個體 ID。

e5c9b727-e06c-4d7e-84d5-f8ce644e****

Form

string

轉換的格式。預設為 CONSTANT。

CONSTANT

Template

string

範本樣式。

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

VirtualHostName

object

訊息佇列 RabbitMQ 版執行個體的 Vhost 的名稱。

Value

string

訊息佇列 RabbitMQ 版執行個體的 Vhost 的名稱。

rabbit-host

Form

string

轉換的格式。預設為 CONSTANT。

CONSTANT

Template

string

範本樣式。

TargetType

object

目標類型。

Value

string

目標類型。取值說明如下：

Exchange：Exchange 模式。
Queue：Queue 模式。

Exchange/Queue

Form

string

轉換的格式。預設為 CONSTANT。

CONSTANT

Template

string

範本樣式。

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

Exchange

object

Exchange 模式。僅當參數 TargetType 配置為 Exchange 時，需配置此參數。

Value

string

訊息佇列 RabbitMQ 版執行個體的 Exchange 的名稱。

a_exchange

Form

string

轉換的格式。預設為 CONSTANT。

CONSTANT

Template

string

範本樣式。

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

RoutingKey

object

訊息的路由規則。僅當參數 TargetType 配置為 Exchange 時，需配置此參數。 [_single.resp.200.props.Data.Sink.SinkRabbitMQParameters.RoutingKey.Value.desc

Value

string

消息的路由规则。

housekeeping

Form

string

轉換的格式。預設為 CONSTANT。

CONSTANT

Template

string

範本樣式。

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

QueueName

object

Queue 模式。仅当参数 TargetType 配置为 Queue 时，需配置此参数。

Value

string

实例的 Queue 的名称。

MyQueue

Form

string

轉換的格式。預設為 CONSTANT。

CONSTANT

Template

string

範本樣式。

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

Body

object

訊息內容。

Value

string

轉換前的值。

{ "key": "value" }

Form

string

轉換的格式。

TEMPLATE

Template

string

範本樣式。

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

MessageId

object

消息 ID。

Value

string

轉換前的值。

{ "key": "value" }

Form

string

轉換的格式。

TEMPLATE

Template

string

範本樣式。

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

Properties

object

过滤属性。

Value

string

轉換前的值。

{ "key": "value" }

Form

string

轉換的格式。

TEMPLATE

Template

string

範本樣式。

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

SinkFcParameters

object

函数目标。

ServiceName

object

服务的名称。

Value

string

服务的名称。

myService

Form

string

轉換的格式。預設為 CONSTANT。

CONSTANT

Template

string

範本樣式。

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

FunctionName

object

函数名称。

Value

string

函数名称。

mFunction

Form

string

轉換的格式。預設為 CONSTANT。

CONSTANT

Template

string

範本樣式。

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

Concurrency

object

投递并发度，最小 1。

Value

string

投递并发度，最小 1。

1

Form

string

轉換的格式。預設為 CONSTANT。

CONSTANT

Template

string

範本樣式。

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

Qualifier

object

服务版本。

Value

string

服务版本。

LATEST

Form

string

轉換的格式。預設為 CONSTANT。

CONSTANT

Template

string

範本樣式。

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

InvocationType

object

同步或则异步。

Sync：同步。
Async：异步。

Value

string

同步或则异步。

Sync：同步。
Async：异步。

Async

Form

string

轉換的格式。預設為 CONSTANT。

CONSTANT

Template

string

範本樣式。

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

Body

object

发送给函数的内容体。

Value

string

轉換前的值。

{ "key": "value" }

Form

string

转换的格式：

ORIGINAL：完整事件
JSONPATH：部分事件
CONSTANT：常量
TEMPLATE：模板

详细参考：https://www.alibabacloud.com/help/zh-TW/eventbridge/user-guide/event-transformation

TEMPLATE

Template

string

範本樣式。

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

DataFormat

object

事件内容的格式转换规则。

Value

string

轉換前的值。

{ "key": "value" }

Form

string

转换的格式：

ORIGINAL：完整事件
JSONPATH：部分事件
CONSTANT：常量
TEMPLATE：模板

JSONPATH

Template

string

範本樣式。

$.data.key

SinkKafkaParameters

object

Sink kafak 参数。

InstanceId

object

目标服务类型为消息队列 Kafka 版。

Value

string

執行個體 ID。

Defaut_1283278472_s****

Form

string

轉換的格式。預設為 CONSTANT。

CONSTANT

Template

string

範本樣式。

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

DynamicTopic

object

指定消息路由的目标 Topic 策略。若同时指定了 topic 参数和 DynamicTopic 参数，以 DynamicTopic 参数的值为准。支持以下两种配置模式： 1. 静态常量模式：直接填写固定的 Topic 名称字符串（例如："order_created"）。所有消息将统一发送至该 Topic。 2. 动态提取模式：填写标准的 JSONPath 表达式（例如："$.user.id" 或 "$.metadata.category"）。系统将解析上游消息体，提取匹配字段的值作为目标 Topic 名称。

Value

string

值

Form

string

转换的类型 CONSTANT：固定值 JSONPATH：根据路径从上游提取

Template

string

模板

Topic

object

主题名称。

Value

string

主题名称。

test

Form

string

轉換的格式。預設為 CONSTANT。

CONSTANT

Template

string

範本樣式。

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

CompressionType

string

Acks

object

写入 Kafka 确认模式：

acks=0：无需服务端的 Response、性能较高、丢数据风险较大。
acks=1：服务端主节点写成功即返回 Response、性能中等、丢数据风险中等、主节点宕机可能导致数据丢失；
acks=all：服务端主节点写成功且备节点同步成功才返回 Response、性能较差、数据较为安全、主节点和备节点都宕机才会导致数据丢失。

Value

string

写入 Kafka 确认模式：

acks=0：无需服务端的 Response、性能较高、丢数据风险较大。
acks=1：服务端主节点写成功即返回 Response、性能中等、丢数据风险中等、主节点宕机可能导致数据丢失；
acks=all：服务端主节点写成功且备节点同步成功才返回 Response、性能较差、数据较为安全、主节点和备节点都宕机才会导致数据丢失。

1

Form

string

轉換的格式。預設為 CONSTANT。

CONSTANT

Template

string

範本樣式。

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

Key

object

消息键。

Value

string

消息键。

key

Form

string

轉換的格式。預設為 CONSTANT。

CONSTANT

Template

string

範本樣式。

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

Headers

object

Kafka 消息的附加元数据。

Value

string

轉換前的值。

{ "key": "value" }

Form

string

转换的格式：

ORIGINAL：完整事件
JSONPATH：部分事件
CONSTANT：常量
TEMPLATE：模板

CONSTANT

Template

string

範本樣式。

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

Value

object

消息体。

Value

string

轉換前的值。

{ "key": "value" }

Form

string

轉換的格式。

TEMPLATE

Template

string

範本樣式。

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

SinkApacheKafkaParameters

object

描述信息

Bootstraps

string

Topic

string

DynamicTopic

object

指定消息路由的目标 Topic 策略。若同时指定了 topic 参数和 DynamicTopic 参数，以 DynamicTopic 参数的值为准。支持以下两种配置模式： 1. 静态常量模式：直接填写固定的 Topic 名称字符串（例如："order_created"）。所有消息将统一发送至该 Topic。 2. 动态提取模式：填写标准的 JSONPath 表达式（例如："$.user.id" 或 "$.metadata.category"）。系统将解析上游消息体，提取匹配字段的值作为目标 Topic 名称。

Value

string

值

Form

string

转换的类型 CONSTANT：固定值 JSONPATH：根据路径从上游提取

Template

string

模板

Acks

string

CompressionType

string

Key

object

Value

string

Form

string

Template

string

Headers

object

Value

string

Form

string

Template

string

Value

object

Value

string

Form

string

Template

string

SecurityProtocol

string

SaslMechanism

string

SaslUser

string

VpcId

object

Value

string

Form

string

Template

string

VSwitchIds

object

Value

string

Form

string

Template

string

SecurityGroupId

object

Value

string

Form

string

Template

string

NetworkType

object

Value

string

Form

string

Template

string

SaslPassword

string

SslTruststoreCertificates

string

【SSL 場景必填】Kafka 伺服器端信任憑證。用於驗證 Kafka Broker 的 SSL 憑證合法性，防止中間人攻擊。格式要求：Base64 編碼的 PEM 格式，通常包含 Kafka 伺服器端的 CA 憑證或伺服器端憑證本身。示例：將 CA 憑證的 PEM 檔案內容（確保開頭和結尾分別是 '-----BEGIN CERTIFICATE-----' 和 '-----END CERTIFICATE-----' ），進行 Base64 編碼。若 Kafka 使用自簽名憑證，需提供簽發該憑證的 CA 憑證。

SslKeystoreCertificateChain

string

【雙向認證必填】Kafka 用戶端憑證鏈。當 Kafka 伺服器端開啟雙向 SSL 認證（ssl.client.auth=required）時，需提供此參數。格式要求：Base64 編碼的 PEM 格式，包含用戶端憑證及完整的憑證鏈（用戶端憑證在前，中間 CA 憑證在後，根 CA 憑證可選）。注意：確保每個 PEM 檔案內容的開頭和結尾分別是 '-----BEGIN CERTIFICATE-----' 和 '-----END CERTIFICATE-----' ，拼接後進行 Base64 編碼。

SslKeyPassword

string

【加密私鑰必填】Kafka 用戶端私鑰密碼。當用戶端私鑰使用密碼加密保護時（即 PEM 檔案中包含 'Proc-Type: 4,ENCRYPTED' 或 'ENCRYPTED' 標記），需提供解密密碼。若私鑰未加密則留空。注意：此密碼僅用於解密私鑰，與 Kafka 認證無關。

SslKeystoreKey

object

【雙向認證必填】SSL 私鑰配置物件。當 Kafka 伺服器端開啟雙向 SSL 認證時，需提供用戶端私鑰。密鑰僅支援 KMS 模式：透過 KmsArn 指定儲存私鑰的密鑰管理服務資源，系統只在記憶體態從 KMS 取得私鑰內容，安全性更高；配置示例：{"KmsArn": "acs:kms:cn-hangzhou:123456789:secret/ssl-key-xxxx", "KmsSecretValueKey": "keystore_private_key"}\n"

KmsArn

string

【必填】儲存 SSL 私鑰的 KMS 資源 ARN。用於定位存放用戶端私鑰的密鑰管理服務執行個體。格式示例： 'acs:kms:cn-hangzhou:123456789:secret/ssl-keystore-key-xxxx'。取得方式：在 KMS 主控台查看對應密鑰的 ARN 資訊。

KmsSecretValueKey

string

【kms KV 模式】KMS 憑據中的密鑰鍵名。當 KMS 儲存的憑據為鍵值對（KV）結構時，填寫此參數以指定 SSL 私鑰對應的 key。示例：若 KMS 憑據為 '{"ssl_keystore_key":"-----BEGIN PRIVATE KEY-----...","ssl_truststore_key":"..."}'，則填寫 'ssl_keystore_key'。若 KMS 憑據為純文字模式（直接儲存私鑰的 PEM 內容），則留空此參數。

SinkRocketMQParameters

object

Sink RocketMQ Parameters

InstanceId

object

目标服务类型为消息队列 RocketMQ 版。

Value

string

訊息佇列 RocketMQ 版的執行個體 ID。

MQ_INST_164901546557****_BAAN****

Form

string

轉換的格式。預設為 CONSTANT。

CONSTANT

Template

string

範本樣式。

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

Topic

object

消息队列 RocketMQ 版实例的 Topic。

Value

string

消息队列 RocketMQ 版实例的 Topic 名称。

Mytopic

Form

string

轉換的格式。預設為 CONSTANT。

CONSTANT

Template

string

範本樣式。

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

Body

object

訊息內容。

Value

string

轉換前的值。

{ "key": "value" }

Form

string

轉換的格式。

TEMPLATE

Template

string

範本樣式。

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

Properties

object

过滤属性。

Value

string

轉換前的值。

{ "key": "value" }

Form

string

轉換的格式。

TEMPLATE

Template

string

範本樣式。

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

Keys

object

过滤属性。

Value

string

轉換前的值。

{ "key": "value" }

Form

string

轉換的格式。

TEMPLATE

Template

string

範本樣式。

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

EventBridge：GetEventStreaming

介面說明

調試

授權資訊

請求參數

返回參數

錯誤碼

變更歷史

名稱	類型	必填	描述	樣本值
EventStreamingName	string	是	要取得資訊的事件流的名稱。	myeventstreaming