建立事件流 - 事件匯流排 - 阿里雲 - EventBridge

建立一個事件流。

介面說明

建立一個事件流。

調試

您可以在OpenAPI Explorer中直接運行該介面，免去您計算簽名的困擾。運行成功後，OpenAPI Explorer可以自動產生SDK程式碼範例。

調試

授權資訊

下表是API對應的授權資訊，可以在RAM權限原則語句的Action元素中使用，用來給RAM使用者或RAM角色授予調用此API的許可權。具體說明如下：

操作：是指具體的許可權點。
存取層級：是指每個操作的存取層級，取值為寫入（Write）、讀取（Read）或列出（List）。
資源類型：是指操作中支援授權的資源類型。具體說明如下：
- 對於必選的資源類型，用前面加 * 表示。
- 對於不支援資源級授權的操作，用全部資源表示。
條件關鍵字：是指雲產品自身定義的條件關鍵字。
關聯操作：是指成功執行操作所需要的其他許可權。操作者必須同時具備關聯操作的許可權，操作才能成功。

操作

存取層級

資源類型

條件關鍵字

關聯操作

eventbridge:CreateEventStreaming

create

*EventStreaming

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

無

請求參數

名稱	類型	必填	描述	樣本值
EventStreamingName	string	是	事件流的名稱。	myeventstreaming
Description	string	否	事件流的描述。	rocketmq2mns
FilterPattern	string	否	事件過濾規則，如果不指定表示匹配全部事件。	{ "source": [ { "prefix": "acs:mns" } ], "type": [ { "prefix": "mns:Queue" } ], "subject": [ { "prefix": "acs:mns:cn-hangzhou:123456789098****:queues/zeus" } ] }
Source	object	否	事件提供方。必須選擇一種 Source，且最多只能選擇一種 Source 進行填選。
SourceMNSParameters	object	否	Source MNS 參數。
RegionId	string	否	地域 ID。	cn-beijing
QueueName	string	否	佇列名稱。	queue_api_1642474203601
IsBase64Decode	boolean	否	是否開啟 Base64 編碼。預設為 true。	true
SourceRabbitMQParameters	object	否	Source RabbitMQ 源。
RegionId	string	否	地域 ID。	cn-hangzhou
InstanceId	string	否	訊息佇列 RabbitMQ 版執行個體的執行個體 ID。	gtm-cn-k2c2yfg****
VirtualHostName	string	否	訊息佇列 RabbitMQ 版執行個體的 Vhost 的名稱。	eb-connect
QueueName	string	否	訊息佇列 RabbitMQ 版執行個體的 Queue 的名稱。	demo
SourceKafkaParameters	object	否	Source Kafka 源。
RegionId	string	否	地域 ID。	cn-hangzhou
InstanceId	string	否	執行個體 ID。	r-8vb64581862c****
Topic	string	否	Topic 名稱。	popvip_center_robot_order
ConsumerGroup	string	否	訂閱該 Topic 的消費者所對應的 Group ID。	DEFAULT_GROUP
OffsetReset	string	否	偏移量。	latest
Network	string	否	網路配置。預設值 Default，VPC 網路是 PublicNetwork。	Default
VpcId	string	否	VPC ID。	vpc-8vblalsi0vbhizr77****
VSwitchIds	string	否	虛擬交換機 ID。	vsw-bp179l3llg3jjxwrq72****
SecurityGroupId	string	否	安全性群組 ID。	sg-bp1iv19sp1msc7zot4****
ValueDataType	string	否	訊息體編解碼格式： JSON Text Binary	JSON
SourceRocketMQParameters	object	否	Source RocketMQ 源。
RegionId	string	否	地域 ID。	cn-qingdao
InstanceId	string	否	訊息佇列 RocketMQ 版的執行個體所屬地域。	default_C56C36026****
Topic	string	否	訊息服務的主題。	Topic_publicRule_api_1667273421288
Tag	string	否	訊息的過濾標籤。	test
Offset	string	否	訊息的消費位點。取值說明如下： CONSUME_FROM_LAST_OFFSET：從最新位點開始消費。 CONSUME_FROM_FIRST_OFFSET：從最早位點開始消費。 CONSUME_FROM_TIMESTAMP：從指定時間點的位點開始消費。預設值：CONSUME_FROM_LAST_OFFSET。	CONSUMEFROMLAST_OFFSET
GroupID	string	否	訊息佇列 RocketMQ 版的 Group ID。	GID_group1
Timestamp	integer	否	時間戳記。僅當參數 Offset 取值為 CONSUME_FROM_TIMESTAMP 時，該參數有效。	1670656652009
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
InstanceUsername	string	否	執行個體使用者名稱。	admin
InstancePassword	string	否	執行個體密碼。	admin
Network	string	否	網路類型： PublicNetwork PrivateNetwork 枚舉值： PrivateNetwork : PrivateNetwork PublicNetwork : PublicNetwork	PrivateNetwork
FilterType	string	否	訊息過濾類型。	Tag
FilterSql	string	否	SQL 過濾語句。	index > 10
AuthType	string	否	鑑權類型。	ACL
VpcId	string	否	跨境任務 VPC ID。	vpc-m5e3sv4b12345****
VSwitchIds	string	否	跨境任務 vSwitchIds。	vsw-m5ev8asdc6h12345****
SecurityGroupId	string	否	跨境任務安全性群組。	sg-m5edtu24f12345****
InstanceVpcId	string	否	執行個體 VPC 資訊。	vpc-m5e3sv4b12345****
InstanceVSwitchIds	string	否	執行個體交換機資訊。	vsw-m5ev8asdc6h123456****
InstanceSecurityGroupId	string	否	執行個體安全性群組資訊。	sg-m5edtu24f12345****
InstanceNetwork	string	否	執行個體網路資訊： PublicNetwork PrivateNetwork	PublicNetwork
BodyDataType	string	否	訊息編碼格式： JSON Text Binary	JSON
SourceRocketMQCheckpointParameters	object	否	Source RocketMQ Checkpoint 源。
RegionId	string	否	地域 ID。
InstanceType	string	否	執行個體類型。
InstanceId	string	否	執行個體 ID。
Topics	array	否	訊息 Topic。
	string	否	訊息 Topic。
