全部產品
Search
文件中心

EventBridge:UpdateEventStreaming

更新時間:Jun 28, 2026

修改一個事件流的基礎資訊、事件來源資訊、事件過濾模式或事件目標資訊。

介面說明

修改一個事件流的基礎資訊、事件來源資訊、事件過濾模式或事件目標資訊。

調試

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

調試

授權資訊

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

  • 操作:是指具體的許可權點。

  • 存取層級:是指每個操作的存取層級,取值為寫入(Write)、讀取(Read)或列出(List)。

  • 資源類型:是指操作中支援授權的資源類型。具體說明如下:

    • 對於必選的資源類型,用前面加 * 表示。

    • 對於不支援資源級授權的操作,用全部資源表示。

  • 條件關鍵字:是指雲產品自身定義的條件關鍵字。

  • 關聯操作:是指成功執行操作所需要的其他許可權。操作者必須同時具備關聯操作的許可權,操作才能成功。

操作

存取層級

資源類型

條件關鍵字

關聯操作

eventbridge:UpdateEventStreaming

update

*EventStreaming

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

請求參數

名稱

類型

必填

描述

樣本值

EventStreamingName

string

事件流的名稱。

myeventstreaming

Description

string

事件流的描述。

rocketmq2mns

FilterPattern

string

事件過濾規則,如果不指定表示匹配全部事件。具體資訊,請參見https://www.alibabacloud.com/help/zh-TW/eventbridge/user-guide/event-patterns

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

QueueName

string

佇列名稱。

queue_api_1642474203601

IsBase64Decode

boolean

是否開啟 Base64 編碼。預設為 true。

true

SourceRabbitMQParameters

object

Source RabbitMQ 來源。

RegionId

string

地域 ID。

cn-hangzhou

InstanceId

string

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

i-f8z9lqkldlb4oxsxwwub

VirtualHostName

string

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

eb-connect

QueueName

string

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

demo

SourceKafkaParameters

object

Source Kafka 來源。

RegionId

string

地域 ID。

cn-zhangjiakou

InstanceId

string

執行個體 ID。

i-8vbh4a5b9yfhgkkzm****

Topic

string

Topic 名稱。

topic_empower_1641539400786

ConsumerGroup

string

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

DEFAULT_GROUP

OffsetReset

string

偏移量。

latest

Network

string

網路配置:預設值 Default,vpc 網路是 PublicNetwork。

Default

VpcId

string

專有網路 VPC 的 ID。

vpc-2ze6p0o345nykmekxt****

VSwitchIds

string

交換器 ID。

vsw-wz9t1l1e8eu2om****

SecurityGroupId

string

安全性群組 ID。

sg-uf6jcm3y5hcs7hkl****

ValueDataType

string

編解碼參數列舉值,有 3 個列舉值,命名如下 a. Json:現有邏輯,bytes 按 utf8 解碼成字串,解析為 json b. Text:bytes 按 utf8 解碼成字串,直接放入 payload c. Binary:bytes 按 base64 編碼成字串,放入 payload。

Text

SourceRocketMQParameters

object

Source RocketMQ 來源。

RegionId

string

訊息佇列 RocketMQ 版的地域 ID。

cn-shanghai

InstanceId

string

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

i-f8z9a9mcgwri1c1id****

Topic

string

topic 名稱。

TOPIC-cainiao-pcs-order-process-inBoundConditionCheck

Tag

string

訊息的過濾標籤。

test

Offset

string

訊息的消費位點。取值說明如下:

  • CONSUMEFROMLASTOFFSET:從最新位點開始消費。

  • CONSUMEFROMFIRSTOFFSET:從最早位點開始消費。

  • CONSUMEFROMTIMESTAMP:從指定時間點的位點開始消費。

預設值:CONSUMEFROMLAST_OFFSET。

CONSUMEFROMLASTOFFSET

GroupID

string

訊息佇列 RocketMQ 版的 Group ID。

GID_test

Timestamp

integer

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

1670656652009

InstanceType

string

執行個體類型。

  • Cloud_4(預設值):阿里雲 RocketMQ 4.0 執行個體

  • Cloud_5:阿里雲 RocketMQ 5.0 執行個體

  • SelfBuilt:自建 Apache RocketMQ 執行個體。

Cloud_5

InstanceEndpoint

string

執行個體接入點。

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

