CreateEventStreaming - 创建一个事件流

地域 id。

队列名称。

是否开启 Base64 编码。默认为 true。

地域 ID。

消息队列 RabbitMQ 版实例的实例 ID。

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

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

地域 ID。

实例 ID。

Topic 名称。

订阅该 Topic 的消费者所对应的 Group ID。

偏移量。

网络配置。 默认值 Default，VPC 网络是 PublicNetwork。

VPC ID。

虚拟交换机 ID。

安全组 ID。

消息体编解码格式：

• JSON
• Text
• Binary

地域 ID。

消息队列 RocketMQ 版的实例所属地域。

消息服务的主题。

消息的过滤标签。

消息的消费位点。取值说明如下：

• CONSUME_FROM_LAST_OFFSET：从最新位点开始消费。
• CONSUME_FROM_FIRST_OFFSET：从最早位点开始消费。
• CONSUME_FROM_TIMESTAMP：从指定时间点的位点开始消费。

默认值：CONSUME_FROM_LAST_OFFSET。

消息队列 RocketMQ 版的 Group ID。

时间戳。仅当参数 Offset 取值为 CONSUME_FROM_TIMESTAMP 时，该参数有效。

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

• Cloud_4：阿里云 RocketMQ 4.0 版本实例（默认选项）
• Cloud_5：阿里云 RocketMQ 5.0 版本实例
• SelfBuilt：自建 Apache RocketMQ 集群

实例接入点。

实例用户名。

实例密码。

网络类型：

• PublicNetwork
• PrivateNetwork

消息过滤类型。

sql 过滤语句。

鉴权类型。

跨境任务 VPC ID。

跨境任务 vSwitchIds。

跨境任务安全组。

实例 VPC 信息。

实例交换机信息。

实例安全组信息。

实例网络信息：

• PublicNetwork
• PrivateNetwork

消息编码格式

• JSON
• Text
• Binary

地域 ID。

实例 ID。

消息的 Topic。

消息编码格式：

• JSON
• Text
• Binary

任务 id。

数据订阅通道的网络地址及端口号信息。

数据订阅通道的订阅 Topic。

消费组 ID。

消费组的账号。

消费组的账号密码。

消费位点，即 SDK 客户端消费第一条数据的时间戳，格式为 Unix 时间戳。

日志服务 SLS 的日志项目。

日志服务 SLS 的日志库。

起始消费位点，可以选择最早或最新位点，分别对应“begin”，“end”，也可以从指定时间开始消费，以秒为单位。

授权事件总线 EventBridge 使用此角色读取 SLS 日志内容时，需满足条件：在 RAM 控制台创建服务所使用的角色时，需要选择“阿里云服务”，并且“受信服务”需要选择“事件总线”。

地域 ID。

集群 id。

数据类型。

标签。

消息队列 Kafka 版的实例 ID。

OSS 资源 ZIP 包下载链接。

kafka 实例配置。

连接器参数。

授权事件总线 EventBridge 读取 OSS 文件的角色名称，要求该角色至少具有 OSS 的只读权限。

对象存储 OSS 中的存储空间名称。

文件路径前缀。

数据加载模式，single 表示单文档加载，element 表示分块加载。 取值：single/element 默认为 single

文档加载器。

分隔符，在分块加载模式下，以该分隔符作为文本的分块标识符，默认以换行符\n 作为分隔符。

目标服务类型为消息服务 MNS。

消息内容。

是否开启 Base64 编码。

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

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

目标类型。

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

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

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

消息内容。

消息 ID。

过滤属性。

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

主题名称。

写入 Kafka 确认模式：

• acks=0：无需服务端的 Response、性能较高、丢数据风险较大。
• acks=1：服务端主节点写成功即返回 Response、性能中等、丢数据风险中等、主节点宕机可能导致数据丢失；
• acks=all：服务端主节点写成功且备节点同步成功才返回 Response、性能较差、数据较为安全、主节点和备节点都宕机才会导致数据丢失。

消息键。

消息体。

服务名。

函数名。

投递并发度，最小 1。

服务版本。

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

发送给函数的内容体。

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

消息队列 RocketMQ 版实例的 Topic。

消息内容。

过滤属性。

过滤属性。

过滤属性。

实例类型。

实例接入点。

实例用户名。

实例密码。

VPC 的 ID。

交换机 ID。

安全组 ID。

网络类型：

• PublicNetwork
• PrivateNetwork

日志服务 SLS 的日志项目。

日志服务 SLS 的日志库。

日志所在的 Topic，对应 SLS 保留字段“topic”。

发送给 SLS 的内容。

授权事件总线 EventBridge 使用此角色读取 SLS 日志内容时，需满足条件：在 RAM 控制台创建服务所使用的角色时，需要选择“阿里云服务”，并且“受信服务”需要选择“事件总线”。

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

• JSON
• KeyValue

自定义日志的键值，仅在 ContentType 为 KeyValue 生效。每一对键值由 Key_n，Value_n 表示。

DataHub 项目名。

DataHub Topic 名称。

topic 类型：

• TUPLE
• BLOB

TUBLE 类型，topic 内容模式。

BLOB 类型，Record 内容模板。

任务角色名。

流程名称。

执行名称。

执行输入信息。

角色配置。

Prometheus Remote Write URL 地址。

请求头的参数数据结构。

鉴权方式。

用户名。

密码。

指标内容。

网络类型。

VPC 的 ID。

交换机 ID。

安全组 ID。

消息队列 Kafka 版的实例 ID。

OSS 文件下载链接。

解析当前 ZIP 包下的 properties 文件。

实例配置。

实例 ID。

Collection（集合）名称。

DashVecotor 控制台创建的 API Key。

DashVector 数据库操作类型。

网络类型。

插入/删除记录时的主键 ID。

Partition（分区），默认值为 default 分区。

插入 DashVector 记录的向量。

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

重试策略：

• BACKOFF_RETRY：退避重试。
• EXPONENTIAL_DECAY_RETRY：指数衰减重试。

最大重试时间。

最大重试次数。

死信队列 ARN。

窗口中最大可容纳的事件数量。当达到此阈值，会触发窗口内的数据往下游推送。当存在多个窗口时，有一个窗口满足即触发。

窗口中最大可容纳的时间范围内的事件（单位秒）。当达到此阈值，会触发窗口内的数据往下游推送。当存在多个窗口时，有一个窗口满足即触发。

云产品的 ARN，比如函数计算中函数的 ARN。