SourceApacheRocketMQCheckpointParameters	object	否	Source RocketMQ Checkpoint 源。
RegionId	string	否	地域 ID。
Topics	array	否	訊息 Topic。
	string	否	訊息 Topic。
InstanceEndpoint	string	否	執行個體接入點。
InstanceUsername	string	否	執行個體使用者名稱。
InstancePassword	string	否	執行個體密碼。
NetworkType	string	否	網路類型。
VpcId	string	否	VPC ID。
VSwitchId	string	否	虛擬交換機 ID。
SecurityGroupId	string	否	安全性群組 ID。
SourceMQTTParameters	object	否	Source MQTT 源。
RegionId	string	否	地域 ID。	cn-shenzhen
InstanceId	string	否	執行個體 ID。	r-bp1b5ncun5lqer****
Topic	string	否	訊息的 Topic。	CANAL_VICUTU_UAT
BodyDataType	string	否	訊息編碼格式： JSON Text Binary	JSON
NetworkType	string	否
VpcId	string	否
VSwitchIds	string	否
SecurityGroupId	string	否
SourceDTSParameters	object	否	Source DTS 源。
TaskId	string	否	任務 ID。	f86e5814-b223-482c-b768-3b873297****
BrokerUrl	string	否	資料訂閱通道的網路位址及連接埠號資訊。
Topic	string	否	資料訂閱通道的訂閱 Topic。	LTC_CACHE_PRD
Sid	string	否	消費組 ID。	HD3
Username	string	否	消費組的帳號。	admin
Password	string	否	消費組的帳號密碼。	admin
InitCheckPoint	integer	否	消費位點，即 SDK 用戶端消費第一筆資料的時間戳記，格式為 Unix 時間戳記。	1620962769
SourceSLSParameters	object	否	Source SLS 源。
Project	string	否	日誌服務 SLS 的日誌專案。	test
LogStore	string	否	日誌服務 SLS 的日誌庫。	sas-log
ConsumePosition	string	否	起始消費位點，可以選擇最早或最新位點，分別對應「begin」、「end」，也可以從指定時間開始消費，以秒為單位。	end
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	否
ExternalLabels	string	否
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"
WorkerParameters	object	否	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	否	連接器參數。
Name	string	否	連接器名稱。	test-name
Config	object	否	連接器配置。	{ "connector.class": "com.mongodb.kafka.connect.MongoSinkConnector", "tasks.max": "1", "topics": "sourceA,sourceB" }
SourceApacheKafkaParameters	object	否	開源 Kafka 參數配置。
Bootstraps	string	否	接入點。
Topic	string	否	主題名稱。
ConsumerGroup	string	否	消費者名稱。
OffsetReset	string	否	消費位點 latest 使用該配置系統將從最新位點開始讀取資料 earliest 使用該配置系統將從最早位點開始讀取資料，該配置僅支援未使用的 Group 首次初始化
ValueDataType	string	否	資料類型，列舉值： Text Binary Json。
VpcId	string	否	Kafka 源的 VPC ID。
VSwitchIds	string	否	Kafka 源的交換機 ID 列表。
SecurityGroupId	string	否	Kafka 源的安全性群組 ID。
NetworkType	string	否	指定 Kafka 網路類型。
SecurityProtocol	string	否	Kafka 安全協議類型 SASL_SSL PLAINTEXT SASL_PLAINTEXT。
SaslMechanism	string	否	Kafka SASL 認證機制。
SaslUser	string	否	Kafka SASL 認證使用者名稱。
SaslPassword	string	否	Kafka SASL 認證密碼。
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 認證無關。
SslTruststoreCertificates	string	否	【SSL 場景必填】Kafka 伺服器端信任憑證。用於驗證 Kafka Broker 的 SSL 憑證合法性，防止中間人攻擊。格式要求：Base64 編碼的 PEM 格式，通常包含 Kafka 伺服器端的 CA 憑證或伺服器端憑證本身。示例：將 CA 憑證的 PEM 檔案內容（確保開頭和結尾分別是 '-----BEGIN CERTIFICATE-----' 和 '-----END CERTIFICATE-----'），進行 Base64 編碼。若 Kafka 使用自簽名憑證，需提供簽發該憑證的 CA 憑證。
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 : single element : element	single
LoadFormat	string	否	檔案載入器。枚舉值： TextLoader : TextLoader	TextLoader
Delimiter	string	否	分隔符，在分塊載入模式下，以該分隔符作為文字的分塊識別符，預設以換行符 \n 作為分隔符。	\n
SourceOpenSourceRabbitMQParameters	object	否
Endpoint	string	否
VirtualHostName	string	否
QueueName	string	否
BodyDataType	string	否
Username	string	否
Password	string	否
VpcId	string	否
VSwitchIds	string	否
SecurityGroupId	string	否
NetworkType	string	否
AuthType	string	否
SourceEventBusParameters	object	否
EventBusName	string	否
EventRuleName	string	否
SourceMySQLParameters	SourceMySQLParameters	否
SourcePostgreSQLParameters	SourcePostgreSQLParameters	否
SourceRabbitMQMetaParameters	SourceRabbitMQMetaParameters	否
SourceRabbitMQMsgSyncParameters	SourceRabbitMQMsgSyncParameters	否
SourceFeiShuDocsParameters	SourceFeiShuDocsParameters	否
Metadata	string	否
Sink	object	否	事件目標。必須選擇一種 Sink，且最多只能選擇一種 Sink 進行填選。
SinkMNSParameters	object	否	MNS 事件目標。
QueueName	object	否	目標服務類型為訊息服務 MNS。
Value	string	否	訊息服務 MNS 的 Queue 的名稱。	MyQueue
Form	string	否	轉換的格式。預設為 CONSTANT。枚舉值： CONSTANT : CONSTANT	CONSTANT
Template	string	否	範本樣式。	The value of ${key} is ${value}!
Body	object	否	訊息內容。
Value	string	否	轉換前的值。	{ "key": "value" }
Form	string	否	轉換的格式。枚舉值： JSONPATH : JSONPATH CONSTANT : CONSTANT TEMPLATE : TEMPLATE	TEMPLATE
Template	string	否	範本樣式。	The value of ${key} is ${value}!
IsBase64Encode	object	否	是否開啟 Base64 編碼。
Value	string	否	開啟 Base64 編碼。	true
Form	string	否	事件轉換的格式。預設為 CONSTANT。枚舉值： CONSTANT : CONSTANT	CONSTANT
Template	string	否	範本樣式。	The value of ${key} is ${value}!
SinkEventHouseParameters	object	否	事件目標名稱。
CatalogName	string	否	catalog 名稱。	demo
NamespaceName	string	否	目標表的命名空間。	name1
EventTableName	string	否	目標表的名稱。	demo-table
MappingRules	array<object>	否	欄位映射規則。
	array<object>	否	欄位映射規則。
