使用 ListEventStreamings 获取事件流列表 - 事件总线 -Alibaba Cloud - 事件总线EventBridge

查询事件流。

接口说明

查询事件流。

调试

您可以在OpenAPI Explorer中直接运行该接口，免去您计算签名的困扰。运行成功后，OpenAPI Explorer可以自动生成SDK代码示例。

调试

授权信息

下表是API对应的授权信息，可以在RAM权限策略语句的Action元素中使用，用来给RAM用户或RAM角色授予调用此API的权限。具体说明如下：

操作：是指具体的权限点。
访问级别：是指每个操作的访问级别，取值为写入（Write）、读取（Read）或列出（List）。
资源类型：是指操作中支持授权的资源类型。具体说明如下：
- 对于必选的资源类型，用前面加 * 表示。
- 对于不支持资源级授权的操作，用全部资源表示。
条件关键字：是指云产品自身定义的条件关键字。
关联操作：是指成功执行操作所需要的其他权限。操作者必须同时具备关联操作的权限，操作才能成功。

操作

访问级别

资源类型

条件关键字

关联操作

eventbridge:ListEventStreamings

list

*EventStreaming

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

无

请求参数

名称	类型	必填	描述	示例值
NamePrefix	string	否	事件流名称前缀。	name
Limit	integer	否	限定每次返回的最大条数，可以和 NextToken 搭配使用实现翻页能力。重要每次返回的最大条数不超过 100。	10
NextToken	string	否	当指定 Limit 时，如果还有多余的返回值则会返回 NextToken。	10
Tags	array<object>	否	标签筛选。
	object	否	标签。
Key	string	否	标签键。	mns
Value	string	否	标签值。	mnstest
SourceArn	string	否	事件源 Arn。	acs:alikafka:cn-hangzhou:118609547428**:instance/alikafka_pre-cn-zxu36kvi**/topic/test-topic
SinkArn	string	否	事件目标 Arn。	acs:fc:cn-hangzhou:118609547428****:services/fw1.LATEST/functions/log1

返回参数

名称	类型	描述	示例值
	object	返回信息。
Code	string	接口返回码： Success：表示成功。其它：表示错误码。错误码详情，请参见错误码。	Success
Data	object	事件流列表。
EventStreamings	array<object>	事件流列表。
	array<object>	事件流实体。
