CreateEventStreaming
创建一个事件流
服务地址：
华东1（杭州）
输入参数
只看必填
EventStreamingName事件流的名称
Description事件流的描述
FilterPattern事件过滤规则
Source事件提供方
SourceMNSParametersSource MNS 参数
RegionId地域id
QueueName队列名称
IsBase64Decode是否开启Base64编码
请选择布尔值
SourceRabbitMQParametersSource RabbitMQ源
RegionId地域ID
InstanceId消息队列RabbitMQ版实例的实例ID
VirtualHostName消息队列RabbitMQ版实例的Vho...
QueueName消息队列RabbitMQ版实例的Que...
SourceKafkaParametersSource Kafka源
RegionId地域ID
InstanceId实例ID
TopicTopic名称
ConsumerGroup订阅该Topic的消费者所对应的Gro...
OffsetReset偏移量
Network网络配置
VpcIdVPC ID
VSwitchIds虚拟交换机ID
SecurityGroupId安全组ID
ValueDataType消息体编解码格式：
SourceRocketMQParametersSource RocketMQ源
RegionId地域ID
InstanceId消息队列RocketMQ版的实例所属地域
Topic消息服务的主题
Tag消息的过滤标签
Offset消息的消费位点
GroupID消息队列RocketMQ版的Group ID
Timestamp时间戳
InstanceType实例类型
InstanceEndpoint实例接入点
InstanceUsername实例用户名
InstancePassword实例密码
Network网络类型：
FilterType消息过滤类型
FilterSqlsql过滤语句
AuthType鉴权类型
VpcId跨境任务VPC ID
VSwitchIds跨境任务vSwitchIds
SecurityGroupId跨境任务安全组
InstanceVpcId实例VPC信息
InstanceVSwitchIds实例交换机信息
InstanceSecurityGroupId实例安全组信息
InstanceNetwork实例网络信息：
BodyDataType消息编码格式
SourceRocketMQCheckpointParametersSource RocketMQ Che...
RegionId
InstanceType
InstanceId
Topics
0
添加
SourceApacheRocketMQCheckpointParametersSource RocketMQ Che...
RegionId
Topics
0
添加
InstanceEndpoint
InstanceUsername
InstancePassword
NetworkType
VpcId
VSwitchId
SecurityGroupId
SourceMQTTParametersSource MQTT源
RegionId地域ID
InstanceId实例ID
Topic消息的Topic
BodyDataType消息编码格式：
SourceDTSParametersSource DTS源
TaskId任务id
BrokerUrl数据订阅通道的网络地址及端口号信息
Topic数据订阅通道的订阅Topic
Sid消费组ID
Username消费组的账号
Password消费组的账号密码
InitCheckPoint消费位点
SourceSLSParametersSource SLS源
Project日志服务SLS的日志项目
LogStore日志服务SLS的日志库
ConsumePosition起始消费位点
RoleName授权事件总线EventBridge使用...
SourcePrometheusParametersSource Prometheus 事件源
RegionId地域ID
ClusterId集群id
DataType数据类型
Labels标签
RoleName
ExternalLabels
SourceCustomizedKafkaParameters自定义 Kafka 事件源
InstanceId消息队列Kafka版的实例ID
SourceCustomizedKafkaConnectorParameters自定义连接器 Apache Kafka...
ConnectorPackageUrlOSS资源ZIP包下载链接
WorkerParameterskafka实例配置
ConnectorParameters连接器参数
Name连接器名称
Config连接器配置
SourceOSSParametersSource OSS 事件源
RoleName授权事件总线 EventBridge ...
BucketName对象存储OSS中的存储空间名称
Prefix文件路径前缀
LoadMode数据加载模式
LoadFormat文档加载器
Delimiter分隔符
SourceOpenSourceRabbitMQParameters
Endpoint
VirtualHostName
QueueName
BodyDataType
Username
Password
VpcId
VSwitchIds
SecurityGroupId
NetworkType
AuthType
SourceEventBusParameters
EventBusName
EventRuleName
Sink事件目标
SinkMNSParametersMNS事件目标
QueueName目标服务类型为消息服务MNS
Value消息服务MNS的Queue的名称
Form转换的格式
Template模板样式
Body消息内容
Value转换前的值
Form转换的格式
Template模板样式
IsBase64Encode是否开启Base64编码
Value开启Base64编码
Form事件转换的格式
Template模板样式
SinkRabbitMQParametersSink Rabbitmq的参数
InstanceId目标服务类型为消息队列RabbitMQ版
Value消息队列RabbitMQ版的实例ID
Form转换的格式
Template模板样式
VirtualHostName消息队列RabbitMQ版实例的Vho...
Value消息队列RabbitMQ版实例的Vho...
Form转换的格式
Template模板样式
TargetType目标类型
Value目标类型
Form转换的格式
Template模板样式
ExchangeExchange模式
Value消息队列RabbitMQ版实例的Exc...
Form转换的格式
Template模板样式
RoutingKey消息的路由规则
Value消息的路由规则
Form转换的格式
Template模板样式
QueueNameQueue模式
Value实例的Queue的名称
Form转换的格式
Template模板样式
Body消息内容
Value转换前的值
Form转换的格式
Template模板样式
MessageId消息ID
Value转换前的值
Form转换的格式
Template模板样式
Properties过滤属性
Value转换前的值
Form转换的格式
Template模板样式
SinkKafkaParametersSink kafak 参数
InstanceId目标服务类型为消息队列Kafka版
Value实例ID
Form转换的格式
Template模板样式
Topic主题名称
Value主题的名称
Form转换的格式
Template模板样式
Acks写入Kafka确认模式：
Value写入Kafka确认模式：
Form转换的格式
Template模板样式
Key消息键
Value消息键
Form转换的格式
Template模板样式
Value消息体
Value转换前的值
Form转换的格式
Template模板样式
SinkFcParameters函数目标
ServiceName服务名
Value服务名
Form转换的格式
Template模板样式
FunctionName函数名
Value函数名
Form转换的格式
Template模板样式
Concurrency投递并发度
Value投递并发度
Form转换的格式
Template模板样式
Qualifier服务版本
Value服务版本
Form转换的格式
Template模板样式
InvocationType同步或则异步
Value同步或则异步
Form转换的格式
Template模板样式
Body发送给函数的内容体
Value转换前的值
Form转换的格式：
Template模板样式
DataFormat
Value
Form
Template
SinkRocketMQParametersSink RocketMQ Param...
InstanceId目标服务类型为消息队列RocketMQ版
Value消息队列RocketMQ版的实例ID
Form转换的格式
Template模板样式
Topic消息队列RocketMQ版实例的Topic
Value消息队列RocketMQ版实例的Top...
Form转换的格式
Template模板样式
Body消息内容
Value转换前的值
Form转换的格式
Template模板样式
Properties过滤属性
Value转换前的值
Form转换的格式
Template模板样式
Keys过滤属性
Value转换前的值
Form转换的格式
Template模板样式
Tags过滤属性
Value转换前的值
Form转换的格式
Template模板样式
InstanceType实例类型
Value实例类型
Form转换的格式
Template无
InstanceEndpoint实例接入点
Value实例接入点
Form转换的格式
Template无
InstanceUsername实例用户名
Value实例用户名
Form转换的格式
Template无
InstancePassword实例密码
Value实例密码
Form转换的格式
Template无
VpcIdVPC的ID
ValueVPC的ID
Form事件转换的格式
Template无
VSwitchIds交换机ID
Value交换机ID
Form转换的格式
Template无
SecurityGroupId安全组ID
Value安全组ID
Form转换的格式
Template无
Network网络类型：
Value网络类型：
Form转换的格式
Template无
DeliveryOrderType
Value
Form
Template
ShardingKey
Value
Form
Template
SinkRocketMQCheckpointParameters事件源类型
InstanceType
InstanceId
Topic
Value
Form
Template
ConsumeTimestamp
Value
Form
Template
Group
Value
Form
Template
SinkApacheRocketMQCheckpointParameters事件源类型
Topic
Value
Form
Template
ConsumeTimestamp
Value
Form
Template
Group
Value
Form
Template
InstanceEndpoint
InstanceUsername
InstancePassword
NetworkType
VpcId
VSwitchId
SecurityGroupId
SinkSLSParametersSink SLS Parameters
Project日志服务SLS的日志项目
Value日志服务SLS的日志项目
Form转换的格式
Template无
LogStore日志服务SLS的日志库
Value日志服务SLS的日志库
Form转换的格式
Template无
Topic日志所在的Topic
Value日志所在的Topic
Form转换的格式
Template无
Body发送给SLS的内容
Value转换前的值
Form转换的格式
Template模板样式
RoleName授权事件总线EventBridge使用...
Value授权事件总线EventBridge使用...
Form转换的格式
Template无
ContentTypeSLS数据格式
Value转换前的值
Form转换的格式
Template模板样式
ContentSchema自定义日志的键值
Value转换前的值
Form模板样式
Template模板样式
SinkDataHubParametersSink DataHub 参数
ProjectDataHub项目名
ValueDataHub项目名
Form转换的格式
Template无
TopicDataHub Topic名称
ValueDataHub Topic名称
Form转换的格式
Template无
TopicTypetopic 类型： ...
Valuetopic 类型： ...
Form转换的格式
Template无
TopicSchemaTUBLE类型
ValueTUBLE类型
Form转换的格式
Template模板样式
BodyBLOB类型
ValueBLOB类型
Form转换的格式
Template无
RoleName任务角色名
Value任务角色名称
Form转换的格式
Template无
SinkFnfParametersSink Fnf 参数
FlowName流程名称
Value流程名称
Form转换的格式
Template模板样式
ExecutionName执行名称
Value执行名称
Form转换的格式
Template模板样式
Input执行输入信息
Value执行输入信息
Form转换的格式：
Template模板样式
RoleName角色配置
Value角色配置
Form转换的格式
Template模板样式
SinkPrometheusParametersSink Prometheus 参数
URLPrometheus Remote W...
ValuePrometheus Remote W...
Form转换的格式
Template模板样式（Form为CONSTANT时为空）
HeaderParameters请求头的参数数据结构
Value- Form为CONSTANT：常量值
Form转换的格式
TemplateHTTP请求头模板样式
AuthorizationType鉴权方式
Value鉴权方式
Form转换的格式
Template无
Username用户名
Value用户名
Form转换的格式
Template无
Password密码
Value密码
Form转换的格式
Template无
Data指标内容
Value指标内容
Form转换的格式
Template模板样式
NetworkType网络类型
Value网络类型
Form转换的格式
Template无
VpcIdVPC的ID
ValueVPC的ID
Form转换的格式
Template无
VSwitchId交换机ID
Value交换机ID
Form转换的格式
Template无
SecurityGroupId安全组ID
Value安全组ID
Form转换的格式
Template无
SinkCustomizedKafkaParametersSink Kafka 参数
InstanceId消息队列Kafka版的实例ID
SinkCustomizedKafkaConnectorParametersSink Kafka 连接器参数
ConnectorPackageUrlOSS文件下载链接
ConnectorParameters解析当前 ZIP 包下的 proper...
Name连接器名称
Config连接器配置
WorkerParameters实例配置
SinkDashVectorParametersSink DashVector 参数
InstanceId实例ID
CollectionCollection（集合）名称
ApiKeyDashVecotor控制台创建的AP...
OperationDashVector数据库操作类型
Network网络类型
PrimaryKeyId插入/删除记录时的主键ID
Form转换的格式
Value- Form为JSONPATH：JSO...
Template主键ID模板
PartitionPartition（分区）
Form转换的格式
Value- Form为CONSTANT：常量值
Template无
Vector插入DashVector记录的向量
Form转换的格式
ValueJSONPath提取内容
Template无
DashVectorSchemaParameters插入DashVector时表项的Sch...
Form转换的格式
Value- Form为CONSTANT：常量值
TemplateSchema模板
SinkOpenSourceRabbitMQParameters
Endpoint
VirtualHostName
TargetType
Exchange
QueueName
Username
Password
VpcId
VSwitchIds
SecurityGroupId
NetworkType
AuthType
RoutingKey
Form
Value
Template
Body
Form
Value
Template
MessageId
Form
Value
Template
Properties
Form
Value
Template
RunOptions运行环境参数
MaximumTasks并发数
ErrorsTolerance异常容忍策略：
RetryStrategy事件推送失败时的重试策略
PushRetryStrategy重试策略：
MaximumEventAgeInSeconds最大重试时间
MaximumRetryAttempts最大重试次数
DeadLetterQueue是否启用死信队列
Arn死信队列ARN
BatchWindow攒批窗口
CountBasedWindow窗口中最大可容纳的事件数量
TimeBasedWindow窗口中最大可容纳的时间范围内的事件（单位秒）
TransformsTransform 相关配置
0云产品的 ARN
Arn云产品的 ARN
添加
插件下载了解更多
VS Code 插件
安装插件之前，确保已安装 VS Code安装插件之前，确保已安装 VS Code
Alibaba Cloud Developer ToolkitbetaAlibaba Cloud OpenAPI
Alibaba Cloud Developer Toolkit is a collection of extensions that can help access Alibaba Cloud services in Visual Studio Code.
安 装
JetBrains 插件
安装插件之前，确保已安装 JetBrains IDE安装插件之前，确保已安装 JetBrains IDE
Alibaba Cloud Developer ToolkitbetaAlibaba Cloud OpenAPI
The Alibaba Cloud Developer Toolkit for JetBrains makes it easier to access Alibaba Cloud services.
安 装