InstanceUsername

string

執行個體使用者名稱。

admin

InstancePassword

string

執行個體密碼。

admin

AuthType

string

鑑權類型。

ACL

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

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

Cloud_5

InstanceId

string

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

rmq-cn-jte3w******

Topics

array

訊息佇列 RocketMQ 版執行個體 Topic。

string

訊息佇列 RocketMQ 版執行個體 Topic。

myTopic

SourceApacheRocketMQCheckpointParameters

object

Source RocketMQ Checkpoint 來源。

RegionId

string

地域 ID。

cn-hangzhou

Topics

array

Apache RocketMQ 執行個體 Topic。

string

Apache RocketMQ 執行個體 Topic。

myTopic

InstanceEndpoint

string

Apache RocketMQ 執行個體的接入點。

192.168.1.1:9876

InstanceUsername

string

Apache RocketMQ 執行個體的使用者名稱。

admin

InstancePassword

string

Apache RocketMQ 執行個體的密碼。

****

NetworkType

string

網路類型。

  • PublicNetwork

  • PrivateNetwork。

PrivateNetwork

VpcId

string

VPC ID。

vpc-adw1awdw*****

VSwitchId

string

交換器 ID。

vsw-dwaafds****

SecurityGroupId

string

安全性群組 ID。

sg-mw43*****

SourceMQTTParameters

object

Source MQTT 來源。

RegionId

string

地域 ID。

cn-shanghai

InstanceId

string

執行個體 ID。

i-bp1dsudbecqwt61j****

Topic

string

Topic 名稱。

topic_empower_1642400400779

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。

LTC_CACHE_PRD

Sid

string

消費組 ID。

hkprdb

Username

string

消費組的帳號。

admin

Password

string

消費組的帳號密碼。

admin

InitCheckPoint

integer

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

1620962769

SourceSLSParameters

object

Source SLS 來源。

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

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 內容),則留空此參數。

Topic

string

ConsumerGroup

string

OffsetReset

string

ValueDataType

string

VpcId

string

VSwitchIds

string

SecurityGroupId

string

NetworkType

string

SecurityProtocol

string

SaslMechanism

string

SaslUser

string

SaslPassword

string

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 作為分隔符。

\n

SourceEventBusParameters

object

Source EventBus 來源。

EventBusName

string

事件匯流排名稱。

my-event-bus

EventRuleName

string

事件規則名稱。

my-event-rule

SourceOpenSourceRabbitMQParameters

object

Source Open Source RabbitMQ 來源。

Endpoint

string

執行個體接入點。

192.168.1.1:9876

VirtualHostName

string

開源 RabbitMQ 執行個體的虛擬主機名稱。

Vhost1

QueueName

string

開源 RabbitMQ 執行個體的佇列名稱。

demo

BodyDataType

string

訊息體資料類型。

Json

Username

string

連線開源 RabbitMQ 執行個體時使用的使用者名稱。

admin

Password

string

連線開源 RabbitMQ 執行個體時使用的密碼。

****

VpcId

string

VPC ID。

vpc-m5e3sv4b12345****

VSwitchIds

string

交換器 ID。

vsw-m5ev8asdc6h12345****

SecurityGroupId

string

安全性群組 ID。

sg-m5edtu24f12345****

NetworkType

string

網路類型。

  • PublicNetwork

  • PrivateNetwork。

PrivateNetwork

AuthType

string

鑑權類型。

ACL

SourceMySQLParameters SourceMySQLParameters

Source MySQL 來源。

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

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

無。

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。

$.data.value

Form

string

轉換的方式,如 JSONPATH。

JSONPATH

Template

string

範本配置。

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

ColumnName

string

列名稱。

age

ColumnType

string