ColumnValue	object	否	列值的擷取規則。
Value	string	否	擷取路徑，如 $.data.value.name [_single.params.Sink.props.SinkEventH	$.data.value
Form	string	否	转换的方式，如 JSONPATH	JSONPATH
Template	string	否	模板配置	The value of ${key} is ${value}!
ColumnName	string	否	列名称	age
ColumnType	string	否	列的类型	text
SinkRabbitMQParameters	object	否	Sink Rabbitmq 的参数。
InstanceId	object	否	目标服务类型为消息队列 RabbitMQ 版。
Value	string	否	消息队列 RabbitMQ 版的实例 ID。	a5ff91ad4f3f24947887fe184fc2****
Form	string	否	轉換的格式。預設為 CONSTANT。枚舉值： CONSTANT : CONSTANT	CONSTANT
Template	string	否	範本樣式。	The value of ${key} is ${value}!
VirtualHostName	object	否	訊息佇列 RabbitMQ 版執行個體的 Vhost 的名稱。
Value	string	否	訊息佇列 RabbitMQ 版執行個體的 Vhost 的名稱。	rabbit-host
Form	string	否	轉換的格式。預設為 CONSTANT。枚舉值： CONSTANT : 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 时，需配置此参数。
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}!
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}!
Topic	object	否	主题名称。
Value	string	否	主题的名称。	test
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	否	模板
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}!
Value	object	否	消息体。
Value	string	否	轉換前的值。	{ "key": "value" }
Form	string	否	轉換的格式。	TEMPLATE
Template	string	否	範本樣式。	The value of ${key} is ${value}!
Headers	object	否
Value	string	否
Form	string	否
Template	string	否
CompressionType	string	否
SinkApacheKafkaParameters	object	否	描述信息
Bootstraps	string	否	Kafka 集群的初始连接地址
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	string	否
Acks	string	否
Key	object	否
Value	string	否
Form	string	否
Template	string	否
Value	object	否
Value	string	否
Form	string	否
Template	string	否
Headers	object	否
Value	string	否
Form	string	否
Template	string	否
SecurityProtocol	string	否
SaslMechanism	string	否
SaslUser	string	否
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 認證無關。
SslTruststoreCertificates	string	否	【SSL 場景必填】Kafka 伺服器端信任憑證。用於驗證 Kafka Broker 的 SSL 憑證合法性，防止中間人攻擊。格式要求：Base64 編碼的 PEM 格式，通常包含 Kafka 伺服器端的 CA 憑證或伺服器端憑證本身。示例：將 CA 憑證的 PEM 檔案內容（確保開頭和結尾分別是 '-----BEGIN CERTIFICATE-----' 和 '-----END CERTIFICATE-----'），進行 Base64 編碼。若 Kafka 使用自簽名憑證，需提供簽發該憑證的 CA 憑證。
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 內容），則留空此參數。
CompressionType	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	否
SinkFcParameters	object	否	函数目标。
ServiceName	object	否	服务名。
Value	string	否	服务名。	myService
Form	string	否	轉換的格式。預設為 CONSTANT。枚舉值： CONSTANT : CONSTANT	CONSTANT
Template	string	否	範本樣式。	The value of ${key} is ${value}!
FunctionName	object	否	函数名。
Value	string	否	函数名。	myFunction
Form	string	否	轉換的格式。預設為 CONSTANT。枚舉值： CONSTANT : CONSTANT	CONSTANT
Template	string	否	範本樣式。	The value of ${key} is ${value}!
Concurrency	object	否	投递并发度，最小 1。
Value	string	否	投递并发度，最小 1。	1
Form	string	否	轉換的格式。預設為 CONSTANT。枚舉值： CONSTANT : CONSTANT	CONSTANT
Template	string	否	範本樣式。	The value of ${key} is ${value}!
Qualifier	object	否	服务版本。
Value	string	否	服务版本。	LATEST
Form	string	否	轉換的格式。預設為 CONSTANT。枚舉值： CONSTANT : CONSTANT	CONSTANT
Template	string	否	範本樣式。	The value of ${key} is ${value}!
InvocationType	object	否	同步或则异步。 Sync：同步。 Async：异步。
Value	string	否	同步或则异步。 Sync：同步。 Async：异步。枚舉值： Async : Async Sync : Sync	Async
Form	string	否	轉換的格式。預設為 CONSTANT。枚舉值： CONSTANT : 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 枚舉值： JSONPATH : JSONPATH CONSTANT : CONSTANT ORIGINAL : ORIGINAL TEMPLATE : TEMPLATE	TEMPLATE
Template	string	否	範本樣式。	The value of ${key} is ${value}!
DataFormat	object	否
Value	string	否
Form	string	否
Template	string	否
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}!
Tags	object	否	过滤属性。
Value	string	否	轉換前的值。	{ "key": "value" }
Form	string	否	轉換的格式。	TEMPLATE
Template	string	否	範本樣式。	The value of ${key} is ${value}!
InstanceType	object	否	執行個體類型。
Value	string	否	執行個體類型。取值說明如下： Cloud_4：阿里雲 RocketMQ 4.0 版本執行個體（預設選項） Cloud_5：阿里雲 RocketMQ 5.0 版本執行個體 SelfBuilt：自建 Apache RocketMQ 叢集	Cloud_4
Form	string	否	轉換的格式。預設為 CONSTANT。	CONSTANT
Template	string	否	无
InstanceEndpoint	object	否	執行個體接入點。
Value	string	否	執行個體接入點。	vbr-8vbsvkkbpf3vb0zef****
Form	string	否	轉換的格式。預設為 CONSTANT。	CONSTANT
Template	string	否	无
InstanceUsername	object	否	執行個體使用者名稱。
Value	string	否	執行個體使用者名稱。	admin
Form	string	否	轉換的格式。預設為 CONSTANT。	CONSTANT
Template	string	否	无
InstancePassword	object	否	執行個體密碼。
Value	string	否	執行個體密碼。	admin
Form	string	否	轉換的格式。預設為 CONSTANT。	CONSTANT
Template	string	否	无
VpcId	object	否	VPC 的 ID。
Value	string	否	VPC 的 ID。	vbr-8vb835n3zf9shwlvb****
Form	string	否	事件轉換的格式。預設為 CONSTANT。	CONSTANT
Template	string	否	无
VSwitchIds	object	否	交换机 ID。
Value	string	否	交换机 ID。	vbr-8vb835n3zf9shwl****mp
Form	string	否	轉換的格式。預設為 CONSTANT。	CONSTANT
Template	string	否	无
SecurityGroupId	object	否	安全性群組 ID。
Value	string	否	安全性群組 ID。	b4bf375515f6440f942e3a20c33d****
Form	string	否	轉換的格式。預設為 CONSTANT。	CONSTANT
Template	string	否	无
Network	object	否	网络类型： PublicNetwork PrivateNetwork
Value	string	否	网络类型： PublicNetwork PrivateNetwork	PublicNetwork
Form	string	否	轉換的格式。預設為 CONSTANT。	CONSTANT
Template	string	否	无
DeliveryOrderType	object	否
Value	string	否
Form	string	否
Template	string	否
ShardingKey	object	否
Value	string	否
Form	string	否
Template	string	否
SinkDorisParameters	object	否	事件源类型
QueryEndpoint	object	否
Value	string	否
Form	string	否
Template	string	否
FeHttpEndpoint	object	否
Value	string	否
Form	string	否
Template	string	否
BeHttpEndpoint	object	否
Value	string	否
Form	string	否
Template	string	否
UserName	object	否
Value	string	否
Form	string	否
Template	string	否
Password	object	否
Value	string	否
Form	string	否
Template	string	否
Database	object	否
Value	string	否
Form	string	否
Template	string	否
Table	object	否
Value	string	否
Form	string	否
Template	string	否
Body	object	否
Value	string	否
Form	string	否
Template	string	否
NetworkType	object	否
Value	string	否
Form	string	否
Template	string	否
VpcId	object	否
Value	string	否
Form	string	否
Template	string	否
VSwitchIds	object	否
Value	string	否
Form	string	否
Template	string	否
SecurityGroupId	object	否
Value	string	否
Form	string	否
Template	string	否
SinkRocketMQCheckpointParameters	object	否	事件源类型
InstanceType	string	否
InstanceId	string	否
Topic	object	否
Value	string	否
Form	string	否
Template	string	否
ConsumeTimestamp	object	否
Value	string	否
Form	string	否
Template	string	否
Group	object	否
Value	string	否
Form	string	否
Template	string	否
SinkApacheRocketMQCheckpointParameters	object	否	事件源类型
Topic	object	否
Value	string	否
Form	string	否
Template	string	否
ConsumeTimestamp	object	否
Value	string	否
Form	string	否
Template	string	否
Group	object	否
Value	string	否
Form	string	否
Template	string	否
InstanceEndpoint	string	否
InstanceUsername	string	否
InstancePassword	string	否
NetworkType	string	否
VpcId	string	否
VSwitchId	string	否
SecurityGroupId	string	否
SinkSLSParameters	object	否	Sink SLS Parameters
Project	object	否	日誌服務 SLS 的日誌專案。
Value	string	否	日誌服務 SLS 的日誌專案。	test-project
Form	string	否	轉換的格式。預設為 CONSTANT。	CONSTANT
Template	string	否	无
LogStore	object	否	日誌服務 SLS 的日誌庫。
Value	string	否	日誌服務 SLS 的日誌庫。	test-logstore
Form	string	否	轉換的格式。預設為 CONSTANT。	CONSTANT
Template	string	否	无
Topic	object	否	日志所在的 Topic，对应 SLS 保留字段“topic”。
Value	string	否	日志所在的 Topic，对应 SLS 保留字段“topic”。	testTopic
Form	string	否	轉換的格式。預設為 CONSTANT。	CONSTANT
Template	string	否	无
Body	object	否	发送给 SLS 的内容。
Value	string	否	轉換前的值。	{ "key": "value" }
Form	string	否	轉換的格式。	TEMPLATE
Template	string	否	範本樣式。	The value of ${key} is ${value}!
RoleName	object	否	授權事件匯流排 EventBridge 使用此角色讀取 SLS 日誌內容時，需滿足條件：在 RAM 主控台建立服務所使用的角色時，需要選擇「阿里雲服務」，並且「受信服務」需要選擇「事件匯流排」。
Value	string	否	授權事件匯流排 EventBridge 使用此角色讀取 SLS 日誌內容時，需滿足條件：在 RAM 主控台建立服務所使用的角色時，需要選擇「阿里雲服務」，並且「受信服務」需要選擇「事件匯流排」。	testRole
Form	string	否	轉換的格式。預設為 CONSTANT。	CONSTANT
Template	string	否	无
ContentType	object	否	SLS 数据格式。可选择默认或者配置制定的键值： JSON KeyValue
Value	string	否	轉換前的值。	JSON
Form	string	否	轉換的格式。	CONSTANT
Template	string	否	範本樣式。
ContentSchema	object	否	自定义日志的键值，仅在 ContentType 为 KeyValue 生效。每一对键值由 Key_n，Value_n 表示。
Value	string	否	轉換前的值。	{"Key_1":{"form":"CONSTANT","value":"demoKey"},"Value_1":{"form":"JSONPATH","value":"$.data.value"}}
Form	string	否	範本樣式。	CONSTANT
Template	string	否	範本樣式。
SinkDataHubParameters	object	否	Sink DataHub 参数。
Project	object	否	DataHub 项目名。
Value	string	否	DataHub 项目名。	demo-project
Form	string	否	轉換的格式。預設為 CONSTANT。	CONSTANT
Template	string	否	无
Topic	object	否	DataHub Topic 名称。
Value	string	否	DataHub Topic 名称。	demo-topic
Form	string	否	轉換的格式。預設為 CONSTANT。	CONSTANT
Template	string	否	无
TopicType	object	否	topic 类型： TUPLE BLOB
Value	string	否	topic 类型： TUPLE BLOB	TUPLE
Form	string	否	轉換的格式。預設為 CONSTANT。	CONSTANT
Template	string	否	无
TopicSchema	object	否	TUBLE 类型，topic 内容模式。
Value	string	否	TUBLE 类型，topic 内容模式。	{"k1":"value1","k2":"value2"}
Form	string	否	轉換的格式。	TEMPLATE
Template	string	否	範本樣式。	{"k1":"${k1}","k2":"${k2}"}
Body	object	否	BLOB 类型，Record 内容模板。
Value	string	否	BLOB 类型，Record 内容模板。
Form	string	否	轉換的格式。	ORIGINAL
Template	string	否	无
RoleName	object	否	任务角色名。
Value	string	否	任务角色名称。	test-role
Form	string	否	轉換的格式。預設為 CONSTANT。	CONSTANT
Template	string	否	无
SinkFnfParameters	object	否	Sink Fnf 参数。
FlowName	object	否	流程名称。
Value	string	否	流程名称。	test-streaming-fnf
Form	string	否	轉換的格式。預設為 CONSTANT。枚舉值： CONSTANT : CONSTANT	CONSTANT
Template	string	否	範本樣式。
ExecutionName	object	否	执行名称。
Value	string	否	执行名称。	123
Form	string	否	转换的格式。默认为 CONSTANT JSONPATH：部分事件 CONSTANT：常量 TEMPLATE：模板详细参考：https://www.alibabacloud.com/help/zh-TW/eventbridge/user-guide/event-transformation 枚舉值： JSONPATH : JSONPATH CONSTANT : CONSTANT TEMPLATE : TEMPLATE	CONSTANT
Template	string	否	範本樣式。
Input	object	否	执行输入信息。
Value	string	否	执行输入信息。	123
Form	string	否	转换的格式： ORIGINAL：完整事件 JSONPATH：部分事件 CONSTANT：常量 TEMPLATE：模板详细参考：https://www.alibabacloud.com/help/zh-TW/eventbridge/user-guide/event-transformation 枚舉值： JSONPATH : JSONPATH CONSTANT : CONSTANT ORIGINAL : ORIGINAL TEMPLATE : TEMPLATE	CONSTANT
Template	string	否	範本樣式。
RoleName	object	否	角色配置。
Value	string	否	角色配置。	Al**FNF-x**
Form	string	否	轉換的格式。預設為 CONSTANT。枚舉值： CONSTANT : CONSTANT	CONSTANT
Template	string	否	範本樣式。
SinkPrometheusParameters	object	否	Sink Prometheus 参数。
URL	object	否	Prometheus Remote Write URL 地址。
Value	string	否	Prometheus Remote Write URL 地址。	https://cn-hangzhou.arms.aliyuncs.com/prometheus/167275**/c5b7faeb2e8994641***d5c559f/cn-hangzhou/api/v3/write
Form	string	否	轉換的格式。預設為 CONSTANT。枚舉值： CONSTANT : CONSTANT	CONSTANT
Template	string	否	模板样式（Form 为 CONSTANT 时为空）。
HeaderParameters	object	否	请求头的参数数据结构。
Value	string	否	Form 为 CONSTANT：常量值 Form 为 JSONPATH：JSONPath 提取内容 Form 为 TEMPLATE：模板变量注：Value 字段不允许超过 10240 个字符	name
Form	string	否	轉換的格式。枚舉值： JSONPATH : JSONPATH CONSTANT : CONSTANT TEMPLATE : TEMPLATE	TEMPLATE
Template	string	否	HTTP 请求头模板样式，当 Form 是 TEMPLATE 时填写，事件内容转换后结果必须是 JSON 格式。	{ "user_name":"${name}" }
AuthorizationType	object	否	鉴权方式。
Value	string	否	鉴权方式。枚舉值： BASIC_AUTH : BASIC_AUTH	BASIC_AUTH
Form	string	否	轉換的格式。預設為 CONSTANT。枚舉值： CONSTANT : CONSTANT	CONSTANT
Template	string	否	无
Username	object	否	用户名。
Value	string	否	用户名。	****admin
Form	string	否	轉換的格式。預設為 CONSTANT。	CONSTANT
Template	string	否	无
Password	object	否	密码。
Value	string	否	密码。	*****
Form	string	否	轉換的格式。預設為 CONSTANT。枚舉值： CONSTANT : CONSTANT	CONSTANT
Template	string	否	无
Data	object	否	指标内容。
Value	string	否	指标内容。	$.data
Form	string	否	转换的格式。默认为 JSAONPATH。	JSAONPATH
Template	string	否	範本樣式。
NetworkType	object	否	網路類型。
Value	string	否	網路類型。枚舉值： PrivateNetwork : PrivateNetwork PublicNetwork : PublicNetwork	PrivateNetwork
Form	string	否	轉換的格式。預設為 CONSTANT。枚舉值： CONSTANT : CONSTANT	CONSTANT
Template	string	否	无
VpcId	object	否	VPC 的 ID。
Value	string	否	VPC 的 ID。	i-2ze7u5i17mbqtx1p****
Form	string	否	轉換的格式。預設為 CONSTANT。枚舉值： CONSTANT : CONSTANT	CONSTANT
Template	string	否	无
VSwitchId	object	否	交换机 ID。
Value	string	否	交换机 ID。	vsw-dwaafds****
Form	string	否	轉換的格式。預設為 CONSTANT。枚舉值： CONSTANT : CONSTANT	CONSTANT
Template	string	否	无
SecurityGroupId	object	否	安全性群組 ID。
Value	string	否	安全性群組 ID。	sg-mw43*****
Form	string	否	轉換的格式。預設為 CONSTANT。枚舉值： CONSTANT : CONSTANT	CONSTANT
Template	string	否	无
SinkCustomizedKafkaParameters	object	否	Sink Kafka 参数。
InstanceId	string	否	訊息佇列 Kafka 版的執行個體 ID。	90be1f96-4229-4535-bb76-34b4f6fb2b71
SinkCustomizedKafkaConnectorParameters	object	否	Sink Kafka 连接器参数。
ConnectorPackageUrl	string	否	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	否	解析当前 ZIP 包下的 properties 文件。
Name	string	否	連接器名稱。	mongo-sink
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" }
SinkDashVectorParameters	object	否	Sink DashVector 参数。
InstanceId	string	否	執行個體 ID。	vrs-cn-lbj3ru1***
Collection	string	否	Collection（集合）名称。	collection1
ApiKey	string	否	DashVecotor 控制台创建的 API Key。	Q34nExQH7sQ****
Operation	string	否	DashVector 数据库操作类型。枚舉值： Delete : Delete Upsert : Upsert	Upsert
Network	string	否	網路類型。枚舉值： PrivateNetwork : PrivateNetwork PublicNetwork : PublicNetwork	PublicNetwork
PrimaryKeyId	object	否	插入/删除记录时的主键 ID。說明不填写此字段时，表示使用随机主键 ID。
Form	string	否	轉換的格式。枚舉值： JSONPATH : JSONPATH TEMPLATE : TEMPLATE	JSONPATH
Value	string	否	Form 为 JSONPATH：JSONPath 提取内容 Form 为 TEMPLATE：模板变量說明 Value 字段不允许超过 10240 个字符。	$.data.requestId
Template	string	否	主键 ID 模板，仅当 Form 是 TEMPLATE 时需要填写。	${ID}
Partition	object	否	Partition（分区），默认值为 default 分区。
Form	string	否	轉換的格式。枚舉值： JSONPATH : JSONPATH CONSTANT : CONSTANT	CONSTANT
Value	string	否	Form 为 CONSTANT：常量值 Form 为 JSONPATH：JSONPath 提取内容說明 Value 字段不允许超过 10240 个字符。	default
Template	string	否	无	${partition}
Vector	object	否	插入 DashVector 记录的向量。
Form	string	否	轉換的格式。枚舉值： JSONPATH : JSONPATH	JSONPATH
Value	string	否	JSONPath 提取内容。說明 Value 字段不允许超过 10240 个字符。	$.data.messageBody
Template	string	否	无	${vector}
DashVectorSchemaParameters	array<object>	否	插入 DashVector 时表项的 Schema 字段定义，事件内容转换后结果必须是 JSON 格式。
	array<object>	否	属性列