接口说明

创建一个事件流。

请求参数

字段名称字段详情
EventStreamingNamestring

事件流的名称。

示例值:myeventstreaming字符长度 <= 255字符长度 >= 2
Descriptionstring

事件流的描述。

示例值:rocketmq2mns
FilterPatternstring

事件过滤规则，如果不指定表示匹配全部事件。

示例值:无
Sourceobject

事件提供方。必须选择一种 Source，且最多只能选择一种 Source 进行填选。

Sinkobject

事件目标。必须选择一种 Sink，且最多只能选择一种 Sink 进行填选。

RunOptionsobject

运行环境参数。

Transformsarray<object>

Transform 相关配置。

返回参数

字段名称字段详情
Messagestring

错误信息。

示例值:The name [xxxx] of event streaming in request is already exist!
RequestIdstring

请求 ID。

示例值:B896B484-F16D-59DE-9E23-DD0E5C36****
Dataobject

返回数据。

Codestring

接口返回码：展开详情

示例值:Success
Successboolean

操作成功返回 true。

示例值:true
变更历史
变更时间变更内容概要操作
2025-03-26
变更请求参数Source
变更请求参数Sink
2025-02-20
变更请求参数EventStreamingName
变更请求参数Source
变更请求参数Sink
2025-02-11
变更请求参数Source
2025-01-10
变更请求参数Sink
2024-09-10
变更请求参数Source
变更请求参数Sink
2024-09-09
变更请求参数RunOptions
2024-08-19
变更请求参数Source
2024-07-12
变更请求参数Sink
2024-05-31
变更请求参数Source