列的類型。 [parameters.5.schema

text

SinkFcParameters

object

函数目标。

ServiceName

object

服务的名称。

Value

string

服务的名称。

myService

Form

string

轉換的格式。預設為 CONSTANT。

CONSTANT

Template

string

無。

FunctionName

object

函数名称。

Value

string

函数名称。

mFunction

Form

string

轉換的格式。預設為 CONSTANT。

CONSTANT

Template

string

無。

Concurrency

object

投递并发度,最小 1。

Value

string

投递并发度,最小 1。

1

Form

string

轉換的格式。預設為 CONSTANT。

CONSTANT

Template

string

無。

Qualifier

object

函数所属服务的别名。

Value

string

函数所属服务的别名。

LATEST

Form

string

轉換的格式。預設為 CONSTANT。

CONSTANT

Template

string

無。

InvocationType

object

同步或则异步。 Sync:同步。 Async:异步。

Value

string

调用类型。

Async

Form

string

轉換的格式。預設為 CONSTANT。

CONSTANT

Template

string

無。

Body

object

发送给函数的内容体。

Value

string

轉換前的值。

{ "key": "value" }

Form

string

轉換的格式。

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

SinkRabbitMQParameters

object

Sink Rabbitmq 的参数。

InstanceId

object

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

Value

string

消息队列 RabbitMQ 版的实例 ID。

amqp-cn-2r42e73o****

Form

string

轉換的格式。預設為 CONSTANT。

CONSTANT

Template

string

無。

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

無。

Exchange

object

Exchange 模式。 仅当参数 TargetType 配置为 Exchange 时,需配置此参数。

Value

string

消息队列 RabbitMQ 版实例的 Exchange 的名称。

a_exchange

Form

string

轉換的格式。預設為 CONSTANT。

CONSTANT

Template

string

無。

RoutingKey

object

消息的路由规则。 仅当参数 TargetType 配置为 Exchange 时,需配置此参数。

Value

string

消息的路由规则。

housekeeping

Form

string

轉換的格式。預設為 CONSTANT。

CONSTANT

Template

string

無。

QueueName

object

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

Value

string

实例的 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}!

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

無。

CompressionType

string

Topic

object

主题名称。

Value

string

主题名称。

test

Form

string

轉換的格式。預設為 CONSTANT。

CONSTANT

Template

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

模板

Headers

object

Kafka 消息的附加元数据。

Value

string

轉換前的值。

{ "key": "value" }

Form

string

转换的格式:

  • ORIGINAL:完整事件

  • JSONPATH:部分事件

  • CONSTANT:常量

  • TEMPLATE:模板

CONSTANT

Template

string

範本樣式。

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

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

無。

Key

object

消息的标识。

Value

string

消息的标识。

key

Form

string

轉換的格式。預設為 CONSTANT。

CONSTANT

Template

string

無。

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

Key

object

Value

string

Form

string

Template

string

Value

object

Value

string

Form

string

Template

string

CompressionType

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

Headers

object

Value

string

Form

string

Template

string

SaslPassword

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 內容),則留空此參數。

SinkRocketMQParameters

object

Sink RocketMQ Parameters

InstanceId

object

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

Value

string

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

MQ_INST_164901546557****_BAAN****

Form

string

轉換的格式。預設為 CONSTANT。

CONSTANT

Template

string

無。

Topic

object

消息队列 RocketMQ 版实例的 Topic。

Value

string

消息队列 RocketMQ 版实例的 Topic。

Mytopic

Form

string

轉換的格式。預設為 CONSTANT。

CONSTANT

Template

string

無。

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

投递顺序类型。

  • Orderly: 顺序投递

  • Concurrently: 并发投递

Concurrently

Form

string

转换的格式。默认为 CONSTANT。

CONSTANT

Template

string

範本樣式。

ShardingKey

object

消息的分片健。

說明

DeliveryOrderType 为 Orderly 时,向下游写入消息时 ShardingKey 属性的事件内容转换规则。Source 为 RocketMQ 时,ShardingKey 允许为空,此时使用上游 BrokerName 和 QueueId 拼接得到消息 ShardingKey。

Value

string

分片健值。

order_id

Form

string

转换的格式。默认为 CONSTANT。

CONSTANT

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

Body

object

Value

string

Form

string

Template

string

Table

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

Sink RocketMQ Checkpoint Parameters

InstanceType

string

实例类型。取值说明如下:

  • Cloud_4:阿里云 RocketMQ 4.0 版本实例

  • Cloud_5:阿里云 RocketMQ 5.0 版本实例

Cloud_4

InstanceId

string

執行個體 ID。

MQ_INST_164901546557****_BAAN****

Topic

object

消息队列 RocketMQ 版实例的 Topic。

Value

string

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

Mytopic

Form

string

转换的格式。默认为 CONSTANT。

CONSTANT

Template

string

範本樣式。

ConsumeTimestamp

object

消息消费的时间戳。

Value

string

时间戳。

1570761026400

Form