Name	object	否	属性名
Form	string	否	Form	CONSTANT
Value	string	否	Value	content
Template	string	否	Template
Type	object	否	DashVector 属性类型
Form	string	否	Form	CONSTANT
Value	string	否	Value	STRING
Template	string	否	Template
Value	object	否	属性值
Form	string	否	Form	JSONPATH
Value	string	否	Value	$.data.content
Template	string	否	Template	${content}
SinkOpenSourceRabbitMQParameters	object	否
Endpoint	string	否
VirtualHostName	string	否
TargetType	string	否
Exchange	string	否
QueueName	string	否
Username	string	否
Password	string	否
VpcId	string	否
VSwitchIds	string	否
SecurityGroupId	string	否
NetworkType	string	否
AuthType	string	否
RoutingKey	object	否
Form	string	否
Value	string	否
Template	string	否
Body	object	否
Form	string	否
Value	string	否
Template	string	否
MessageId	object	否
Form	string	否
Value	string	否
Template	string	否
Properties	object	否
Form	string	否
Value	string	否
Template	string	否
SinkBaiLianParameters	SinkBaiLianParameters	否
SinkDataWorksTriggerParameters	SinkDataWorksTriggerParameters	否
SinkHttpsParameters	SinkHttpsParameters	否
SinkApiDestinationParameters	SinkApiDestinationParameters	否
SinkOSSParameters	SinkOSSParameters	否
SinkRabbitMQMetaParameters	SinkRabbitMQMetaParameters	否
SinkRabbitMQMsgSyncParameters	SinkRabbitMQMsgSyncParameters	否
SinkMQTTParameters	SinkMQTTParameters	否
SinkAgentRunParameters	SinkAgentRunParameters	否
RunOptions	object	否	运行环境参数。
MaximumTasks	integer	否	并发数。	2
ErrorsTolerance	string	否	异常容忍策略： NONE：不容忍异常。 ALL：容忍所有异常。	ALL
RetryStrategy	object	否	事件推送失败时的重试策略。
PushRetryStrategy	string	否	重试策略： BACKOFF_RETRY：退避重试。 EXPONENTIAL_DECAY_RETRY：指数衰减重试。	BACKOFF_RETRY
MaximumEventAgeInSeconds	integer	否	最大重试时间。	512
MaximumRetryAttempts	integer	否	最大重试次数。	2
DeadLetterQueue	object	否	是否启用死信队列。默认不启用死信队列，超过重试策略后的消息将被丢弃。
Arn	string	否	死信队列 ARN。	acs:ram::131733464781****:role/rdstoecsassumekms
Network	string	否
VpcId	string	否
VSwitchIds	string	否
SecurityGroupId	string	否
BatchWindow	object	否	攒批窗口。
CountBasedWindow	integer	否	窗口中最大可容纳的事件数量。当达到此阈值，会触发窗口内的数据往下游推送。当存在多个窗口时，有一个窗口满足即触发。	100
TimeBasedWindow	integer	否	窗口中最大可容纳的时间范围内的事件（单位秒）。当达到此阈值，会触发窗口内的数据往下游推送。当存在多个窗口时，有一个窗口满足即触发。	10
BusinessOption	object	否
BusinessMode	string	否
MinCapacityUnitCount	integer	否
MaxCapacityUnitCount	integer	否
Throttling	integer	否
Transforms	array<object>	否	Transform 相关配置。
	object	否	云产品的 ARN，比如函数计算中函数的 ARN。