Description	string	事件流描述信息。	demo
EventStreamingName	string	事件流名称。	name
FilterPattern	string	事件过滤规则，如果不指定表示匹配全部事件。
Metadata	string
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::159787121179****:role/aliyunsaedefaultrole
Network	string	死信队列的网络类型。	PrivateNetwork
SecurityGroupId	string	死信队列所在实例的安全组 ID。	sg-2vcgdxz7o1n9zapp****
VSwitchIds	string	死信队列所在的虚拟交换机 ID。	vsw-m5ev8asdc6h12345****
VpcId	string	死信队列所在的 VPC 网络 ID。	vpc-2zehizpoendb3****
ErrorsTolerance	string	异常容忍策略：NONE（不容忍异常）、ALL（容忍所有异常）。	ALL
MaximumTasks	integer	并发数。	2
RetryStrategy	object	事件推送失败时的重试策略。
PushRetryStrategy	string	重试策略：BACKOFF_RETRY（退避重试）和 EXPONENTIAL_DECAY_RETRY（指数衰减重试）。	EXPONENTIAL_DECAY_RETRY
Throttling	integer
Sink	object	事件目标。
SinkAgentRunParameters	SinkAgentRunParameters
SinkApacheRocketMQCheckpointParameters	object	Sink Apache RocketMQ Checkpoint 参数。
ConsumeTimestamp	object	消费位点。
Form	string	转换格式，默认为 CONSTANT。	CONSTANT
Template	string	模板样式。
Value	string	时间戳。	1636597951964
Group	object	Apache RocketMQ 的消费者分组信息。
Form	string	转换格式，默认为 CONSTANT。	CONSTANT
Template	string	模板样式。
Value	string	消费者分组的 Group ID。	GID_******
InstanceEndpoint	string	Apache RocketMQ 实例的接入点。	192.168.1.1:9876
InstancePassword	string	Apache RocketMQ 实例的密码。	****
InstanceUsername	string	Apache RocketMQ 实例的用户名。	admin
NetworkType	string	网络类型。	PrivateNetwork
SecurityGroupId	string	安全组 ID。	sg-2vcgdxz7o1n9zapp****
Topic	object	Apache RocketMQ 实例的 Topic 名称。
Form	string	转换格式，默认为 CONSTANT。	CONSTANT
Template	string	模板样式。
Value	string	Topic 的名称。	myTopic
VSwitchId	string	交换机 ID。	vsw-wz9qqeovkwjxlu9uc****
VpcId	string	VPC ID。	vpc-2zehizpoendb3****
SinkApiDestinationParameters	SinkApiDestinationParameters	ApiDestination 目标参数
SinkBaiLianParameters	SinkBaiLianParameters	Sink BaiLian 参数。
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
Template	string
Value	string
Type	object
Form	string
Template	string
Value	string
Value	object
Form	string
Template	string
Value	string
InstanceId	string	实例 ID。	vrs-cn-lbj3ru1***
Network	string	网络类型。	PublicNetwork
Operation	string	DashVector 数据库操作类型。	Upsert
Partition	object	Partition（分区），默认值为 default 分区。
Form	string	转换的格式。	CONSTANT
Template	string	无
Value	string	Form 为 CONSTANT：常量值 Form 为 JSONPATH：JSONPath 提取内容注：Value 字段不允许超过 10240 个字符。	default
PrimaryKeyId	object	插入/删除记录时的主键 ID 不填写此字段时，使用随机主键 ID。
Form	string	转换的格式。	JSONPATH
Template	string	主键 ID 模板，仅当 Form 是 TEMPLATE 时需要填写。	${ID}
Value	string	Form 为 JSONPATH：JSONPath 提取内容 Form 为 TEMPLATE：模板变量注：Value 字段不允许超过 10240 个字符。	$.data.requestId
Vector	object	插入 DashVector 记录的向量。
Form	string	转换的格式。	JSONPATH
Template	string	无
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	授权事件总线 EventBridge 使用此角色读取 SLS 日志内容时，需满足条件：在 RAM 控制台创建服务所使用的角色时，需要选择“阿里云服务”，并且“受信服务”需要选择“事件总线”。
Form	string	转换的格式。默认为 CONSTANT。	CONSTANT
Template	string	无
Value	string	授权事件总线 EventBridge 使用此角色读取 SLS 日志内容时，需满足条件：在 RAM 控制台创建服务所使用的角色时，需要选择“阿里云服务”，并且“受信服务”需要选择“事件总线”。	testRole
Topic	object	DataHub Topic 名称。
Form	string	转换的格式。默认为 CONSTANT。	CONSTANT
Template	string	无
Value	string	DataHub Topic 名称。	demo-topic
TopicSchema	object	TUBLE 类型，topic 内容模式。
Form	string	转换的格式。默认为 CONSTANT。	CONSTANT
Template	string	无
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
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 名称	cat1
EventTableName	string	表名称	table1
MappingRules	array<object>	字段映射规则
	array<object>	映射规则