string

轉換的格式。預設為 CONSTANT。

CONSTANT

Template

string

範本樣式。

Group

object

消费者组的 Group ID。

Value

string

Group ID

GID_EVENTBRIDGE_1736234******

Form

string

轉換的格式。預設為 CONSTANT。

CONSTANT

Template

string

範本樣式。

SinkApacheRocketMQCheckpointParameters

object

Sink Apache RocketMQ Checkpoint Parameters

Topic

object

RocketMQ 实例的 Topic。

Value

string

RocketMQ 实例的 Topic 的名称。

Mytopic

Form

string

轉換的格式。預設為 CONSTANT。

CONSTANT

Template

string

範本樣式。

ConsumeTimestamp

object

消息消费的时间戳。

Value

string

时间戳。

1570761026400

Form

string

轉換的格式。預設為 CONSTANT。

CONSTANT

Template

string

範本樣式。

Group

object

消费者组的 Group ID。

Value

string

Group ID

GID_EVENTBRIDGE_1736234******

Form

string

轉換的格式。預設為 CONSTANT。

CONSTANT

Template

string

範本樣式。

InstanceEndpoint

string

執行個體接入點。

192.168.1.1:9876

InstanceUsername

string

认证需要的用户名。

admin

InstancePassword

string

用户名密码。

****

NetworkType

string

網路類型。

  • PublicNetwork

  • PrivateNetwork。

PrivateNetwork

VpcId

string

专有网络的 ID。

vpc-2zeccak5pb0j3ay******

VSwitchId

string

交換器 ID。

vsw-uf62oqt1twuevrt******

SecurityGroupId

string

安全性群組 ID。

sg-2ze5bmpw6adn0q******

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

SLS 数据格式。

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

範本樣式。

SinkFnfParameters

object

Sink Fnf 参数

FlowName

object

流程名称

Value

string

流程名称

test-streaming-fnf

Form

string

轉換的格式。預設為 CONSTANT。

CONSTANT

Template

string

範本樣式。

ExecutionName

object

执行名称

Value

string

执行名称

123

Form

string

轉換的格式。預設為 CONSTANT。

CONSTANT

Template

string

範本樣式。

Input

object

执行输入信息

Value

string

执行输入信息

123

Form

string

轉換的格式。預設為 CONSTANT。

CONSTANT

Template

string

範本樣式。

RoleName

object

角色配置

Value

string

角色配置

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

Form

string

轉換的格式。預設為 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

Template

string

無。

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

Form

string

轉換的格式。預設為 CONSTANT。

CONSTANT

Template

string

無。

Username

object

用户名

Value

string

用户名

***admin

Form

string

轉換的格式。預設為 CONSTANT。

CONSTANT

Template

string

無。

Password

object

密码

Value

string

密码

abc

Form

string

轉換的格式。預設為 CONSTANT。

CONSTANT

Template

string

無。

Data

object

指标内容

Value

string

指标内容

$.data

Form

string

转换的格式。默认为 JSONPATH。

JSONPATH

Template

string

無。

NetworkType

object

网络类型

Value

string

网络类型:

  • PublicNetwork

  • PrivateNetwork

PrivateNetwork

Form

string

轉換的格式。預設為 CONSTANT。

CONSTANT

Template

string

無。

VpcId

object

VPC ID。

Value

string

VPC ID。

vpc-adw1awdw*****

Form

string

轉換的格式。預設為 CONSTANT。

CONSTANT

Template

string

無。

VSwitchId

object

交换机 Id

Value

string

交换机 Id

vsw-dwaafds****

Form

string

轉換的格式。預設為 CONSTANT。

CONSTANT

Template

string

無。

SecurityGroupId

object

安全性群組 ID。

Value

string

安全性群組 ID。

sg-mw43*****

Form

string

轉換的格式。預設為 CONSTANT。

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

無。

ContentType

object

数据格式。可选择默认或者配置制定的键值:

  • 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

範本樣式。

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

  • Upsert

Upsert

Network

string

网络类型。

  • PrivateNetwork

  • PublicNetwork

PublicNetwork

PrimaryKeyId

object

插入/删除记录时的主键 ID 不填写此字段时,使用随机主键 ID。

Form

string

转换的格式:

  • JSONPATH

  • 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

  • CONSTANT

CONSTANT

Value