Arn	string	否	云产品的 ARN，比如函数计算中函数的 ARN。	acs:fc:cn-hangzhou:*****:services/demo-service.LATEST/functions/demo-func
DashScopeTransformParameters	DashScopeTransformParameters	否
BaiLianAgentTransformParameters	BaiLianAgentTransformParameters	否
EmbeddingTransformParameters	EmbeddingTransformParameters	否
Tags	array<object>	否	标签列表，最多包含 20 个子项
	object	否
Key	string	否	标签键
Value	string	否	标签值

返回參數

名稱	類型	描述	樣本值
	object	请求参数。
Message	string	错误信息。	The name [xxxx] of event streaming in request is already exist!
RequestId	string	请求 ID。	B896B484-F16D-59DE-9E23-DD0E5C36****
Data	object	返回数据。
EventStreamingARN	string	事件流在阿里云上的统一资源标识（ARN）。	acs:eventbridge:cn-hangzhou:164901546557****:eventstreaming/myeventstreaming
Code	string	接口返回码： Success：表示成功。其它：表示错误码。错误码详情，请参见错误码。	Success
Success	boolean	操作成功返回 true。	true

樣本

正常返回樣本

JSON格式

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

錯誤碼

HTTP status code	錯誤碼	錯誤資訊	描述
403	ServiceNotEnable	Service not enable

訪問錯誤中心查看更多錯誤碼。

變更歷史

更多資訊，參考變更詳情。