ColumnName	string	列名称	age
ColumnType	string	列类型	text
ColumnValue	object	列值提取规则
Form	string	提取方法	JSONPATH
Template	string	模板	The value of ${key} is ${value}!
Value	string	提取路径	$.data.value
NamespaceName	string	namespace 名称	name1
SinkFcParameters	object	函数目标。
Body	object	发送给函数的内容体。
Form	string	转换的格式。	TEMPLATE
Template	string	模板样式。	The value of ${key} is ${value}!
Value	string	转换前的值。	{ "key": "value" }
Concurrency	object	投递并发度，最小为 1。
Form	string	转换的格式。默认为 CONSTANT。	CONSTANT
Template	string	无
Value	string	投递并发度，最小为 1。	1
DataFormat	object	事件内容格式的转换规则。
Form	string	转换格式，默认为 CONSTANT。	CONSTANT
Template	string	模板样式。	The value of ${key} is ${value}!
Value	string	转换前的值。	{ "key": "value" }
FunctionName	object	函数名称。
Form	string	转换的格式。默认为 CONSTANT。	CONSTANT
Template	string	无
Value	string	函数名称。	mFunction
InvocationType	object	同步或则异步。 Sync：同步。 Async：异步。
Form	string	转换的格式。默认为 CONSTANT。	CONSTANT
Template	string	无
Value	string	同步或则异步。 Sync：同步。 Async：异步。	Async
Qualifier	object	函数所属服务的别名。
Form	string	转换的格式。默认为 CONSTANT。	CONSTANT
Template	string	无
Value	string	函数所属服务的别名。	LATEST
ServiceName	object	服务的名称。
Form	string	转换的格式。默认为 CONSTANT。	CONSTANT
Template	string	无
Value	string	服务的名称。	myService
SinkFnfParameters	object	Sink Fnf 参数。
ExecutionName	object	执行名称。
Form	string	转换的格式。默认为 CONSTANT。	CONSTANT
Template	string	模板样式。
Value	string	执行名称。	123
FlowName	object	流程名称。
Form	string	转换的格式。默认为 CONSTANT。	CONSTANT
Template	string	模板样式。
Value	string	流程名称。	test-streaming-fnf
Input	object	执行输入信息。
Form	string	转换的格式。默认为 CONSTANT。	CONSTANT
Template	string	模板样式。
Value	string	执行输入信息。	123
RoleName	object	角色配置。
Form	string	转换的格式。默认为 CONSTANT。	CONSTANT
Template	string	模板样式。
Value	string	角色配置。	Al**FNF-x**
SinkHttpsParameters	SinkHttpsParameters	Https 目标参数
SinkKafkaParameters	object	Sink kafka 参数。
Acks	object	写入 Kafka 确认模式： acks=0：无需服务端的 Response、性能较高、丢数据风险较大。 acks=1：服务端主节点写成功即返回 Response、性能中等、丢数据风险中等、主节点宕机可能导致数据丢失； acks=all：服务端主节点写成功且备节点同步成功才返回 Response、性能较差、数据较为安全、主节点和备节点都宕机才会导致数据丢失。
Form	string	转换的格式。默认为 CONSTANT。	CONSTANT
Template	string	无
Value	string	写入 Kafka 确认模式： acks=0：无需服务端的 Response、性能较高、丢数据风险较大。 acks=1：服务端主节点写成功即返回 Response、性能中等、丢数据风险中等、主节点宕机可能导致数据丢失； acks=all：服务端主节点写成功且备节点同步成功才返回 Response、性能较差、数据较为安全、主节点和备节点都宕机才会导致数据丢失。	1
CompressionType	string
DynamicTopic	object	指定消息路由的目标 Topic 策略。若同时指定了 topic 参数和 topics 参数，以 topics 参数的值为准。支持以下两种配置模式： 1. 静态常量模式：直接填写固定的 Topic 名称字符串（例如："order_created"）。所有消息将统一发送至该 Topic。 2. 动态提取模式：填写标准的 JSONPath 表达式（例如："$.user.id" 或 "$.metadata.category"）。系统将解析上游消息体，提取匹配字段的值作为目标 Topic 名称。
Form	string	转换的类型 CONSTANT：固定值 JSONPATH：根据路径从上游提取
Template	string	模板
Value	string	值
InstanceId	object	目标服务类型为消息队列 Kafka 版。
Form	string	转换的格式。默认为 CONSTANT。	CONSTANT
Template	string	无
Value	string	实例 ID。	Defaut_1283278472_sad****
Key	object	消息的标识。
Form	string	转换的格式。默认为 CONSTANT。	CONSTANT
Template	string	无
Value	string	消息的标识。	key
Topic	object	主题名称。
Form	string	转换的格式。默认为 CONSTANT。	CONSTANT
Template	string	无
Value	string	主题名称。	topic
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	转换的格式。	TEMPLATE
Template	string	模板样式。	The value of ${key} is ${value}!
Value	string	转换前的值。	{ "key": "value" }
IsBase64Encode	object	是否开启 Base64 编码。
Form	string	转换的格式。默认为 CONSTANT。	CONSTANT
Template	string	无
Value	string	开启 Base64 编码。	true
QueueName	object	目标服务类型为轻量消息队列（原 MNS）。
Form	string	转换的格式。默认为 CONSTANT。	CONSTANT
Template	string	无
Value	string	轻量消息队列（原 MNS）的 Queue 的名称。	MyQueue
SinkMQTTParameters	SinkMQTTParameters
SinkOSSParameters	SinkOSSParameters
SinkOpenSourceRabbitMQParameters	object	Sink Open Source RabbitMQ 参数。
AuthType	string	认证类型。	ACL
Body	object	消息内容。
Form	string	转换的格式。	TEMPLATE
Template	string	模板样式。	The value of ${key} is ${value}!
Value	string	转换前的值。	{ "key": "value" }
Endpoint	string	RabbitMQ 实例接入点。	192.168.1.1:9876
Exchange	string	用于消息路由的交换机名称。	my_exchange
MessageId	object	消息 ID。
Form	string	转换的格式。	TEMPLATE
Template	string	模板样式。	The value of ${key} is ${value}!
Value	string	转换前的值。	{ "key": "value" }
NetworkType	string	网络类型。	PrivateNetwork
Password	string	用于身份验证的用户名密码。	****
Properties	object	过滤属性。
Form	string	转换的格式。	TEMPLATE
Template	string	模板样式。	The value of ${key} is ${value}!
Value	string	转换前的值。	{ "key": "value" }
QueueName	string	用于存储消息的队列名称。	my_queue
RoutingKey	object	消息的路由规则。仅当参数 TargetType 配置为 Exchange 时，需配置此参数。
Form	string	数据格式，默认为 JSONPATH。	JSONPATH
Template	string	模板样式。	The value of ${key} is ${value}!
Value	string	消息的路由规则。	housekeeping
SecurityGroupId	string	安全组 ID。	sg-2vcgdxz7o1n9zapp****
TargetType	string	目标类型。	exchange
Username	string	用于身份验证的用户名。	admin
VSwitchIds	string	交换机 ID。	vsw-wz9qqeovkwjxlu9uc****
VirtualHostName	string	RabbitMQ 的虚拟主机名称。	Vhost1
VpcId	string	VPC ID。	vpc-2zehizpoendb3****
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	无
Value	string	消息队列 RabbitMQ 版实例的 Exchange 的名称。	a_exchange
InstanceId	object	目标服务类型为消息队列 RabbitMQ 版。
Form	string	转换的格式。默认为 CONSTANT。	CONSTANT
Template	string	无
Value	string	消息队列 RabbitMQ 版的实例 ID。	si-296cd57939a1421b****
MessageId	object	消息 ID。
Form	string	转换的格式。	TEMPLATE
Template	string	模板样式。	The value of ${key} is ${value}!
Value	string	转换前的值。	{ "key": "value" }
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	无
Value	string	实例的 Queue 的名称。	MyQueue
RoutingKey	object	消息的路由规则。仅当参数 TargetType 配置为 Exchange 时，需配置此参数。
Form	string	转换的格式。默认为 CONSTANT。	CONSTANT
Template	string	无
Value	string	消息的路由规则。	housekeeping
TargetType	object	目标类型。
Form	string	转换的格式。默认为 CONSTANT。	CONSTANT
Template	string	无
Value	string	目标类型。取值说明如下： Exchange：Exchange 模式。 Queue：Queue 模式。	Queue
VirtualHostName	object	消息队列 RabbitMQ 版实例的 Vhost 的名称。
Form	string	转换的格式。默认为 CONSTANT。	CONSTANT
Template	string	无
Value	string	消息队列 RabbitMQ 版实例的 Vhost 的名称。	rabbit-host
SinkRocketMQCheckpointParameters	object	Sink RocketMQ Checkpoint 参数。
ConsumeTimestamp	object	消费位点。
Form	string	转换格式，默认为 CONSTANT。	CONSTANT
Template	string	模板样式。
Value	string	时间戳。	1636597951964
Group	object	消息队列 RocketMQ 版的消费者分组信息。
Form	string	转换格式，默认为 CONSTANT。	CONSTANT
Template	string	模板样式。
Value	string	消费者分组的 Group ID。	GID_******
InstanceId	string	RocketMQ 实例 ID。	MQ_INST_1825725063814405_BZ******
InstanceType	string	消息队列 RocketMQ 版的实例类型。	Cloud_5
Topic	object	消息队列 RocketMQ 版实例的 Topic。
Form	string	转换格式，默认为 CONSTANT。	CONSTANT
Template	string	模板样式。
Value	string	Topic 的名称。	myTopic
SinkRocketMQParameters	object	Sink RocketMQ 源。
Body	object	消息内容。
Form	string	转换的格式。	TEMPLATE
Template	string	模板样式。	The value of ${key} is ${value}!
Value	string	转换前的值。	{ "key": "value" }
DeliveryOrderType	object	消息的投递顺序类型。
Form	string	转换格式，默认为 CONSTANT。	CONSTANT
Template	string	无
Value	string	投递顺序类型。	Orderly
InstanceEndpoint	object	实例接入点。
Form	string	转换的格式。默认为 CONSTANT。	CONSTANT
Template	string	无
Value	string	实例接入点。	vbr-8vbsvkkbpf3vb0zef****
InstanceId	object	目标服务类型为消息队列 RocketMQ 版。
Form	string	转换的格式。默认为 CONSTANT。	CONSTANT
Template	string	无
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	转换格式，默认为 CONSTANT。	CONSTANT
Template	string	模板样式。
Value	string	分片键值。	order_id
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	无
Value	string	消息队列 RocketMQ 版实例的 Topic。	topic
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。	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。	CONSTANT
Template	string	无
Value	string	SLS 数据格式。可选择默认或者配置制定的键值： JSON KeyValue	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 控制台创建服务所使用的角色时，需要选择“阿里云服务”，并且“受信服务”需要选择“事件总线”。	test-role
Topic	object	日志所在的 topic，对应 SLS 保留字段“topic”。
Form	string	转换的格式。默认为 CONSTANT。	CONSTANT
Template	string	无
Value	string	日志所在的 topic，对应 SLS 保留字段“topic”。	topic
Source	object	事件提供方。
SourceApacheRocketMQCheckpointParameters	object	Source RocketMQ Checkpoint 源
InstanceEndpoint	string	Apache RocketMQ 实例的接入点。	192.168.1.1:9876
InstancePassword	string	Apache RocketMQ 实例的密码。	****
InstanceUsername	string	Apache RocketMQ 实例的用户名。	admin
NetworkType	string	网络类型。	PrivateNetwork
RegionId	string	地域 ID。	cn-hangzhou
SecurityGroupId	string	安全组 ID。	sg-mw43*****
Topics	array	Apache RocketMQ 实例 Topic。
	string	Apache RocketMQ 实例 Topic。	myTopic