string

  • Form 为 CONSTANT:常量值

  • Form 为 JSONPATH:JSONPath 提取内容

說明

Value 字段不允许超过 10240 个字符。

default

Template

string

無。

Vector

object

插入 DashVector 记录的向量。

Form

string

轉換的格式。

JSONPATH

Value

string

JSONPath 提取内容。

說明

Value 字段不允许超过 10240 个字符。

$.data.messageBody

Template

string

無。

DashVectorSchemaParameters

array<object>

插入 DashVector 时表项的 Schema 字段定义,事件内容转换后结果必须是 Json 格式。

array<object>

Name

object

Form

string

Value

string

Template

string

Type

object

Form

string

Value

string

Template

string

Value

object

Form

string

Value

string

Template

string

SinkOpenSourceRabbitMQParameters

object

Sink Open Source RabbitMQ Parameters

Endpoint

string

接入点。

192.168.1.1:9876

VirtualHostName

string

RabbitMQ 的虚拟主机名称。

Vhost1

TargetType

string

消息投递的目标类型。

  • Exchange: 消息通过交换机进行路由。

  • Queue: 消息直接投递到指定队列。

Exchange

Exchange

string

RabbitMQ 中的 Exchange 名称,当 TargetType 设置为 Exchange 时生效。

my-exchange

QueueName

string

RabbitMQ 中的队列名称,仅当 TargetType 设置为 Queue 时生效。

my-queue

Username

string

访问 RabbitMQ 实例的用户名。

admin

Password

string

访问 RabbitMQ 实例的密码。

****

VpcId

string

专有网络 ID。

vpc-uf6of9452b2pba82c ****

VSwitchIds

string

交換器 ID。

vsw-uf6of9452b2pba82c ****

SecurityGroupId

string

安全性群組 ID。

sg-uf6of9452b2pba82c ****

NetworkType

string

网络类型。

  • PrivateNetwork

  • PublicNetwork

PublicNetwork

AuthType

string

认证类型:

  • ACL

  • 无需配置

ACL

RoutingKey

object

消息路由键。

Form

string

转换格式,默认为 CONSTANT。

CONSTANT

Value

string

路由键值。

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

Template

string

範本樣式。

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

Body

object

消息体内容。

Form

string

转换格式,默认为 CONSTANT。

CONSTANT

Value

string

原始数据值。

{"key": "value"}

Template

string

範本樣式。

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

MessageId

object

消息的唯一标识符。

Form

string

转换格式,默认为 CONSTANT。

CONSTANT

Value

string

消息 ID 值。

12345

Template

string

範本樣式。

Properties

object

消息的附加属性。

Form

string

转换格式,默认为 CONSTANT。

CONSTANT

Value

string

属性内容。

{"env": "prod"}

Template

string

範本樣式。

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

SinkBaiLianParameters SinkBaiLianParameters

Sink BaiLian Parameters

SinkDataWorksTriggerParameters SinkDataWorksTriggerParameters

SinkHttpsParameters

SinkHttpsParameters

Https 目标参数

SinkApiDestinationParameters SinkApiDestinationParameters

ApiDestination 目标参数

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

死信队列的网络类型。

  • PrivateNetwork

  • PublicNetwork

PrivateNetwork

VpcId

string

死信队列所在的 VPC 网络 ID。

vpc-2zehizpoendb3****

VSwitchIds

string

死信队列所在的虚拟交换机 ID。

vsw-m5ev8asdc6h12345****

SecurityGroupId

string

死信队列所在实例的安全组 ID。

sg-2vcgdxz7o1n9zapp****

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

返回參數

名稱

類型

描述

樣本值

object

返回信息。

Message

string

错误信息。

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

RequestId

string

阿里云为该请求生成的唯一标识符。

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

Code

string

接口返回码:Success:表示成功。 其它:表示错误码。错误码详情,请参见错误码。

Success

Success

boolean

操作成功返回 true。

true

樣本

正常返回樣本

JSON格式

{
  "Message": "The name [xxxx] of event streaming in request is already exist!",
  "RequestId": "0FDD73AA-7A2D-5BD4-B4C0-88AFEBF5F0F5",
  "Code": "Success",
  "Success": true
}

錯誤碼

HTTP status code

錯誤碼

錯誤資訊

描述

403 ServiceNotEnable Service not enable

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

變更歷史

更多資訊,參考變更詳情