CreateEventStreaming API参考-事件总线-阿里云-事件总线(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 进行填选。
SourceApacheKafkaParameters	object	否	开源 Kafka 参数配置
Bootstraps	string	否	接入点
ConsumerGroup	string	否	消费者名称
NetworkType	string	否	指定 Kafka 网络类型
OffsetReset	string	否	消费位点 latest 使用该配置系统将从最新位点开始读取数据 earliest 使用该配置系统将从最早位点开始读取数据，该配置仅支持未使用的 Group 首次初始化
SaslMechanism	string	否	Kafka SASL 认证机制
SaslPassword	string	否	Kafka SASL 认证密码
SaslUser	string	否	Kafka SASL 认证用户名
SecurityGroupId	string	否	Kafka 源的安全组 ID
SecurityProtocol	string	否	Kafka 安全协议类型 SASL_SSL PLAINTEXT SASL_PLAINTEXT
SslKeyPassword	string	否	【加密私钥必填】Kafka 客户端私钥密码。当客户端私钥使用密码加密保护时（即 PEM 文件中包含 'Proc-Type: 4,ENCRYPTED' 或 'ENCRYPTED' 标记），需提供解密密码。若私钥未加密则留空。注意：此密码仅用于解密私钥，与 Kafka 认证无关
SslKeystoreCertificateChain	string	否	【双向认证必填】Kafka 客户端证书链。当 Kafka 服务端开启双向 SSL 认证（ssl.client.auth=required）时，需提供此参数。格式要求：Base64 编码的 PEM 格式，包含客户端证书及完整的证书链（客户端证书在前，中间 CA 证书在后，根 CA 证书可选）。注意：确保每个 PEM 文件内容的开头和结尾分别是 '-----BEGIN CERTIFICATE-----' 和 '-----END CERTIFICATE-----' ，拼接后进行 Base64 编码
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 内容），则留空此参数
SslTruststoreCertificates	string	否	【SSL 场景必填】Kafka 服务端信任证书。用于验证 Kafka Broker 的 SSL 证书合法性，防止中间人攻击。格式要求：Base64 编码的 PEM 格式，通常包含 Kafka 服务端的 CA 证书或服务端证书本身。示例：将 CA 证书的 PEM 文件内容（确保开头和结尾分别是 '-----BEGIN CERTIFICATE-----' 和 '-----END CERTIFICATE-----' ），进行 Base64 编码。若 Kafka 使用自签名证书，需提供签发该证书的 CA 证书
Topic	string	否	主题名称
VSwitchIds	string	否	Kafka 源的交换机 ID 列表
ValueDataType	string	否	数据类型，枚举值： Text Binary Json
VpcId	string	否	Kafka 源的 VPC ID
SourceApacheRocketMQCheckpointParameters	object	否	Source RocketMQ Checkpoint 源
InstanceEndpoint	string	否	实例接入点。
InstancePassword	string	否	实例密码。
InstanceUsername	string	否	实例用户名。
NetworkType	string	否	网络类型。
RegionId	string	否	地域 ID。
SecurityGroupId	string	否	安全组 ID。
Topics	array	否	消息 Topic。
	string	否	消息 Topic。
VSwitchId	string	否	虚拟交换机 ID。
VpcId	string	否	VPC ID。
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	否	连接器参数。
Config	object	否	连接器配置。	{ "connector.class": "com.mongodb.kafka.connect.MongoSinkConnector", "tasks.max": "1", "topics": "sourceA,sourceB" }
Name	string	否	连接器名称。	test-name
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" }
SourceCustomizedKafkaParameters	object	否	自定义 Kafka 事件源。
InstanceId	string	否	消息队列 Kafka 版的实例 ID。	r-8vb64581862c****
SourceDTSParameters	object	否	Source DTS 源。
BrokerUrl	string	否	数据订阅通道的网络地址及端口号信息。
InitCheckPoint	integer	否	消费位点，即 SDK 客户端消费第一条数据的时间戳，格式为 Unix 时间戳。	1620962769
Password	string	否	消费组的账号密码。	admin
Sid	string	否	消费组 ID。	HD3
TaskId	string	否	任务 id。	f86e5814-b223-482c-b768-3b873297****
Topic	string	否	数据订阅通道的订阅 Topic。	LTC_CACHE_PRD
Username	string	否	消费组的账号。	admin
SourceEventBusParameters	object	否
EventBusName	string	否
EventRuleName	string	否
SourceFeiShuDocsParameters	SourceFeiShuDocsParameters	否
SourceJDBCParameters	SourceJDBCParameters	否
SourceKafkaParameters	object	否	Source Kafka 源。
ConsumerGroup	string	否	订阅该 Topic 的消费者所对应的 Group ID。	DEFAULT_GROUP
InstanceId	string	否	实例 ID。	r-8vb64581862c****
Network	string	否	网络配置。默认值 Default，VPC 网络是 PublicNetwork。	Default
OffsetReset	string	否	偏移量。	latest
RegionId	string	否	地域 ID。	cn-hangzhou
SecurityGroupId	string	否	安全组 ID。	sg-bp1iv19sp1msc7zot4****
Topic	string	否	Topic 名称。	popvip_center_robot_order
VSwitchIds	string	否	虚拟交换机 ID。	vsw-bp179l3llg3jjxwrq72****
ValueDataType	string	否	消息体编解码格式： JSON Text Binary	JSON
VpcId	string	否	VPC ID。	vpc-8vblalsi0vbhizr77****
SourceMNSParameters	object	否	Source MNS 参数。
IsBase64Decode	boolean	否	是否开启 Base64 编码。默认为 true。	true
QueueName	string	否	队列名称。	queue_api_1642474203601
RegionId	string	否	地域 id。	cn-beijing
SourceMQTTParameters	object	否	Source MQTT 源。
BodyDataType	string	否	消息编码格式： JSON Text Binary	JSON
InstanceId	string	否	实例 ID。	r-bp1b5ncun5lqer****
NetworkType	string	否
RegionId	string	否	地域 ID。	cn-shenzhen
SecurityGroupId	string	否
Topic	string	否	消息的 Topic。	CANAL_VICUTU_UAT
VSwitchIds	string	否
VpcId	string	否
SourceMySQLParameters	SourceMySQLParameters	否
SourceOSSParameters	object	否	Source OSS 事件源。
BucketName	string	否	对象存储 OSS 中的存储空间名称。	bucket_abc
Delimiter	string	否	分隔符，在分块加载模式下，以该分隔符作为文本的分块标识符，默认以换行符\n 作为分隔符。	\n
FileExtensions	array	否	OSS 对象后缀白名单，在扫描阶段过滤，仅后缀命中白名单的对象会导入知识库。支持的后缀：txt/md/markdown/html/htm/pdf/doc/docx/ppt/pptx/xls/xlsx（大小写不敏感）。不传或为空表示不按后缀过滤	["pdf","docx"]
	string	否	允许导入的文件后缀，如 pdf、docx，大小写不敏感、无需带点	pdf
LoadFormat	string	否	文档加载器。枚举值： TextLoader : TextLoader	TextLoader
LoadMode	string	否	数据加载模式，single 表示单文档加载，element 表示分块加载。取值：single/element 默认为 single 枚举值： single : single element : element	single
Prefix	string	否	文件路径前缀。	fun/document/
RoleName	string	否	授权事件总线 EventBridge 读取 OSS 文件的角色名称，要求该角色至少具有 OSS 的只读权限。	eventbridge_oss_role
SourceOpenSourceRabbitMQParameters	object	否
AuthType	string	否
BodyDataType	string	否
Endpoint	string	否
NetworkType	string	否
Password	string	否
QueueName	string	否
SecurityGroupId	string	否
Username	string	否
VSwitchIds	string	否
VirtualHostName	string	否
VpcId	string	否
SourcePostgreSQLParameters	SourcePostgreSQLParameters	否
SourcePrometheusParameters	object	否	Source Prometheus 事件源。
ClusterId	string	否	集群 id。	c83555068b6******ad213f565f209
DataType	string	否	数据类型。	JSON
ExternalLabels	string	否
Labels	string	否	标签。	__name__=.*
RegionId	string	否	地域 ID。	cn-hangzhou
RoleName	string	否
SourceRabbitMQMetaParameters	SourceRabbitMQMetaParameters	否
SourceRabbitMQMsgSyncParameters	SourceRabbitMQMsgSyncParameters	否
SourceRabbitMQParameters	object	否	Source RabbitMQ 源。
InstanceId	string	否	消息队列 RabbitMQ 版实例的实例 ID。	gtm-cn-k2c2yfg****
NetworkType	string	否
QueueName	string	否	消息队列 RabbitMQ 版实例的 Queue 的名称。	demo
RegionId	string	否	地域 ID。	cn-hangzhou
SecurityGroupId	string	否
VSwitchIds	string	否
VirtualHostName	string	否	消息队列 RabbitMQ 版实例的 Vhost 的名称。	eb-connect
VpcId	string	否
SourceRocketMQCheckpointParameters	object	否	Source RocketMQ Checkpoint 源
InstanceId	string	否	实例 ID。
InstanceType	string	否	实例类型。
RegionId	string	否	地域 ID。
Topics	array	否	消息 Topic。
	string	否	消息 Topic。
SourceRocketMQParameters	object	否	Source RocketMQ 源
AuthType	string	否	鉴权类型。	ACL
BodyDataType	string	否	消息编码格式 JSON Text Binary	JSON
FilterSql	string	否	sql 过滤语句。	index > 10
FilterType	string	否	消息过滤类型。	Tag
GroupID	string	否	消息队列 RocketMQ 版的 Group ID。	GID_group1
InstanceEndpoint	string	否	实例接入点。	reg****-vpc.cn-zhangjiakou.aliyuncs.com
InstanceId	string	否	消息队列 RocketMQ 版的实例所属地域。	default_C56C36026****
InstanceNetwork	string	否	实例网络信息： PublicNetwork PrivateNetwork	PublicNetwork
InstancePassword	string	否	实例密码。	admin
InstanceSecurityGroupId	string	否	实例安全组信息。	sg-m5edtu24f12345****
InstanceType	string	否	实例类型。取值说明如下： Cloud_4：阿里云 RocketMQ 4.0 版本实例（默认选项） Cloud_5：阿里云 RocketMQ 5.0 版本实例 SelfBuilt：自建 Apache RocketMQ 集群	Cloud_4
InstanceUsername	string	否	实例用户名。	admin
InstanceVSwitchIds	string	否	实例交换机信息。	vsw-m5ev8asdc6h123456****
InstanceVpcId	string	否	实例 VPC 信息。	vpc-m5e3sv4b12345****
Network	string	否	网络类型： PublicNetwork PrivateNetwork 枚举值： PrivateNetwork : PrivateNetwork PublicNetwork : PublicNetwork	PrivateNetwork
Offset	string	否	消息的消费位点。取值说明如下： CONSUME_FROM_LAST_OFFSET：从最新位点开始消费。 CONSUME_FROM_FIRST_OFFSET：从最早位点开始消费。 CONSUME_FROM_TIMESTAMP：从指定时间点的位点开始消费。默认值：CONSUME_FROM_LAST_OFFSET。	CONSUMEFROMLAST_OFFSET
RegionId	string	否	地域 ID。	cn-qingdao
SecurityGroupId	string	否	跨境任务安全组。	sg-m5edtu24f12345****
Tag	string	否	消息的过滤标签。	test
Timestamp	integer	否	时间戳。仅当参数 Offset 取值为 CONSUME_FROM_TIMESTAMP 时，该参数有效。	1670656652009
Topic	string	否	消息服务的主题。	Topic_publicRule_api_1667273421288
VSwitchIds	string	否	跨境任务 vSwitchIds。	vsw-m5ev8asdc6h12345****
VpcId	string	否	跨境任务 VPC ID。	vpc-m5e3sv4b12345****
SourceSLSParameters	object	否	Source SLS 源。
ConsumePosition	string	否	起始消费位点，可以选择最早或最新位点，分别对应“begin”，“end”，也可以从指定时间开始消费，以秒为单位。	end
LogStore	string	否	日志服务 SLS 的日志库。	sas-log
Project	string	否	日志服务 SLS 的日志项目。	test
RoleName	string	否	授权事件总线 EventBridge 使用此角色读取 SLS 日志内容时，需满足条件：在 RAM 控制台创建服务所使用的角色时，需要选择“阿里云服务”，并且“受信服务”需要选择“事件总线”。	testRole
Metadata	string	否	事件提供方通用 JSON 配置（与 Source 二选一）
Sink	object	否	事件目标。必须选择一种 Sink，且最多只能选择一种 Sink 进行填选。
SinkAgentRunParameters	SinkAgentRunParameters	否
SinkApacheKafkaParameters	object	否	描述信息
Acks	string	否
Bootstraps	string	否	Kafka 集群的初始连接地址
CompressionType	string	否
DynamicTopic	object	否	指定消息路由的目标 Topic 策略。若同时指定了 Topic 参数和 DynamicTopic 参数，以 DynamicTopic 参数的值为准。支持以下两种配置模式： 1. 静态常量模式：直接填写固定的 Topic 名称字符串（例如："order_created"）。所有消息将统一发送至该 Topic。 2. 动态提取模式：填写标准的 JSONPath 表达式（例如："$.user.id" 或 "$.metadata.category"）。系统将解析上游消息体，提取匹配字段的值作为目标 Topic 名称。
Form	string	否	转换的类型 CONSTANT：固定值 JSONPATH：根据路径从上游提取
Template	string	否	模板
Value	string	否	值
Headers	object	否
Form	string	否
Template	string	否
Value	string	否
Key	object	否
Form	string	否
Template	string	否
Value	string	否
NetworkType	object	否
Form	string	否
Template	string	否
Value	string	否
SaslMechanism	string	否
SaslPassword	string	否
SaslUser	string	否
SecurityGroupId	object	否
Form	string	否
Template	string	否
Value	string	否
SecurityProtocol	string	否
SslKeyPassword	string	否	【加密私钥必填】Kafka 客户端私钥密码。当客户端私钥使用密码加密保护时（即 PEM 文件中包含 'Proc-Type: 4,ENCRYPTED' 或 'ENCRYPTED' 标记），需提供解密密码。若私钥未加密则留空。注意：此密码仅用于解密私钥，与 Kafka 认证无关
SslKeystoreCertificateChain	string	否	【双向认证必填】Kafka 客户端证书链。当 Kafka 服务端开启双向 SSL 认证（ssl.client.auth=required）时，需提供此参数。格式要求：Base64 编码的 PEM 格式，包含客户端证书及完整的证书链（客户端证书在前，中间 CA 证书在后，根 CA 证书可选）。注意：确保每个 PEM 文件内容的开头和结尾分别是 '-----BEGIN CERTIFICATE-----' 和 '-----END CERTIFICATE-----' ，拼接后进行 Base64 编码
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 内容），则留空此参数
SslTruststoreCertificates	string	否	【SSL 场景必填】Kafka 服务端信任证书。用于验证 Kafka Broker 的 SSL 证书合法性，防止中间人攻击。格式要求：Base64 编码的 PEM 格式，通常包含 Kafka 服务端的 CA 证书或服务端证书本身。示例：将 CA 证书的 PEM 文件内容（确保开头和结尾分别是 '-----BEGIN CERTIFICATE-----' 和 '-----END CERTIFICATE-----' ），进行 Base64 编码。若 Kafka 使用自签名证书，需提供签发该证书的 CA 证书
Topic	string	否
VSwitchIds	object	否
Form	string	否
Template	string	否
Value	string	否
Value	object	否
Form	string	否
Template	string	否
Value	string	否
VpcId	object	否
Form	string	否
Template	string	否
Value	string	否
SinkApacheRocketMQCheckpointParameters	object	否	事件源类型
ConsumeTimestamp	object	否
Form	string	否
Template	string	否
Value	string	否
Group	object	否
Form	string	否
Template	string	否
Value	string	否
InstanceEndpoint	string	否
InstancePassword	string	否
InstanceUsername	string	否
NetworkType	string	否
SecurityGroupId	string	否
Topic	object	否
Form	string	否
Template	string	否
Value	string	否
VSwitchId	string	否
VpcId	string	否
SinkApiDestinationParameters	SinkApiDestinationParameters	否
SinkBaiLianParameters	SinkBaiLianParameters	否
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 文件。
Config	object	否	连接器配置。	{ "connector.class": "com.mongodb.kafka.connect.MongoSinkConnector", "tasks.max": "1", "topics": "sourceA,sourceB" }
Name	string	否	连接器名称。	mongo-sink
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" }
SinkCustomizedKafkaParameters	object	否	Sink Kafka 参数。
InstanceId	string	否	消息队列 Kafka 版的实例 ID。	90be1f96-4229-4535-bb76-34b4f6fb2b71
SinkDashVectorParameters	object	否	Sink DashVector 参数。
ApiKey	string	否	DashVecotor 控制台创建的 API Key。	Q34nExQH7sQ****
Collection	string	否	Collection（集合）名称。	collection1
DashVectorSchemaParameters	array<object>	否	插入 DashVector 时表项的 Schema 字段定义，事件内容转换后结果必须是 JSON 格式。
	array<object>	否	属性列
Name	object	否	属性名
Form	string	否	Form	CONSTANT
Template	string	否	Template
Value	string	否	Value	content
Type	object	否	DashVector 属性类型
Form	string	否	Form	CONSTANT
Template	string	否	Template
Value	string	否	Value	STRING
Value	object	否	属性值
Form	string	否	Form	JSONPATH
Template	string	否	Template	${content}
Value	string	否	Value	$.data.content
InstanceId	string	否	实例 ID。	vrs-cn-lbj3ru1***
Network	string	否	网络类型。枚举值： PrivateNetwork : PrivateNetwork PublicNetwork : PublicNetwork	PublicNetwork
Operation	string	否	DashVector 数据库操作类型。枚举值： Delete : Delete Upsert : Upsert	Upsert
Partition	object	否	Partition（分区），默认值为 default 分区。
Form	string	否	转换的格式。枚举值： JSONPATH : JSONPATH CONSTANT : CONSTANT	CONSTANT
Template	string	否	无	${partition}
Value	string	否	Form 为 CONSTANT：常量值 Form 为 JSONPATH：JSONPath 提取内容说明 Value 字段不允许超过 10240 个字符。	default
PrimaryKeyId	object	否	插入/删除记录时的主键 ID。说明不填写此字段时，表示使用随机主键 ID。
Form	string	否	转换的格式。枚举值： JSONPATH : JSONPATH TEMPLATE : TEMPLATE	JSONPATH
Template	string	否	主键 ID 模板，仅当 Form 是 TEMPLATE 时需要填写。	${ID}
Value	string	否	Form 为 JSONPATH：JSONPath 提取内容 Form 为 TEMPLATE：模板变量说明 Value 字段不允许超过 10240 个字符。	$.data.requestId
Vector	object	否	插入 DashVector 记录的向量。
Form	string	否	转换的格式。枚举值： JSONPATH : JSONPATH	JSONPATH
Template	string	否	无	${vector}
Value	string	否	JSONPath 提取内容。说明 Value 字段不允许超过 10240 个字符。	$.data.messageBody
SinkDataHubParameters	object	否	Sink DataHub 参数。
Body	object	否	BLOB 类型，Record 内容模板。
Form	string	否	转换的格式。	ORIGINAL
Template	string	否	无
Value	string	否	BLOB 类型，Record 内容模板。
Project	object	否	DataHub 项目名。
Form	string	否	转换的格式。默认为 CONSTANT。	CONSTANT
Template	string	否	无
Value	string	否	DataHub 项目名。	demo-project
RoleName	object	否	任务角色名。
Form	string	否	转换的格式。默认为 CONSTANT。	CONSTANT
Template	string	否	无
Value	string	否	任务角色名称。	test-role
Topic	object	否	DataHub Topic 名称。
Form	string	否	转换的格式。默认为 CONSTANT。	CONSTANT
Template	string	否	无
Value	string	否	DataHub Topic 名称。	demo-topic
TopicSchema	object	否	TUBLE 类型，topic 内容模式。
Form	string	否	转换的格式。	TEMPLATE
Template	string	否	模板样式。	{"k1":"${k1}","k2":"${k2}"}
Value	string	否	TUBLE 类型，topic 内容模式。	{"k1":"value1","k2":"value2"}
TopicType	object	否	topic 类型： TUPLE BLOB
Form	string	否	转换的格式。默认为 CONSTANT。	CONSTANT
Template	string	否	无
Value	string	否	topic 类型： TUPLE BLOB	TUPLE
SinkDataWorksTriggerParameters	SinkDataWorksTriggerParameters	否
SinkDorisParameters	object	否	事件源类型
BeHttpEndpoint	object	否
Form	string	否
Template	string	否
Value	string	否
Body	object	否
Form	string	否
Template	string	否
Value	string	否
Database	object	否
Form	string	否
Template	string	否
Value	string	否
FeHttpEndpoint	object	否
Form	string	否
Template	string	否
Value	string	否
NetworkType	object	否
Form	string	否
Template	string	否
Value	string	否
Password	object	否
Form	string	否
Template	string	否
Value	string	否
QueryEndpoint	object	否
Form	string	否
Template	string	否
Value	string	否
SecurityGroupId	object	否
Form	string	否
Template	string	否
Value	string	否
Table	object	否
Form	string	否
Template	string	否
Value	string	否
UserName	object	否
Form	string	否
Template	string	否
Value	string	否
VSwitchIds	object	否
Form	string	否
Template	string	否
Value	string	否
VpcId	object	否
Form	string	否
Template	string	否
Value	string	否
SinkEventHouseParameters	object	否	事件目标名称
CatalogName	string	否	catalog 名称	demo
EventTableName	string	否	目标表的名称	demo-table
MappingRules	array<object>	否	字段映射规则
	array<object>	否	字段映射规则
ColumnName	string	否	列名称	age
ColumnType	string	否	列的类型	text
ColumnValue	object	否	列值的提取规则
Form	string	否	转换的方式，如 JSONPATH	JSONPATH
Template	string	否	模板配置	The value of ${key} is ${value}!
Value	string	否	提取路径，如$.data.value.name	$.data.value
NamespaceName	string	否	目标表的命名空间	name1
SinkFcParameters	object	否	函数目标。
Body	object	否	发送给函数的内容体。
Form	string	否	转换的格式： ORIGINAL：完整事件 JSONPATH：部分事件 CONSTANT：常量 TEMPLATE：模板详细参考：https://help.aliyun.com/zh/eventbridge/user-guide/event-transformation 枚举值： JSONPATH : JSONPATH CONSTANT : CONSTANT ORIGINAL : ORIGINAL TEMPLATE : TEMPLATE	TEMPLATE
Template	string	否	模板样式。	The value of ${key} is ${value}!
Value	string	否	转换前的值。	{ "key": "value" }
Concurrency	object	否	投递并发度，最小 1。
Form	string	否	转换的格式。默认为 CONSTANT。枚举值： CONSTANT : CONSTANT	CONSTANT
Template	string	否	模板样式。	The value of ${key} is ${value}!
Value	string	否	投递并发度，最小 1。	1
DataFormat	object	否
Form	string	否
Template	string	否
Value	string	否
FunctionName	object	否	函数名。
Form	string	否	转换的格式。默认为 CONSTANT。枚举值： CONSTANT : CONSTANT	CONSTANT
Template	string	否	模板样式。	The value of ${key} is ${value}!
Value	string	否	函数名。	myFunction
InvocationType	object	否	同步或则异步。 Sync：同步。 Async：异步。
Form	string	否	转换的格式。默认为 CONSTANT。枚举值： CONSTANT : CONSTANT	CONSTANT
Template	string	否	模板样式。	The value of ${key} is ${value}!
Value	string	否	同步或则异步。 Sync：同步。 Async：异步。枚举值： Async : Async Sync : Sync	Async
Qualifier	object	否	服务版本。
Form	string	否	转换的格式。默认为 CONSTANT。枚举值： CONSTANT : CONSTANT	CONSTANT
Template	string	否	模板样式。	The value of ${key} is ${value}!
Value	string	否	服务版本。	LATEST
ServiceName	object	否	服务名。
Form	string	否	转换的格式。默认为 CONSTANT。枚举值： CONSTANT : CONSTANT	CONSTANT
Template	string	否	模板样式。	The value of ${key} is ${value}!
Value	string	否	服务名。	myService
SinkFnfParameters	object	否	Sink Fnf 参数。
ExecutionName	object	否	执行名称。
Form	string	否	转换的格式。默认为 CONSTANT JSONPATH：部分事件 CONSTANT：常量 TEMPLATE：模板详细参考：https://help.aliyun.com/zh/eventbridge/user-guide/event-transformation 枚举值： JSONPATH : JSONPATH CONSTANT : CONSTANT TEMPLATE : TEMPLATE	CONSTANT
Template	string	否	模板样式。
Value	string	否	执行名称。	123
FlowName	object	否	流程名称。
Form	string	否	转换的格式。默认为 CONSTANT。枚举值： CONSTANT : CONSTANT	CONSTANT
Template	string	否	模板样式。
Value	string	否	流程名称。	test-streaming-fnf
Input	object	否	执行输入信息。
Form	string	否	转换的格式： ORIGINAL：完整事件 JSONPATH：部分事件 CONSTANT：常量 TEMPLATE：模板详细参考：https://help.aliyun.com/zh/eventbridge/user-guide/event-transformation 枚举值： JSONPATH : JSONPATH CONSTANT : CONSTANT ORIGINAL : ORIGINAL TEMPLATE : TEMPLATE	CONSTANT
Template	string	否	模板样式。
Value	string	否	执行输入信息。	123
RoleName	object	否	角色配置。
Form	string	否	转换的格式。默认为 CONSTANT。枚举值： CONSTANT : CONSTANT	CONSTANT
Template	string	否	模板样式。
Value	string	否	角色配置。	Al**FNF-x**
SinkHttpsParameters	SinkHttpsParameters	否
SinkKafkaParameters	object	否	Sink kafak 参数。
Acks	object	否	写入 Kafka 确认模式： acks=0：无需服务端的 Response、性能较高、丢数据风险较大。 acks=1：服务端主节点写成功即返回 Response、性能中等、丢数据风险中等、主节点宕机可能导致数据丢失； acks=all：服务端主节点写成功且备节点同步成功才返回 Response、性能较差、数据较为安全、主节点和备节点都宕机才会导致数据丢失。
Form	string	否	转换的格式。默认为 CONSTANT。	CONSTANT
Template	string	否	模板样式。	The value of ${key} is ${value}!
Value	string	否	写入 Kafka 确认模式： acks=0：无需服务端的 Response、性能较高、丢数据风险较大。 acks=1：服务端主节点写成功即返回 Response、性能中等、丢数据风险中等、主节点宕机可能导致数据丢失； acks=all：服务端主节点写成功且备节点同步成功才返回 Response、性能较差、数据较为安全、主节点和备节点都宕机才会导致数据丢失。	1
CompressionType	string	否
DynamicTopic	object	否	指定消息路由的目标 Topic 策略。若同时指定了 Topic 参数和 DynamicTopic 参数，以 DynamicTopic 参数的值为准。支持以下两种配置模式： 1. 静态常量模式：直接填写固定的 Topic 名称字符串（例如："order_created"）。所有消息将统一发送至该 Topic。 2. 动态提取模式：填写标准的 JSONPath 表达式（例如："$.user.id" 或 "$.metadata.category"）。系统将解析上游消息体，提取匹配字段的值作为目标 Topic 名称。
Form	string	否	转换的类型 CONSTANT：固定值 JSONPATH：根据路径从上游提取
Template	string	否	模板
Value	string	否	值
Headers	object	否
Form	string	否
Template	string	否
Value	string	否
InstanceId	object	否	目标服务类型为消息队列 Kafka 版。
Form	string	否	转换的格式。默认为 CONSTANT。	CONSTANT
Template	string	否	模板样式。	The value of ${key} is ${value}!
Value	string	否	实例 ID。	Defaut_1283278472_s****
Key	object	否	消息键。
Form	string	否	转换的格式。默认为 CONSTANT。	CONSTANT
Template	string	否	模板样式。	The value of ${key} is ${value}!
Value	string	否	消息键。	key
Topic	object	否	主题名称。
Form	string	否	转换的格式。默认为 CONSTANT。	CONSTANT
Template	string	否	模板样式。	The value of ${key} is ${value}!
Value	string	否	主题的名称。	test
Value	object	否	消息体。
Form	string	否	转换的格式。	TEMPLATE
Template	string	否	模板样式。	The value of ${key} is ${value}!
Value	string	否	转换前的值。	{ "key": "value" }
SinkKnowledgeBaseParameters	SinkKnowledgeBaseParameters	否	事件流投递到 EventHouse 知识库的目标端参数，仅 Sink 类型为知识库时传入
SinkMNSParameters	object	否	MNS 事件目标。
Body	object	否	消息内容。
Form	string	否	转换的格式。枚举值： JSONPATH : JSONPATH CONSTANT : CONSTANT TEMPLATE : TEMPLATE	TEMPLATE
Template	string	否	模板样式。	The value of ${key} is ${value}!
Value	string	否	转换前的值。	{ "key": "value" }
IsBase64Encode	object	否	是否开启 Base64 编码。
Form	string	否	事件转换的格式。默认为 CONSTANT。枚举值： CONSTANT : CONSTANT	CONSTANT
Template	string	否	模板样式。	The value of ${key} is ${value}!
Value	string	否	开启 Base64 编码。	true
QueueName	object	否	目标服务类型为消息服务 MNS。
Form	string	否	转换的格式。默认为 CONSTANT。枚举值： CONSTANT : CONSTANT	CONSTANT
Template	string	否	模板样式。	The value of ${key} is ${value}!
Value	string	否	消息服务 MNS 的 Queue 的名称。	MyQueue
SinkMQTTParameters	SinkMQTTParameters	否
SinkOSSParameters	SinkOSSParameters	否
SinkOpenSourceRabbitMQParameters	object	否
AuthType	string	否
Body	object	否
Form	string	否
Template	string	否
Value	string	否
Endpoint	string	否
Exchange	string	否
MessageId	object	否
Form	string	否
Template	string	否
Value	string	否
NetworkType	string	否
Password	string	否
Properties	object	否
Form	string	否
Template	string	否
Value	string	否
QueueName	string	否
RoutingKey	object	否
Form	string	否
Template	string	否
Value	string	否
SecurityGroupId	string	否
TargetType	string	否
Username	string	否
VSwitchIds	string	否
VirtualHostName	string	否
VpcId	string	否
SinkPrometheusParameters	object	否	Sink Prometheus 参数。
AuthorizationType	object	否	鉴权方式。
Form	string	否	转换的格式。默认为 CONSTANT。枚举值： CONSTANT : CONSTANT	CONSTANT
Template	string	否	无
Value	string	否	鉴权方式。枚举值： BASIC_AUTH : BASIC_AUTH	BASIC_AUTH
Data	object	否	指标内容。
Form	string	否	转换的格式。默认为 JSAONPATH。	JSAONPATH
Template	string	否	模板样式。
Value	string	否	指标内容。	$.data
HeaderParameters	object	否	请求头的参数数据结构。
Form	string	否	转换的格式。枚举值： JSONPATH : JSONPATH CONSTANT : CONSTANT TEMPLATE : TEMPLATE	TEMPLATE
Template	string	否	HTTP 请求头模板样式，当 Form 是 TEMPLATE 时填写，事件内容转换后结果必须是 JSON 格式。	{ "user_name":"${name}" }
Value	string	否	Form 为 CONSTANT：常量值 Form 为 JSONPATH：JSONPath 提取内容 Form 为 TEMPLATE：模板变量注：Value 字段不允许超过 10240 个字符	name
NetworkType	object	否	网络类型。
Form	string	否	转换的格式。默认为 CONSTANT。枚举值： CONSTANT : CONSTANT	CONSTANT
Template	string	否	无
Value	string	否	网络类型。枚举值： PrivateNetwork : PrivateNetwork PublicNetwork : PublicNetwork	PrivateNetwork
Password	object	否	密码。
Form	string	否	转换的格式。默认为 CONSTANT。枚举值： CONSTANT : CONSTANT	CONSTANT
Template	string	否	无
Value	string	否	密码。	*****
SecurityGroupId	object	否	安全组 ID。
Form	string	否	转换的格式。默认为 CONSTANT。枚举值： CONSTANT : CONSTANT	CONSTANT
Template	string	否	无
Value	string	否	安全组 ID。	sg-mw43*****
URL	object	否	Prometheus Remote Write URL 地址。
Form	string	否	转换的格式。默认为 CONSTANT。枚举值： CONSTANT : CONSTANT	CONSTANT
Template	string	否	模板样式（Form 为 CONSTANT 时为空）。
Value	string	否	Prometheus Remote Write URL 地址。	https://cn-hangzhou.arms.aliyuncs.com/prometheus/167275**/c5b7faeb2e8994641***d5c559f/cn-hangzhou/api/v3/write
Username	object	否	用户名。
Form	string	否	转换的格式。默认为 CONSTANT。	CONSTANT
Template	string	否	无
Value	string	否	用户名。	****admin
VSwitchId	object	否	交换机 ID。
Form	string	否	转换的格式。默认为 CONSTANT。枚举值： CONSTANT : CONSTANT	CONSTANT
Template	string	否	无
Value	string	否	交换机 ID。	vsw-dwaafds****
VpcId	object	否	VPC 的 ID。
Form	string	否	转换的格式。默认为 CONSTANT。枚举值： CONSTANT : CONSTANT	CONSTANT
Template	string	否	无
Value	string	否	VPC 的 ID。	i-2ze7u5i17mbqtx1p****
SinkRabbitMQMetaParameters	SinkRabbitMQMetaParameters	否
SinkRabbitMQMsgSyncParameters	SinkRabbitMQMsgSyncParameters	否
SinkRabbitMQParameters	object	否	Sink Rabbitmq 的参数。
Body	object	否	消息内容。
Form	string	否	转换的格式。	TEMPLATE
Template	string	否	模板样式。	The value of ${key} is ${value}!
Value	string	否	转换前的值。	{ "key": "value" }
Exchange	object	否	Exchange 模式。仅当参数 TargetType 配置为 Exchange 时，需配置此参数。
Form	string	否	转换的格式。默认为 CONSTANT。	CONSTANT
Template	string	否	模板样式。	The value of ${key} is ${value}!
Value	string	否	消息队列 RabbitMQ 版实例的 Exchange 的名称。	a_exchange
InstanceId	object	否	目标服务类型为消息队列 RabbitMQ 版。
Form	string	否	转换的格式。默认为 CONSTANT。枚举值： CONSTANT : CONSTANT	CONSTANT
Template	string	否	模板样式。	The value of ${key} is ${value}!
Value	string	否	消息队列 RabbitMQ 版的实例 ID。	a5ff91ad4f3f24947887fe184fc2****
MessageId	object	否	消息 ID。
Form	string	否	转换的格式。	TEMPLATE
Template	string	否	模板样式。	The value of ${key} is ${value}!
Value	string	否	转换前的值。	{ "key": "value" }
NetworkType	object	否
Form	string	否
Template	string	否
Value	string	否
Properties	object	否	过滤属性。
Form	string	否	转换的格式。	TEMPLATE
Template	string	否	模板样式。	The value of ${key} is ${value}!
Value	string	否	转换前的值。	{ "key": "value" }
QueueName	object	否	Queue 模式。仅当参数 TargetType 配置为 Queue 时，需配置此参数。
Form	string	否	转换的格式。默认为 CONSTANT。	CONSTANT
Template	string	否	模板样式。	The value of ${key} is ${value}!
Value	string	否	实例的 Queue 的名称。	MyQueue
RoutingKey	object	否	消息的路由规则。仅当参数 TargetType 配置为 Exchange 时，需配置此参数。
Form	string	否	转换的格式。默认为 CONSTANT。	CONSTANT
Template	string	否	模板样式。	The value of ${key} is ${value}!
Value	string	否	消息的路由规则。	housekeeping
SecurityGroupId	object	否
Form	string	否
Template	string	否
Value	string	否
TargetType	object	否	目标类型。
Form	string	否	转换的格式。默认为 CONSTANT。	CONSTANT
Template	string	否	模板样式。	The value of ${key} is ${value}!
Value	string	否	目标类型。取值说明如下： Exchange：Exchange 模式。 Queue：Queue 模式。	Exchange/Queue
VSwitchIds	object	否
Form	string	否
Template	string	否
Value	string	否
VirtualHostName	object	否	消息队列 RabbitMQ 版实例的 Vhost 的名称。
Form	string	否	转换的格式。默认为 CONSTANT。枚举值： CONSTANT : CONSTANT	CONSTANT
Template	string	否	模板样式。
Value	string	否	消息队列 RabbitMQ 版实例的 Vhost 的名称。	rabbit-host
VpcId	object	否
Form	string	否
Template	string	否
Value	string	否
SinkRocketMQCheckpointParameters	object	否	事件源类型
ConsumeTimestamp	object	否
Form	string	否
Template	string	否
Value	string	否
Group	object	否
Form	string	否
Template	string	否
Value	string	否
InstanceId	string	否
InstanceType	string	否
Topic	object	否
Form	string	否
Template	string	否
Value	string	否
SinkRocketMQParameters	object	否	Sink RocketMQ Parameters
Body	object	否	消息内容。
Form	string	否	转换的格式。	TEMPLATE
Template	string	否	模板样式。	The value of ${key} is ${value}!
Value	string	否	转换前的值。	{ "key": "value" }
DeliveryOrderType	object	否
Form	string	否
Template	string	否
Value	string	否
InstanceEndpoint	object	否	实例接入点。
Form	string	否	转换的格式。默认为 CONSTANT。	CONSTANT
Template	string	否	无
Value	string	否	实例接入点。	vbr-8vbsvkkbpf3vb0zef****
InstanceId	object	否	目标服务类型为消息队列 RocketMQ 版。
Form	string	否	转换的格式。默认为 CONSTANT。	CONSTANT
Template	string	否	模板样式。	The value of ${key} is ${value}!
Value	string	否	消息队列 RocketMQ 版的实例 ID。	MQ_INST_164901546557**_BAAN**
InstancePassword	object	否	实例密码。
Form	string	否	转换的格式。默认为 CONSTANT。	CONSTANT
Template	string	否	无
Value	string	否	实例密码。	admin
InstanceType	object	否	实例类型。
Form	string	否	转换的格式。默认为 CONSTANT。	CONSTANT
Template	string	否	无
Value	string	否	实例类型。取值说明如下： Cloud_4：阿里云 RocketMQ 4.0 版本实例（默认选项） Cloud_5：阿里云 RocketMQ 5.0 版本实例 SelfBuilt：自建 Apache RocketMQ 集群	Cloud_4
InstanceUsername	object	否	实例用户名。
Form	string	否	转换的格式。默认为 CONSTANT。	CONSTANT
Template	string	否	无
Value	string	否	实例用户名。	admin
Keys	object	否	过滤属性。
Form	string	否	转换的格式。	TEMPLATE
Template	string	否	模板样式。	The value of ${key} is ${value}!
Value	string	否	转换前的值。	{ "key": "value" }
Network	object	否	网络类型： PublicNetwork PrivateNetwork
Form	string	否	转换的格式。默认为 CONSTANT。	CONSTANT
Template	string	否	无
Value	string	否	网络类型： PublicNetwork PrivateNetwork	PublicNetwork
Properties	object	否	过滤属性。
Form	string	否	转换的格式。	TEMPLATE
Template	string	否	模板样式。	The value of ${key} is ${value}!
Value	string	否	转换前的值。	{ "key": "value" }
SecurityGroupId	object	否	安全组 ID。
Form	string	否	转换的格式。默认为 CONSTANT。	CONSTANT
Template	string	否	无
Value	string	否	安全组 ID。	b4bf375515f6440f942e3a20c33d****
ShardingKey	object	否
Form	string	否
Template	string	否
Value	string	否
Tags	object	否	过滤属性。
Form	string	否	转换的格式。	TEMPLATE
Template	string	否	模板样式。	The value of ${key} is ${value}!
Value	string	否	转换前的值。	{ "key": "value" }
Topic	object	否	消息队列 RocketMQ 版实例的 Topic。
Form	string	否	转换的格式。默认为 CONSTANT。	CONSTANT
Template	string	否	模板样式。	The value of ${key} is ${value}!
Value	string	否	消息队列 RocketMQ 版实例的 Topic 名称。	Mytopic
VSwitchIds	object	否	交换机 ID。
Form	string	否	转换的格式。默认为 CONSTANT。	CONSTANT
Template	string	否	无
Value	string	否	交换机 ID。	vbr-8vb835n3zf9shwl****mp
VpcId	object	否	VPC 的 ID。
Form	string	否	事件转换的格式。默认为 CONSTANT。	CONSTANT
Template	string	否	无
Value	string	否	VPC 的 ID。	vbr-8vb835n3zf9shwlvb****
SinkSLSParameters	object	否	Sink SLS Parameters
Body	object	否	发送给 SLS 的内容。
Form	string	否	转换的格式。	TEMPLATE
Template	string	否	模板样式。	The value of ${key} is ${value}!
Value	string	否	转换前的值。	{ "key": "value" }
ContentSchema	object	否	自定义日志的键值，仅在 ContentType 为 KeyValue 生效。每一对键值由 Key_n，Value_n 表示。
Form	string	否	模板样式。	CONSTANT
Template	string	否	模板样式。
Value	string	否	转换前的值。	{"Key_1":{"form":"CONSTANT","value":"demoKey"},"Value_1":{"form":"JSONPATH","value":"$.data.value"}}
ContentType	object	否	SLS 数据格式。可选择默认或者配置制定的键值： JSON KeyValue
Form	string	否	转换的格式。	CONSTANT
Template	string	否	模板样式。
Value	string	否	转换前的值。	JSON
LogStore	object	否	日志服务 SLS 的日志库。
Form	string	否	转换的格式。默认为 CONSTANT。	CONSTANT
Template	string	否	无
Value	string	否	日志服务 SLS 的日志库。	test-logstore
Project	object	否	日志服务 SLS 的日志项目。
Form	string	否	转换的格式。默认为 CONSTANT。	CONSTANT
Template	string	否	无
Value	string	否	日志服务 SLS 的日志项目。	test-project
RoleName	object	否	授权事件总线 EventBridge 使用此角色读取 SLS 日志内容时，需满足条件：在 RAM 控制台创建服务所使用的角色时，需要选择“阿里云服务”，并且“受信服务”需要选择“事件总线”。
Form	string	否	转换的格式。默认为 CONSTANT。	CONSTANT
Template	string	否	无
Value	string	否	授权事件总线 EventBridge 使用此角色读取 SLS 日志内容时，需满足条件：在 RAM 控制台创建服务所使用的角色时，需要选择“阿里云服务”，并且“受信服务”需要选择“事件总线”。	testRole
Topic	object	否	日志所在的 Topic，对应 SLS 保留字段“topic”。
Form	string	否	转换的格式。默认为 CONSTANT。	CONSTANT
Template	string	否	无
Value	string	否	日志所在的 Topic，对应 SLS 保留字段“topic”。	testTopic
RunOptions	object	否	运行环境参数。
BatchWindow	object	否	攒批窗口。
CountBasedWindow	integer	否	窗口中最大可容纳的事件数量。当达到此阈值，会触发窗口内的数据往下游推送。当存在多个窗口时，有一个窗口满足即触发。	100
TimeBasedWindow	integer	否	窗口中最大可容纳的时间范围内的事件（单位秒）。当达到此阈值，会触发窗口内的数据往下游推送。当存在多个窗口时，有一个窗口满足即触发。	10
BusinessOption	object	否
BusinessMode	string	否
MaxCapacityUnitCount	integer	否
MinCapacityUnitCount	integer	否
DeadLetterQueue	object	否	是否启用死信队列。默认不启用死信队列，超过重试策略后的消息将被丢弃。
Arn	string	否	死信队列 ARN。	acs:ram::131733464781****:role/rdstoecsassumekms
Network	string	否
SecurityGroupId	string	否
VSwitchIds	string	否
VpcId	string	否
ErrorsTolerance	string	否	异常容忍策略： NONE：不容忍异常。 ALL：容忍所有异常。	ALL
MaximumTasks	integer	否	并发数。	2
RetryStrategy	object	否	事件推送失败时的重试策略。
MaximumEventAgeInSeconds	integer	否	最大重试时间。	512
MaximumRetryAttempts	integer	否	最大重试次数。	2
PushRetryStrategy	string	否	重试策略： BACKOFF_RETRY：退避重试。 EXPONENTIAL_DECAY_RETRY：指数衰减重试。	BACKOFF_RETRY
Throttling	integer	否
Transforms	array<object>	否	Transform 相关配置。
	object	否	云产品的 ARN，比如函数计算中函数的 ARN。
AiChunkTransformParameters	AiChunkTransformParameters	否	AI 本地文本分块参数
AiClassifyTransformParameters	AiClassifyTransformParameters	否	AI 文本分类参数
AiEmbedTransformParameters	AiEmbedTransformParameters	否	AI 向量化参数
AiExtractTransformParameters	AiExtractTransformParameters	否	AI 信息抽取参数
AiFilterTransformParameters	AiFilterTransformParameters	否	AI 条件过滤参数
AiPrepSearchTransformParameters	AiPrepSearchTransformParameters	否	AI 语义切块参数
AiRedactTransformParameters	AiRedactTransformParameters	否	AI 脱敏参数
AiSentimentAnalysisTransformParameters	AiSentimentAnalysisTransformParameters	否	AI 情感分析参数
AiSummarizeTransformParameters	AiSummarizeTransformParameters	否	AI 摘要参数
AiTranslateTransformParameters	AiTranslateTransformParameters	否	AI 翻译参数
Arn	string	否	云产品的 ARN，比如函数计算中函数的 ARN。	acs:fc:cn-hangzhou:*****:services/demo-service.LATEST/functions/demo-func
BaiLianAgentTransformParameters	BaiLianAgentTransformParameters	否
DashScopeTransformParameters	DashScopeTransformParameters	否
EmbeddingTransformParameters	EmbeddingTransformParameters	否
Tags	array<object>	否	标签列表，最多包含 20 个子项
	object	否
Key	string	否	标签键
Value	string	否	标签值

返回参数

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

示例

正常返回示例

JSON格式

{
  "Code": "Success",
  "Data": {
    "EventStreamingARN": "acs:eventbridge:cn-hangzhou:164901546557****:eventstreaming/myeventstreaming"
  },
  "Message": "The name [xxxx] of event streaming in request is already exist!",
  "RequestId": "B896B484-F16D-59DE-9E23-DD0E5C36****",
  "Success": true
}

错误码

HTTP status code	错误码	错误信息	描述
403	ServiceNotEnable	Service not enable

访问错误中心查看更多错误码。

变更历史

更多信息，参考变更详情。