VSwitchId	string	交换机 ID。	vsw-dwaafds****
VpcId	string	VPC ID。	vpc-adw1awdw*****
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	实例 ID。	gtm-cn-k2c2yfg****
SourceDTSParameters	object	Source DTS 源。
BrokerUrl	string	数据订阅通道的网络地址及端口号信息。
InitCheckPoint	string	消费位点，即 SDK 客户端消费第一条数据的时间戳，格式为 Unix 时间戳。	1620962769
Password	string	消费组的账号密码。	123456
Sid	string	消费组 ID。	HG9
TaskId	string	任务 ID。	1611b337285f44e2936a2c4170****
Topic	string	数据订阅通道的订阅 Topic。	TP_TEST_UNDERWRITE_ISSUE
Username	string	消费组的账号。	admin
SourceEventBusParameters	object	Source EventBus 源。
EventBusName	string	事件总线名称。	my-event-bus
EventRuleName	string	事件规则名称。	my-event-rule
SourceFeiShuDocsParameters	SourceFeiShuDocsParameters
SourceJDBCParameters	SourceJDBCParameters
SourceKafkaParameters	object	Source Kafka 源。
ConsumerGroup	string	订阅该 Topic 的消费者所对应的 Group ID。	GID_TEST
InstanceId	string	实例 id。	bastionhost-cn-i7m2gwt****
Network	string	网络配置：默认值 Default，vpc 网络是 PublicNetwork。	Default
OffsetReset	string	偏移量。	latest
RegionId	string	实例所在地域 id。	cn-chengdu
SecurityGroupId	string	安全组 ID。	sg-5ud5f3p0rqqis69****eho7cp
Topic	string	Topic 名称。	topic_empower_1642473600414
VSwitchIds	string	交换机 ID。	vsw-bp1rmi8rind7eo50c****
ValueDataType	string	消息体编解码格式： JSON Text Binary	JSON
VpcId	string	用户的 VPC ID。	vpc-wz9ki1qdlx3cx5cbf****
SourceMNSParameters	object	Source 轻量消息队列（原 MNS）源。
IsBase64Decode	boolean	是否开启 Base64 编码。	true
QueueName	string	轻量消息队列（原 MNS）的 Queue 的名称。	work4
RegionId	string	地域 ID。	cn-zhangjiakou
SourceMQTTParameters	object	Source MQTT 源。
BodyDataType	string	消息编码格式： JSON Text Binary	JSON
InstanceId	string	实例 id。	bastionhost-cn-zvp27kc****
NetworkType	string	网络类型。
RegionId	string	地域 ID。	cn-qingdao
SecurityGroupId	string	安全组 ID。
Topic	string	Topic 名称。	migration_instance
VSwitchIds	string	虚拟交换机 ID。
VpcId	string	VPC ID。
SourceMySQLParameters	SourceMySQLParameters	Source MySQL 源。
SourceOSSParameters	object	Source OSS 事件源。
BucketName	string	对象存储 OSS 中的存储空间名称。	bucket_abc
Delimiter	string	分隔符，在分块加载模式下，以该分隔符作为文本的分块标识符，默认以换行符\n 作为分隔符。	\n
LoadFormat	string	文档加载器。	TextLoader
LoadMode	string	数据加载模式，single 表示单文档加载，element 表示分块加载。取值：single/element 默认为 single。	single
Prefix	string	文件路径前缀。	fun/document/
RoleName	string	授权事件总线 EventBridge 读取 OSS 文件的角色名称，要求该角色至少具有 OSS 的只读权限。	eventbridge_oss_role
SourceOpenSourceRabbitMQParameters	object	Source Open Source RabbitMQ 源。
AuthType	string	鉴权类型。	ACL
BodyDataType	string	消息体数据类型。	Json
Endpoint	string	实例接入点。	192.168.1.1:9876
NetworkType	string	网络类型。	PrivateNetwork
Password	string	连接开源 RabbitMQ 实例时使用的密码。	****
QueueName	string	开源 RabbitMQ 实例的队列名称。	demo
SecurityGroupId	string	安全组 ID。	sg-m5edtu24f12345****
Username	string	连接开源 RabbitMQ 实例时使用的用户名。	admin
VSwitchIds	string	交换机 ID。	vsw-m5ev8asdc6h12345****
VirtualHostName	string	开源 RabbitMQ 实例的虚拟主机名称。	Vhost1
VpcId	string	VPC ID。	vpc-m5e3sv4b12345****
SourcePostgreSQLParameters	SourcePostgreSQLParameters
SourcePrometheusParameters	object	Source Prometheus 事件源。
ClusterId	string	集群 ID。	c83555068b6******ad213f565f209
DataType	string	数据类型。	JSON
ExternalLabels	string	事件中附加的自定义标签。	{"source":"prometheus-prod"}
Labels	string	标签。	__name__=.*
RegionId	string	地域 ID。	cn-beijing
RoleName	string	访问 Prometheus 数据的角色。	testRole
SourceRabbitMQMetaParameters	SourceRabbitMQMetaParameters
SourceRabbitMQMsgSyncParameters	SourceRabbitMQMsgSyncParameters
SourceRabbitMQParameters	object	Source RabbitMQ 源。
InstanceId	string	消息队列 RabbitMQ 版的实例的 ID。	dbaudit-cn-7mz2hqo****
QueueName	string	消息队列 RabbitMQ 版实例的 Queue 的名称。	liuyang
RegionId	string	地域 ID。	cn-zhangjiakou
VirtualHostName	string	消息队列 RabbitMQ 版实例的 Vhost 的名称。	eb-connect
SourceRocketMQCheckpointParameters	object	Source RocketMQ Checkpoint 源
InstanceId	string	消息队列 RocketMQ 版实例 ID。	rmq-cn-jte3w******
InstanceType	string	消息队列 RocketMQ 版实例的类型。	Cloud_5
RegionId	string	地域 ID。	cn-hangzhou
Topics	array	消息队列 RocketMQ 版实例 Topic。
	string	消息队列 RocketMQ 版实例 Topic。	myTopic
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	实例接入点。	registry-vpc.cn-hangzhou.aliyuncs.com
InstanceId	string	消息队列 RocketMQ 版的实例 id。	i-f8zbher64dlm58pl****
InstanceNetwork	string	实例网络信息： PublicNetwork PrivateNetwork	PublicNetwork
InstancePassword	string	实例密码。	123
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 的 ID。	vpc-bp1a4gmlk31hy***l3ss
Network	string	网络类型。 PublicNetwork PrivateNetwork	PublicNetwork
Offset	string	消息的消费位点。取值说明如下： CONSUMEFROMLASTOFFSET：从最新位点开始消费。 CONSUMEFROMFIRSTOFFSET：从最早位点开始消费。 CONSUMEFROMTIMESTAMP：从指定时间点的位点开始消费。	CONSUMEFROMTIMESTAMP
RegionId	string	消息队列 RocketMQ 版的地域 ID。	cn-chengdu
SecurityGroupId	string	安全组 ID。	sg-m5edtu24f12345****
Tag	string	消息的过滤标签。	v1
Timestamp	integer	时间戳。仅当参数 Offset 取值为 CONSUMEFROMTIMESTAMP 时，该参数有效。	1670742074043
Topic	string	消息的 Topic。	topic_add_anima
VSwitchIds	string	虚拟交换机 ID。	vsw-m5ev8asdc6h12345****
VpcId	string	VPC 的 ID。	vpc-m5e3sv4b12345****
SourceSLSParameters	object	Source SLS 源。
ConsumePosition	string	起始消费位点，可以选择最早或最新位点，分别对应“begin”，“end”，也可以从指定时间开始消费，以秒为单位。	begin
ConsumerGroup	string	订阅该 Topic 的消费者所对应的 Group ID。	go-dts-shelf-group
LogStore	string	日志服务 SLS 的日志库。	waf-logstore
Project	string	日志服务 SLS 的日志项目。	dmmzk
RoleName	string	授权事件总线 EventBridge 使用此角色读取 SLS 日志内容时，需满足条件：在 RAM 控制台创建服务所使用的角色时，需要选择“阿里云服务”，并且“受信服务”需要选择“事件总线”。	testRole
Status	string	获取到的事件流的状态。	RUNNING
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
NextToken	string	用来表示当前调用返回读取到的位置，空代表数据已经读取完毕。下次调用时，需要将此设置到入参 NextToken 中。	177
Total	integer	总共记录数。	10
Message	string	错误信息。	The event streaming [xxxx] not existed!
RequestId	string	阿里云为该请求生成的唯一标识符。	283FF852-C4B8-58C9-9777-F88A5A16****
Success	boolean	操作成功返回 true。	true

错误码

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

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

变更历史

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