GetEventStreaming - 获取一个事件流的详细信息

获取一个事件流的详细信息。

接口说明

获取一个事件流的详细信息。

调试

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

授权信息

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

  • 操作:是指具体的权限点。
  • 访问级别:是指每个操作的访问级别,取值为写入(Write)、读取(Read)或列出(List)。
  • 资源类型:是指操作中支持授权的资源类型。具体说明如下:
    • 对于必选的资源类型,用前面加 * 表示。
    • 对于不支持资源级授权的操作,用全部资源表示。
  • 条件关键字:是指云产品自身定义的条件关键字。
  • 关联操作:是指成功执行操作所需要的其他权限。操作者必须同时具备关联操作的权限,操作才能成功。
操作访问级别资源类型条件关键字关联操作
eventbridge:GetEventStreamingget
*EventStreaming
acs:eventbridge:{#regionId}:{#accountId}:eventstreaming/{#EventStreamingName}

请求参数

名称类型必填描述示例值
EventStreamingNamestring

要获取信息的事件流的名称。

myeventstreaming

返回参数

名称类型描述示例值
object

返回信息。

Messagestring

错误信息。

The event streaming [xxxx] not existed!
RequestIdstring

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

7892F480-58C9-5067-AB35-8A7BEF****
Dataobject

返回数据。

EventStreamingNamestring

获取到的事件流的名称。

rocketmq-sync
Descriptionstring

获取到的事件流的描述。

RocketMQ-to-RocketMQ
Sourceobject

事件提供方。

SourceMNSParametersobject

Source 轻量消息队列(原 MNS) 参数。

RegionIdstring

地域 ID。

cn-hangzhou
QueueNamestring

轻量消息队列(原 MNS)的 Queue 的名称。

demo
IsBase64Decodeboolean

是否开启 Base64 编码。

true
SourceRabbitMQParametersobject

Source RabbitMQ 源。

RegionIdstring

地域 ID。

cn-hangzhou
InstanceIdstring

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

i-f8z9a9mcgwri1c1i****
VirtualHostNamestring

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

eb-connect
QueueNamestring

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

comp
SourceRocketMQParametersobject

Source RocketMQ 源。

RegionIdstring

消息队列 RocketMQ 版的地域 ID。

cn-hangzhou
InstanceIdstring

消息队列 RocketMQ 版的实例 ID。

i-f8zbher64dlm58pl****
Topicstring

消息的 Topic。

topic_add_anima
Tagstring

消息的过滤标签

v1
Offsetstring

消息的消费位点。取值说明如下: CONSUME_FROM_LAST_OFFSET:从最新位点开始消费。 CONSUME_FROM_FIRST_OFFSET:从最早位点开始消费。 CONSUME_FROM_TIMESTAMP:从指定时间点的位点开始消费。

CONSUMEFROMLASTOFFSET
GroupIDstring

消息队列 RocketMQ 版的 Group ID。

GID_group1
Timestamplong

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

1636597951964
InstanceTypestring

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

  • Cloud_4:阿里云 RocketMQ 4.0 版本实例(默认选项)
  • Cloud_5:阿里云 RocketMQ 5.0 版本实例
  • SelfBuilt:自建 Apache RocketMQ 集群
Cloud_4
InstanceEndpointstring

实例接入点。

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

鉴权类型。

ACL
InstanceUsernamestring

实例用户名。

xxxa
InstancePasswordstring

实例密码。

xxxa
InstanceVpcIdstring

实例 VPC 信息。

vpc-m5e3sv4b12345****
InstanceVSwitchIdsstring

实例交换机信息。

vsw-m5ev8asdc6h12****
InstanceSecurityGroupIdstring

实例安全组信息。

sg-m5edtu24f12345****
InstanceNetworkstring

实例网络信息:

  • PublicNetwork
  • PrivateNetwork
PublicNetwork
BodyDataTypestring

消息编码格式:

  • Json
  • Text
  • Binary
Json
FilterTypestring

消息过滤类型。

Tag
FilterSqlstring

sql 过滤语句。

index > 10
VpcIdstring

VPC 的 ID。

vpc-m5e3sv4b12345****
VSwitchIdsstring

交换机 ID。

vsw-m5ev8asdc6h12345****
SecurityGroupIdstring

安全组 ID。

sg-m5edtu24f12345****
Networkstring

网络类型。

  • PublicNetwork
  • PrivateNetwork
PublicNetwork
SourceRocketMQCheckpointParametersobject

Source RocketMQ Checkpoint 源

RegionIdstring

地域 ID。

cn-hangzhou
InstanceTypestring

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

  • Cloud_4:阿里云 RocketMQ 4.0 版本实例(默认选项)
  • Cloud_5:阿里云 RocketMQ 5.0 版本实例
  • SelfBuilt:自建 Apache RocketMQ 集群
Cloud_4
InstanceIdstring

实例 ID。

rmp-cn-jte3w******
Topicsarray

消息 Topic。

Topicsstring

消息 Topic。

opic_add_anima
SourceApacheRocketMQCheckpointParametersobject

Source RocketMQ Checkpoint 源

RegionIdstring

地域 ID。

cn-hangzhou
InstanceIdstring

RocketMQ 实例 ID。

MQ_INST_164901546557****_BAAN****
Topicsarray

Topic 列表。

Topicsstring

需要消费 Topic 列表。

["Topic_1","Topic_2"]
InstanceEndpointstring

实例接入点。

registry-vpc.cn-hangzhou.aliyuncs.com
InstanceUsernamestring

实例用户名。

admin
InstancePasswordstring

实例密码。

123456
NetworkTypestring

网络类型。

PrivateNetwork
VpcIdstring

VPC ID。

vpc-adw1awdw*****
VSwitchIdstring

交换机 ID。

vsw-dwaafds****
SecurityGroupIdstring

安全组 ID。

sg-mw43*****
SourceKafkaParametersobject

Source Kafka 源。

RegionIdstring

实例所在地域 id。

cn-hangzhou
InstanceIdstring

实例 id。

i-bp1fbtrnqmjvgq66****
Topicstring

Topic 名称。

topic_empower_1642473600414
ConsumerGroupstring

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

GID_TEST
OffsetResetstring

偏移量。

latest
Networkstring

网络配置 :默认值 Default,vpc 网络是 PublicNetwork

Default
VpcIdstring

VPC ID

vpc-2zehizpoendb3****
VSwitchIdsstring

虚拟交换机 ID。

vsw-wz9qqeovkwjxlu9uc****
SecurityGroupIdstring

安全组 ID。

sg-2vcgdxz7o1n9zapp****
ValueDataTypestring

编解码参数枚举值,有 3 个枚举值,命名如下

  1. JSON:现有逻辑,bytes 按 utf8 解码成字符串,解析为 JSON。
  2. Text:bytes 按 utf8 解码成字符串,直接放入 payload。
  3. Binary:bytes 按 base64 编码成字符串,放入 payload。
Text
SourceMQTTParametersobject

Source MQTT 源

RegionIdstring

地域 ID。

cn-shanghai
InstanceIdstring

实例 id。

i-2ze06wqdwk0uq14k****
Topicstring

Topic 名称。

TOPIC-cainiao-pcs-wms-instock-noPrealertPrintLabel
BodyDataTypestring

消息编码格式:

  • JSON
  • Text
  • Binary
JSON
SourceDTSParametersobject

Source DTS 源。

TaskIdstring

任务 ID。

f86e5814-b223-482c-b768-3b873297****
BrokerUrlstring

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

Topicstring

数据订阅通道的订阅 Topic。

TP_TEST_UNDERWRITE_ISSUE
Sidstring

消费组 ID。

HD1
Usernamestring

消费组的账号。

admin
Passwordstring

消费组的账号密码。

admin****
InitCheckPointstring

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

1620962769
SourceSLSParametersobject

Source SLS 源。

Projectstring

日志服务 SLS 的日志项目。

dmmzk
LogStorestring

日志服务 SLS 的日志库。

waf-logstore
ConsumerGroupstring

消费组。

ConsumePositionstring

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

begin
RoleNamestring

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

testRole
SourcePrometheusParametersobject

Source Prometheus 事件源。

RegionIdstring

地域 id。

cn-hangzhou
ClusterIdstring

集群 id。

c83555068b6******ad213f565f209
DataTypestring

数据类型。

Json
Labelsstring

标签。

__name__=.*
RoleNamestring

任务角色名称。

test-role
ExternalLabelsstring

附加到事件流中的外部标签。

{"env":"test"}
SourceCustomizedKafkaParametersobject

自定义 Kafka 事件源。

InstanceIdstring

消息队列 Kafka 版的实例 ID。

r-8vb64581862c****
SourceCustomizedKafkaConnectorParametersobject

自定义连接器 Apache Kafka 事件源。

ConnectorPackageUrlstring

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"
ConnectorParametersobject

连接器参数。

Namestring

连接器名称。

test-name
Configobject

连接器配置。

{ "connector.class": "com.mongodb.kafka.connect.MongoSinkConnector", "tasks.max": "1", "topics": "sourceA,sourceB" }
WorkerParametersobject

实例配置。

{ "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" }
SourceOSSParametersobject

Source OSS 事件源。

RoleNamestring

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

eventbridge_oss_role
BucketNamestring

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

bucket_abc
Prefixstring

文件路径前缀。

fun/document/
LoadModestring

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

single
LoadFormatstring

文档加载器。

TextLoader
Delimiterstring

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

\n
SourceOpenSourceRabbitMQParametersobject

Source 开源 RabbitMQ 源。

Endpointstring

开源版 RabbitMQ 实例接入点。

192.168.1.100:5672
VirtualHostNamestring

开源版 RabbitMQ 实例的 Vhost 的名称。

eb-connect
QueueNamestring

开源版 RabbitMQ 实例的 Queue 的名称。

demo
BodyDataTypestring

消息编码格式:

  • JSON
  • Text
  • Binary
Json
Usernamestring

用户名。

admin
Passwordstring

密码。

******
VpcIdstring

VPC 的 ID。

vpc-bp1vllc1lnw1v657******
VSwitchIdsstring

交换机 ID。

vsw-uf65zhil5oukof5******
SecurityGroupIdstring

安全组 ID。

sg-2ze65razphjfz3******
NetworkTypestring

网络类型:

  • 公网 :PublicNetwork

  • 专有网络 :PrivateNetwork

PrivateNetwork
AuthTypestring

鉴权类型。

ACL
SourceEventBusParametersobject

Source Event Bus 源。

EventBusNamestring

事件总线的名称。

demo
EventRuleNamestring

事件规则名称。

test
SourceMySQLParametersSourceMySQLParameters

Source MySQL 源。

FilterPatternstring

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

Transformsarray<object>

Transform 相关配置。

Transformsobject

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

Arnstring

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

acs:fc:cn-hangzhou:*****:services/demo-service.LATEST/functions/demo-func
Sinkobject

事件目标。

SinkMNSParametersobject

轻量消息队列(原 MNS)事件目标。

QueueNameobject

目标服务类型为轻量消息队列(原 MNS)。

Valuestring

轻量消息队列(原 MNS)的 Queue 的名称。

MyQueue
Formstring

转换的格式。默认为 CONSTANT。

CONSTANT
Templatestring

模板样式。

Bodyobject

消息内容。

Valuestring

转换前的值。

{ "key": "value" }
Formstring

转换的格式。

TEMPLATE
Templatestring

模板样式。

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

是否开启 Base64 编码。

Valuestring

开启 Base64 编码。

true
Formstring

事件转换的格式。默认为 CONSTANT。

CONSTANT
Templatestring

模板样式。

SinkRabbitMQParametersobject

Sink Rabbitmq 的参数。

InstanceIdobject

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

Valuestring

消息队列 RabbitMQ 版的实例 ID。

e5c9b727-e06c-4d7e-84d5-f8ce644e****
Formstring

转换的格式。默认为 CONSTANT。

CONSTANT
Templatestring

模板样式。

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

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

Valuestring

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

rabbit-host
Formstring

转换的格式。默认为 CONSTANT。

CONSTANT
Templatestring

模板样式。

TargetTypeobject

目标类型。

Valuestring

目标类型。取值说明如下:

  • Exchange:Exchange 模式。
  • Queue:Queue 模式。
Exchange/Queue
Formstring

转换的格式。默认为 CONSTANT。

CONSTANT
Templatestring

模板样式。

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

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

Valuestring

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

a_exchange
Formstring

转换的格式。默认为 CONSTANT。

CONSTANT
Templatestring

模板样式。

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

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

Valuestring

消息的路由规则。

housekeeping
Formstring

转换的格式。默认为 CONSTANT。

CONSTANT
Templatestring

模板样式。

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

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

Valuestring

实例的 Queue 的名称。

MyQueue
Formstring

转换的格式。默认为 CONSTANT。

CONSTANT
Templatestring

模板样式。

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

消息内容。

Valuestring

转换前的值。

{ "key": "value" }
Formstring

转换的格式。

TEMPLATE
Templatestring

模板样式。

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

消息 ID。

Valuestring

转换前的值。

{ "key": "value" }
Formstring

转换的格式。

TEMPLATE
Templatestring

模板样式。

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

过滤属性。

Valuestring

转换前的值。

{ "key": "value" }
Formstring

转换的格式。

TEMPLATE
Templatestring

模板样式。

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

函数目标。

ServiceNameobject

服务的名称。

Valuestring

服务的名称。

myService
Formstring

转换的格式。默认为 CONSTANT。

CONSTANT
Templatestring

模板样式。

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

函数名称。

Valuestring

函数名称。

mFunction
Formstring

转换的格式。默认为 CONSTANT。

CONSTANT
Templatestring

模板样式。

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

投递并发度,最小 1。

Valuestring

投递并发度,最小 1。

1
Formstring

转换的格式。默认为 CONSTANT。

CONSTANT
Templatestring

模板样式。

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

服务版本。

Valuestring

服务版本。

LATEST
Formstring

转换的格式。默认为 CONSTANT。

CONSTANT
Templatestring

模板样式。

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

同步或则异步。

  • Sync:同步。
  • Async:异步。
Valuestring

同步或则异步。

  • Sync:同步。
  • Async:异步。
Async
Formstring

转换的格式。默认为 CONSTANT。

CONSTANT
Templatestring

模板样式。

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

发送给函数的内容体。

Valuestring

转换前的值。

{ "key": "value" }
Formstring

转换的格式:

  • ORIGINAL:完整事件
  • JSONPATH:部分事件
  • CONSTANT:常量
  • TEMPLATE:模板

详细参考:https://help.aliyun.com/zh/eventbridge/user-guide/event-transformation

TEMPLATE
Templatestring

模板样式。

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

事件内容的格式转换规则。

Valuestring

转换前的值。

{ "key": "value" }
Formstring

转换的格式:

  • ORIGINAL:完整事件
  • JSONPATH:部分事件
  • CONSTANT:常量
  • TEMPLATE:模板
JSONPATH
Templatestring

模板样式。

$.data.key
SinkKafkaParametersobject

Sink kafak 参数。

InstanceIdobject

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

Valuestring

实例 ID。

Defaut_1283278472_s****
Formstring

转换的格式。默认为 CONSTANT。

CONSTANT
Templatestring

模板样式。

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

主题名称。

Valuestring

主题名称。

test
Formstring

转换的格式。默认为 CONSTANT。

CONSTANT
Templatestring

模板样式。

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

写入 Kafka 确认模式:

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

写入 Kafka 确认模式:

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

转换的格式。默认为 CONSTANT。

CONSTANT
Templatestring

模板样式。

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

消息键。

Valuestring

消息键。

key
Formstring

转换的格式。默认为 CONSTANT。

CONSTANT
Templatestring

模板样式。

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

Kafka 消息的附加元数据。

Valuestring

转换前的值。

{ "key": "value" }
Formstring

转换的格式:

  • ORIGINAL:完整事件
  • JSONPATH:部分事件
  • CONSTANT:常量
  • TEMPLATE:模板
CONSTANT
Templatestring

模板样式。

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

消息体。

Valuestring

转换前的值。

{ "key": "value" }
Formstring

转换的格式。

TEMPLATE
Templatestring

模板样式。

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

Sink RocketMQ Parameters

InstanceIdobject

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

Valuestring

消息队列 RocketMQ 版的实例 ID。

MQ_INST_164901546557****_BAAN****
Formstring

转换的格式。默认为 CONSTANT。

CONSTANT
Templatestring

模板样式。

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

消息队列 RocketMQ 版实例的 Topic。

Valuestring

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

Mytopic
Formstring

转换的格式。默认为 CONSTANT。

CONSTANT
Templatestring

模板样式。

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

消息内容。

Valuestring

转换前的值。

{ "key": "value" }
Formstring

转换的格式。

TEMPLATE
Templatestring

模板样式。

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

过滤属性。

Valuestring

转换前的值。

{ "key": "value" }
Formstring

转换的格式。

TEMPLATE
Templatestring

模板样式。

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

过滤属性。

Valuestring

转换前的值。

{ "key": "value" }
Formstring

转换的格式。

TEMPLATE
Templatestring

模板样式。

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

过滤属性。

Valuestring

转换前的值。

{ "key": "value" }
Formstring

转换的格式。

TEMPLATE
Templatestring

模板样式。

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

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

  • Cloud_4:阿里云 RocketMQ 4.0 版本实例(默认选项)
  • Cloud_5:阿里云 RocketMQ 5.0 版本实例
  • SelfBuilt:自建 Apache RocketMQ 集群
Valuestring

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

  • Cloud_4:阿里云 RocketMQ 4.0 版本实例(默认选项)
  • Cloud_5:阿里云 RocketMQ 5.0 版本实例
  • SelfBuilt:自建 Apache RocketMQ 集群
Cloud_4
Formstring

转换的格式。默认为 CONSTANT。

CONSTANT
Templatestring

InstanceEndpointobject

实例接入点。

Valuestring

实例接入点。

vbr-8vbsvkkbpf3vb0zef****
Formstring

转换的格式。默认为 CONSTANT。

CONSTANT
Templatestring

InstanceUsernameobject

实例用户名。

Valuestring

实例用户名。

admin
Formstring

转换的格式。默认为 CONSTANT。

CONSTANT
Templatestring

InstancePasswordobject

实例密码。

Valuestring

实例密码。

admin****
Formstring

转换的格式。默认为 CONSTANT。

CONSTANT
Templatestring

VpcIdobject

VPC 的 ID。

Valuestring

VPC 的 ID。

vbr-8vb835n3zf9shwlvb****
Formstring

事件转换的格式。默认为 CONSTANT。

CONSTANT
Templatestring

VSwitchIdsobject

交换机 ID。

Valuestring

交换机 ID。

vbr-8vb835n3zf9shwl****mp
Formstring

转换的格式。默认为 CONSTANT。

CONSTANT
Templatestring

SecurityGroupIdobject

安全组 ID。

Valuestring

安全组 ID。

b4bf375515f6440f942e3a20c33d****
Formstring

转换的格式。默认为 CONSTANT。

CONSTANT
Templatestring

Networkobject

网络类型。

  • PublicNetwork
  • PrivateNetwork
Valuestring

网络类型。

  • PublicNetwork
  • PrivateNetwork
PublicNetwork
Formstring

转换的格式。默认为 CONSTANT。

CONSTANT
Templatestring

DeliveryOrderTypeobject

消息的投递顺序类型。选填,默认为并发投递。

Valuestring

投递顺序类型。

  • Orderly: 顺序投递

  • Concurrently: 并发投递

Concurrently
Formstring

转换的格式。默认为 CONSTANT。

CONSTANT
Templatestring

模板样式。

ShardingKeyobject

消息的分片健。

说明
  • DeliveryOrderType 为 Orderly 时,ShardingKey 为必填参数。
  • Source 为 RocketMQ 时,ShardingKey 允许为空,此时使用上游 BrokerName 和 QueueId 拼接得到消息 ShardingKey。
  • Valuestring

    分片健值。

    order_id
    Formstring

    转换的格式。默认为 CONSTANT。

    CONSTANT
    Templatestring

    模板样式。

    SinkRocketMQCheckpointParametersobject

    Sink RocketMQ Checkpoint Parameters

    InstanceTypestring

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

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

    实例 ID。

    MQ_INST_164901546557****_BAAN****
    Topicobject

    消息队列 RocketMQ 版实例的 Topic。

    Valuestring

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

    Mytopic
    Formstring

    转换的格式。默认为 CONSTANT。

    CONSTANT
    Templatestring

    模板样式。

    Groupobject

    消费者组的 Group ID。

    Valuestring

    Group ID

    GID_EVENTBRIDGE_1736234******
    Formstring

    转换的格式。默认为 CONSTANT。

    CONSTANT
    Templatestring

    模板样式。

    ConsumeTimestampobject

    消息消费的时间戳。

    Valuestring

    时间戳。

    1570761026400
    Formstring

    转换的格式。默认为 CONSTANT。

    CONSTANT
    Templatestring

    模板样式。

    SinkApacheRocketMQCheckpointParametersobject

    Sink Apache RocketMQ Checkpoint Parameters

    Topicobject

    RocketMQ 版实例的 Topic。

    Valuestring

    RabbitMQ 版实例的 Topic 的名称。

    Mytopic
    Formstring

    转换的格式。默认为 CONSTANT。

    CONSTANT
    Templatestring

    模板样式。

    Groupobject

    消费者组的 Group ID。

    Valuestring

    Group ID

    GID_EVENTBRIDGE_1736234******
    Formstring

    转换的格式。默认为 CONSTANT。

    CONSTANT
    Templatestring

    模板样式。

    ConsumeTimestampobject

    消息消费的时间戳。

    Valuestring

    时间戳。

    1570761026400
    Formstring

    转换的格式。默认为 CONSTANT。

    CONSTANT
    Templatestring

    模板样式。

    InstanceEndpointstring

    实例接入点。

    192.168.1.1:9876
    InstanceUsernamestring

    认证需要的用户名。

    admin
    InstancePasswordstring

    用户名密码。

    ****
    NetworkTypestring

    网络类型。

    PrivateNetwork
    VpcIdstring

    专有网络的 ID。

    vpc-2zeccak5pb0j3ay******
    VSwitchIdstring

    交换机 ID。

    vsw-uf62oqt1twuevrt******
    SecurityGroupIdstring

    安全组 ID。

    sg-2ze5bmpw6adn0q******
    SinkSLSParametersobject

    Sink SLS Parameters

    Projectobject

    日志服务 SLS 的日志项目。

    Valuestring

    日志服务 SLS 的日志项目。

    test-project
    Formstring

    转换的格式。默认为 CONSTANT。

    CONSTANT
    Templatestring

    模板样式。

    LogStoreobject

    日志服务 SLS 的日志库。

    Valuestring

    日志服务 SLS 的日志库。

    test-logstore
    Formstring

    转换的格式。默认为 CONSTANT。

    CONSTANT
    Templatestring

    模板样式。

    Topicobject

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

    Valuestring

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

    testTopic
    Formstring

    转换的格式。默认为 CONSTANT。

    CONSTANT
    Templatestring

    模板样式。

    Bodyobject

    发送给 SLS 的内容。

    Valuestring

    转换前的值。

    { "key": "value" }
    Formstring

    转换的格式

    TEMPLATE
    Templatestring

    模板样式。

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

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

    Valuestring

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

    testRole
    Formstring

    转换的格式。默认为 CONSTANT。

    CONSTANT
    Templatestring

    模板样式。

    ContentTypeobject

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

    • JSON
    • KeyValue
    Valuestring

    转换前的值。

    JSON
    Formstring

    转换的格式。

    CONSTANT
    Templatestring

    模板样式。

    ContentSchemaobject

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

    Valuestring

    转换前的值。

    {"Key_1":{"form":"CONSTANT","value":"demoKey"},"Value_1":{"form":"JSONPATH","value":"$.data.value"}}
    Formstring

    模板样式。

    CONSTANT
    Templatestring

    模板样式。

    SinkFnfParametersobject

    Sink Fnf 参数。

    FlowNameobject

    流程名称。

    Valuestring

    流程名称。

    test-streaming-fnf
    Formstring

    转换的格式。默认为 CONSTANT。

    CONSTANT
    Templatestring

    模板样式。

    ExecutionNameobject

    执行名称。

    Valuestring

    执行名称。

    123
    Formstring

    转换的格式。默认为 CONSTANT:

    • JSONPATH:部分事件 。
    • CONSTANT:常量。
    • TEMPLATE:模板 。

    详细参考:https://help.aliyun.com/zh/eventbridge/user-guide/event-transformation

    CONSTANT
    Templatestring

    模板样式。

    Inputobject

    执行输入信息。

    Valuestring

    执行输入信息。

    123
    Formstring

    转换的格式。默认为 CONSTANT。

    CONSTANT
    Templatestring

    模板样式。

    RoleNameobject

    角色配置。

    Valuestring

    角色配置。

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

    转换的格式。默认为 CONSTANT。

    CONSTANT
    Templatestring

    模板样式。

    SinkDataHubParametersobject

    Sink DataHub 参数。

    Projectobject

    DataHub 项目名。

    Valuestring

    DataHub 项目名。

    demo-project
    Formstring

    转换的格式。默认为 CONSTANT。

    CONSTANT
    Templatestring

    Topicobject

    DataHub Topic 名称。

    Valuestring

    DataHub Topic 名称。

    demo-topic
    Formstring

    转换的格式。默认为 CONSTANT。

    CONSTANT
    Templatestring

    TopicTypeobject

    opic 类型:

    • TUPLE
    • BLOB
    Valuestring

    topic 类型。

    • TUPLE
    • BLOB
    TUPLE
    Formstring

    转换的格式。默认为 CONSTANT。

    CONSTANT
    Templatestring

    TopicSchemaobject

    TUBLE 类型,topic 内容模式。

    Valuestring

    TUBLE 类型,topic 内容模式。

    {"k1":"value1","k2":"value2"}
    Formstring

    转换的格式。

    TEMPLATE
    Templatestring

    模板样式。

    {"k1":"${k1}","k2":"${k2}"}
    Bodyobject

    BLOB 类型,Record 内容模板。

    Valuestring

    BLOB 类型,Record 内容模板。

    Formstring

    转换的格式。

    ORIGINAL
    Templatestring

    RoleNameobject

    任务角色名。

    Valuestring

    任务角色名称。

    test-role
    Formstring

    转换的格式。默认为 CONSTANT。

    CONSTANT
    Templatestring

    SinkCustomizedKafkaParametersobject

    Sink Kafka 参数。

    InstanceIdstring

    消息队列 Kafka 版的实例 ID。

    90be1f96-4229-4535-bb76-34b4f6fb****
    SinkCustomizedKafkaConnectorParametersobject

    Sink Kafka 连接器参数。

    ConnectorPackageUrlstring

    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=rb8q3OpV******"
    ConnectorParametersobject

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

    Namestring

    连接器名称。

    mongo-sink
    Configobject

    连接器配置。

    { "connector.class": "com.mongodb.kafka.connect.MongoSinkConnector", "tasks.max": "1", "topics": "sourceA,sourceB" }
    WorkerParametersobject

    实例配置。

    { "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" }
    SinkDashVectorParametersobject

    Sink DashVector 参数。

    InstanceIdstring

    实例 ID。

    vrs-cn-lbj3ru1***
    Collectionstring

    Collection(集合)名称。

    collection1
    ApiKeystring

    DashVecotor 控制台创建的 API Key。

    Q34nExQH7sQ****
    Operationstring

    DashVector 数据库操作类型。

    Upsert
    Networkstring

    网络类型。

    PublicNetwork
    PrimaryKeyIdobject

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

    Formstring

    转换的格式。

    JSONPATH
    Valuestring
    • Form 为 JSONPATH:JSONPath 提取内容。
    • Form 为 TEMPLATE:模板变量。

    注:Value 字段不允许超过 10240 个字符、

    $.data.requestId
    Templatestring

    主键 ID 模板,仅当 Form 是 TEMPLATE 时需要填写。

    ${ID}
    Partitionobject

    Partition(分区),默认值为 default 分区。

    Formstring

    转换的格式。

    CONSTANT
    Valuestring
    • Form 为 CONSTANT:常量值。
    • Form 为 JSONPATH:JSONPath 提取内容。

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

    default
    Templatestring

    Vectorobject

    插入 DashVector 记录的向量。

    Formstring

    转换的格式。

    JSONPATH
    Valuestring

    JSONPath 提取内容。

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

    $.data.messageBody
    Templatestring

    DashVectorSchemaParametersobject

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

    Formstring

    转换的格式。

    TEMPLATE
    Valuestring
    • Form 为 CONSTANT:常量值。
    • Form 为 JSONPATH:JSONPath 提取内容。
    • Form 为 TEMPLATE:模板变量。

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

    { "value1":"v1", "value2":"v2" }
    Templatestring

    Schema 模板,仅当 Form 是 TEMPLATE 时需要填写,事件内容转换后必须是 Array(JSON)格式,每个 Schema 对应一个 JSON 对象,属性有且仅有 name, type(仅支持 INT、FLOAT、STRING、BOOL), value 三个字段。

    [ { "name": "schema1", "type": "INT", "value": "${value1}" }, { "name": "schema2", "type": "FLOAT", "value": "${value2}" } ]
    SinkOpenSourceRabbitMQParametersobject

    Sink Open Source RabbitMQ Parameters

    Endpointstring

    接入点。

    192.168.1.1:9876
    VirtualHostNamestring

    RabbitMQ 的虚拟主机名称。

    vhost1
    TargetTypestring

    消息投递的目标类型,仅当 TargetType 设置为 Exchange 时生效。

    Exchange
    Exchangestring

    RabbitMQ 中的 Exchange 名称。

    my-exchange
    QueueNamestring

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

    my-queue
    Usernamestring

    访问 RabbitMQ 实例的用户名。

    admin
    Passwordstring

    访问 RabbitMQ 实例的密码。

    ****
    VpcIdstring

    专有网络 ID。

    vpc-uf6of9452b2pba82c ****
    VSwitchIdsstring

    交换机 ID。

    vsw-uf6of9452b2pba82c ****
    SecurityGroupIdstring

    安全组 ID。

    sg-uf6of9452b2pba82c ****
    NetworkTypestring

    网络类型。

    PublicNetwork
    AuthTypestring

    认证类型。

    ACL
    RoutingKeyobject

    消息路由键。

    Formstring

    转换格式,默认为 CONSTANT。

    CONSTANT
    Valuestring

    路由键值。

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

    模板样式。

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

    消息体内容。

    Formstring

    转换格式,默认为 CONSTANT。

    CONSTANT
    Valuestring

    原始数据值。

    {"key": "value"}
    Templatestring

    模板样式。

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

    消息的唯一标识符。

    Formstring

    转换格式,默认为 CONSTANT。

    CONSTANT
    Valuestring

    消息 ID 值。

    12345
    Templatestring

    模板样式。

    Propertiesobject

    消息的附加属性。

    Formstring

    转换格式,默认为 CONSTANT。

    CONSTANT
    Valuestring

    属性内容。

    {"env": "prod"}
    Templatestring

    模板样式。

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

    Sink BaiLian Parameters

    RunOptionsobject

    运行环境参数。

    MaximumTasksinteger

    并发数。

    2
    RetryStrategyobject

    事件推送失败时的重试策略。

    PushRetryStrategystring

    重试策略:BACKOFF_RETRY(退避重试)和 EXPONENTIALDECAY_RETRY(指数衰减重试)。

    BACKOFF_RETRY
    MaximumEventAgeInSecondsfloat

    最大重试时间。

    512
    MaximumRetryAttemptsfloat

    最大重试次数。

    2
    ErrorsTolerancestring

    异常容忍策略:NONE(不容忍异常)、ALL(容忍所有异常)。

    ALL
    DeadLetterQueueobject

    是否启用死信队列。默认不启用死信队列,超过重试策略后的消息将被丢弃。

    Arnstring

    死信队列 ARN。

    acs:ram::155020394332****:role/edskmstoecs
    Networkstring

    死信队列的网络类型。

    PrivateNetwork
    VpcIdstring

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

    vpc-2zehizpoendb3****
    VSwitchIdsstring

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

    vsw-m5ev8asdc6h12345****
    SecurityGroupIdstring

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

    sg-2vcgdxz7o1n9zapp****
    BatchWindowobject

    攒批窗口。

    CountBasedWindowinteger

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

    100
    TimeBasedWindowinteger

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

    10
    Statusstring

    获取到的事件流的状态。

    RUNNING
    DetailedStatusobject

    详细状态。

    TPSdouble

    每秒处理事务数。

    5
    DelayTimelong

    延迟时间。

    3
    DiffOffsetlong

    差异偏移。

    0
    Extensionsobject

    扩展属性。

    { "test": "test", "test2": 1 }
    Codestring

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

    Success
    Successboolean

    操作成功返回 true。

    true

    示例

    正常返回示例

    JSON格式

    {
      "Message": "The event streaming [xxxx] not existed!",
      "RequestId": "7892F480-58C9-5067-AB35-8A7BEF****",
      "Data": {
        "EventStreamingName": "rocketmq-sync",
        "Description": "RocketMQ-to-RocketMQ",
        "Source": {
          "SourceMNSParameters": {
            "RegionId": "cn-hangzhou",
            "QueueName": "demo",
            "IsBase64Decode": true
          },
          "SourceRabbitMQParameters": {
            "RegionId": "cn-hangzhou",
            "InstanceId": "i-f8z9a9mcgwri1c1i****",
            "VirtualHostName": "eb-connect",
            "QueueName": "comp"
          },
          "SourceRocketMQParameters": {
            "RegionId": "cn-hangzhou",
            "InstanceId": "i-f8zbher64dlm58pl****",
            "Topic": "topic_add_anima",
            "Tag": "v1",
            "Offset": "CONSUMEFROMLASTOFFSET",
            "GroupID": "GID_group1",
            "Timestamp": 1636597951964,
            "InstanceType": "Cloud_4\n",
            "InstanceEndpoint": "reg****-vpc.cn-zhangjiakou.aliyuncs.com\n",
            "AuthType": "ACL",
            "InstanceUsername": "xxxa",
            "InstancePassword": "xxxa",
            "InstanceVpcId": "vpc-m5e3sv4b12345****\n",
            "InstanceVSwitchIds": "vsw-m5ev8asdc6h12****\n",
            "InstanceSecurityGroupId": "sg-m5edtu24f12345****\n",
            "InstanceNetwork": "PublicNetwork",
            "BodyDataType": "Json",
            "FilterType": "Tag\n",
            "FilterSql": "index > 10",
            "VpcId": "vpc-m5e3sv4b12345****\n",
            "VSwitchIds": "vsw-m5ev8asdc6h12345****\n",
            "SecurityGroupId": "sg-m5edtu24f12345****\n",
            "Network": "PublicNetwork"
          },
          "SourceRocketMQCheckpointParameters": {
            "RegionId": "cn-hangzhou",
            "InstanceType": "Cloud_4",
            "InstanceId": "rmp-cn-jte3w******\n",
            "Topics": [
              "opic_add_anima"
            ]
          },
          "SourceApacheRocketMQCheckpointParameters": {
            "RegionId": "cn-hangzhou\n",
            "InstanceId": "MQ_INST_164901546557****_BAAN****",
            "Topics": [
              [
                "Topic_1",
                "Topic_2"
              ]
            ],
            "InstanceEndpoint": "registry-vpc.cn-hangzhou.aliyuncs.com",
            "InstanceUsername": "admin",
            "InstancePassword": 123456,
            "NetworkType": "PrivateNetwork",
            "VpcId": "vpc-adw1awdw*****",
            "VSwitchId": "vsw-dwaafds****",
            "SecurityGroupId": "sg-mw43*****"
          },
          "SourceKafkaParameters": {
            "RegionId": "cn-hangzhou",
            "InstanceId": "i-bp1fbtrnqmjvgq66****",
            "Topic": "topic_empower_1642473600414",
            "ConsumerGroup": "GID_TEST",
            "OffsetReset": "latest",
            "Network": "Default",
            "VpcId": "vpc-2zehizpoendb3****",
            "VSwitchIds": "vsw-wz9qqeovkwjxlu9uc****",
            "SecurityGroupId": "sg-2vcgdxz7o1n9zapp****",
            "ValueDataType": "Text"
          },
          "SourceMQTTParameters": {
            "RegionId": "cn-shanghai",
            "InstanceId": "i-2ze06wqdwk0uq14k****",
            "Topic": "TOPIC-cainiao-pcs-wms-instock-noPrealertPrintLabel",
            "BodyDataType": "JSON"
          },
          "SourceDTSParameters": {
            "TaskId": "f86e5814-b223-482c-b768-3b873297****",
            "BrokerUrl": "无",
            "Topic": "TP_TEST_UNDERWRITE_ISSUE",
            "Sid": "HD1",
            "Username": "admin",
            "Password": "admin****",
            "InitCheckPoint": 1620962769
          },
          "SourceSLSParameters": {
            "Project": "dmmzk",
            "LogStore": "waf-logstore",
            "ConsumerGroup": "无",
            "ConsumePosition": "begin",
            "RoleName": "testRole"
          },
          "SourcePrometheusParameters": {
            "RegionId": "cn-hangzhou",
            "ClusterId": "c83555068b6******ad213f565f209\n",
            "DataType": "Json",
            "Labels": "__name__=.*\n",
            "RoleName": "test-role",
            "ExternalLabels": {
              "env": "test"
            }
          },
          "SourceCustomizedKafkaParameters": {
            "InstanceId": "r-8vb64581862c****\n"
          },
          "SourceCustomizedKafkaConnectorParameters": {
            "ConnectorPackageUrl": "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": {
              "Name": "test-name\n",
              "Config": {
                "connector.class": "com.mongodb.kafka.connect.MongoSinkConnector",
                "tasks.max": 1,
                "topics": "sourceA,sourceB"
              }
            },
            "WorkerParameters": {
              "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"
            }
          },
          "SourceOSSParameters": {
            "RoleName": "eventbridge_oss_role\n",
            "BucketName": "bucket_abc\n",
            "Prefix": "fun/document/\n",
            "LoadMode": "single\n",
            "LoadFormat": "TextLoader\n",
            "Delimiter": "\\n\n"
          },
          "SourceOpenSourceRabbitMQParameters": {
            "Endpoint": "192.168.1.100:5672",
            "VirtualHostName": "eb-connect",
            "QueueName": "demo",
            "BodyDataType": "Json",
            "Username": "admin",
            "Password": "******",
            "VpcId": "vpc-bp1vllc1lnw1v657******",
            "VSwitchIds": "vsw-uf65zhil5oukof5******",
            "SecurityGroupId": "sg-2ze65razphjfz3******",
            "NetworkType": "PrivateNetwork\n",
            "AuthType": "ACL"
          },
          "SourceEventBusParameters": {
            "EventBusName": "demo",
            "EventRuleName": "test"
          },
          "SourceMySQLParameters": {
            "IncludeSchemaChanges": "",
            "User": "",
            "VSwitchIds": "",
            "SnapshotMode": "",
            "SecurityGroupId": "",
            "Port": 0,
            "DatabaseName": "",
            "VpcId": "",
            "NetworkType": "",
            "TableNames": "",
            "RegionId": "",
            "HostName": "",
            "Password": ""
          }
        },
        "FilterPattern": "无",
        "Transforms": [
          {
            "Arn": "acs:fc:cn-hangzhou:*****:services/demo-service.LATEST/functions/demo-func\n"
          }
        ],
        "Sink": {
          "SinkMNSParameters": {
            "QueueName": {
              "Value": "MyQueue",
              "Form": "CONSTANT",
              "Template": "无"
            },
            "Body": {
              "Value": {
                "key": "value"
              },
              "Form": "TEMPLATE",
              "Template": "The value of ${key} is ${value}!"
            },
            "IsBase64Encode": {
              "Value": true,
              "Form": "CONSTANT",
              "Template": "无"
            }
          },
          "SinkRabbitMQParameters": {
            "InstanceId": {
              "Value": "e5c9b727-e06c-4d7e-84d5-f8ce644e****",
              "Form": "CONSTANT",
              "Template": "The value of ${key} is ${value}!\n"
            },
            "VirtualHostName": {
              "Value": "rabbit-host\n",
              "Form": "CONSTANT",
              "Template": "无"
            },
            "TargetType": {
              "Value": "Exchange/Queue",
              "Form": "CONSTANT",
              "Template": "The value of ${key} is ${value}!\n"
            },
            "Exchange": {
              "Value": "a_exchange",
              "Form": "CONSTANT",
              "Template": "The value of ${key} is ${value}!\n"
            },
            "RoutingKey": {
              "Value": "housekeeping",
              "Form": "CONSTANT",
              "Template": "The value of ${key} is ${value}!\n"
            },
            "QueueName": {
              "Value": "MyQueue",
              "Form": "CONSTANT",
              "Template": "The value of ${key} is ${value}!\n"
            },
            "Body": {
              "Value": {
                "key": "value"
              },
              "Form": "TEMPLATE",
              "Template": "The value of ${key} is ${value}!"
            },
            "MessageId": {
              "Value": {
                "key": "value"
              },
              "Form": "TEMPLATE",
              "Template": "The value of ${key} is ${value}!"
            },
            "Properties": {
              "Value": {
                "key": "value"
              },
              "Form": "TEMPLATE",
              "Template": "The value of ${key} is ${value}!\n"
            }
          },
          "SinkFcParameters": {
            "ServiceName": {
              "Value": "myService",
              "Form": "CONSTANT",
              "Template": "The value of ${key} is ${value}!\n"
            },
            "FunctionName": {
              "Value": "mFunction",
              "Form": "CONSTANT",
              "Template": "The value of ${key} is ${value}!\n"
            },
            "Concurrency": {
              "Value": 1,
              "Form": "CONSTANT",
              "Template": "The value of ${key} is ${value}!\n"
            },
            "Qualifier": {
              "Value": "LATEST",
              "Form": "CONSTANT",
              "Template": "The value of ${key} is ${value}!\n"
            },
            "InvocationType": {
              "Value": "Async",
              "Form": "CONSTANT",
              "Template": "The value of ${key} is ${value}!\n"
            },
            "Body": {
              "Value": {
                "key": "value"
              },
              "Form": "TEMPLATE",
              "Template": "The value of ${key} is ${value}!\n"
            },
            "DataFormat": {
              "Value": {
                "key": "value"
              },
              "Form": "JSONPATH",
              "Template": "$.data.key"
            }
          },
          "SinkKafkaParameters": {
            "InstanceId": {
              "Value": "Defaut_1283278472_s****",
              "Form": "CONSTANT",
              "Template": "The value of ${key} is ${value}!\n"
            },
            "Topic": {
              "Value": "test",
              "Form": "CONSTANT",
              "Template": "The value of ${key} is ${value}!\n"
            },
            "Acks": {
              "Value": 1,
              "Form": "CONSTANT",
              "Template": "The value of ${key} is ${value}!\n"
            },
            "Key": {
              "Value": "key",
              "Form": "CONSTANT",
              "Template": "The value of ${key} is ${value}!\n"
            },
            "Headers": {
              "Value": {
                "key": "value"
              },
              "Form": "CONSTANT",
              "Template": "The value of ${key} is ${value}!\n"
            },
            "Value": {
              "Value": {
                "key": "value"
              },
              "Form": "TEMPLATE",
              "Template": "The value of ${key} is ${value}!\n"
            }
          },
          "SinkRocketMQParameters": {
            "InstanceId": {
              "Value": "MQ_INST_164901546557****_BAAN****",
              "Form": "CONSTANT",
              "Template": "The value of ${key} is ${value}!\n"
            },
            "Topic": {
              "Value": "Mytopic",
              "Form": "CONSTANT",
              "Template": "The value of ${key} is ${value}!\n"
            },
            "Body": {
              "Value": {
                "key": "value"
              },
              "Form": "TEMPLATE",
              "Template": "The value of ${key} is ${value}!\n"
            },
            "Properties": {
              "Value": {
                "key": "value"
              },
              "Form": "TEMPLATE",
              "Template": "The value of ${key} is ${value}!\n"
            },
            "Keys": {
              "Value": {
                "key": "value"
              },
              "Form": "TEMPLATE",
              "Template": "The value of ${key} is ${value}!"
            },
            "Tags": {
              "Value": {
                "key": "value"
              },
              "Form": "TEMPLATE",
              "Template": "The value of ${key} is ${value}!"
            },
            "InstanceType": {
              "Value": "Cloud_4\n",
              "Form": "CONSTANT",
              "Template": "无"
            },
            "InstanceEndpoint": {
              "Value": "vbr-8vbsvkkbpf3vb0zef****\n",
              "Form": "CONSTANT\n",
              "Template": "无"
            },
            "InstanceUsername": {
              "Value": "admin\n",
              "Form": "CONSTANT\n",
              "Template": "无"
            },
            "InstancePassword": {
              "Value": "admin****\n",
              "Form": "CONSTANT\n",
              "Template": "无\n"
            },
            "VpcId": {
              "Value": "vbr-8vb835n3zf9shwlvb****\n",
              "Form": "CONSTANT\n",
              "Template": "无\n\n"
            },
            "VSwitchIds": {
              "Value": "vbr-8vb835n3zf9shwl****mp\n",
              "Form": "CONSTANT\n",
              "Template": "无\n\n"
            },
            "SecurityGroupId": {
              "Value": "b4bf375515f6440f942e3a20c33d****\n",
              "Form": "CONSTANT\n",
              "Template": "无\n"
            },
            "Network": {
              "Value": "PublicNetwork\n",
              "Form": "CONSTANT\n",
              "Template": "无\n\n"
            },
            "DeliveryOrderType": {
              "Value": "Concurrently",
              "Form": "CONSTANT",
              "Template": "无"
            },
            "ShardingKey": {
              "Value": "order_id",
              "Form": "CONSTANT",
              "Template": "无"
            }
          },
          "SinkDorisParameters": {
            "QueryEndpoint": {
              "Value": "",
              "Form": "",
              "Template": ""
            },
            "FeHttpEndpoint": {
              "Value": "",
              "Form": "",
              "Template": ""
            },
            "BeHttpEndpoint": {
              "Value": "",
              "Form": "",
              "Template": ""
            },
            "UserName": {
              "Value": "",
              "Form": "",
              "Template": ""
            },
            "Password": {
              "Value": "",
              "Form": "",
              "Template": ""
            },
            "Database": {
              "Value": "",
              "Form": "",
              "Template": ""
            },
            "Table": {
              "Value": "",
              "Form": "",
              "Template": ""
            },
            "Body": {
              "Value": "",
              "Form": "",
              "Template": ""
            },
            "NetworkType": {
              "Value": "",
              "Form": "",
              "Template": ""
            },
            "VpcId": {
              "Value": "",
              "Form": "",
              "Template": ""
            },
            "VSwitchIds": {
              "Value": "",
              "Form": "",
              "Template": ""
            },
            "SecurityGroupId": {
              "Value": "",
              "Form": "",
              "Template": ""
            }
          },
          "SinkRocketMQCheckpointParameters": {
            "InstanceType": "Cloud_4",
            "InstanceId": "MQ_INST_164901546557****_BAAN****",
            "Topic": {
              "Value": "Mytopic",
              "Form": "CONSTANT",
              "Template": "无"
            },
            "Group": {
              "Value": "GID_EVENTBRIDGE_1736234******",
              "Form": "CONSTANT",
              "Template": "无"
            },
            "ConsumeTimestamp": {
              "Value": 1570761026400,
              "Form": "CONSTANT",
              "Template": "无"
            }
          },
          "SinkApacheRocketMQCheckpointParameters": {
            "Topic": {
              "Value": "Mytopic",
              "Form": "CONSTANT",
              "Template": "无"
            },
            "Group": {
              "Value": "GID_EVENTBRIDGE_1736234******\n",
              "Form": "CONSTANT",
              "Template": "无"
            },
            "ConsumeTimestamp": {
              "Value": 1570761026400,
              "Form": "CONSTANT",
              "Template": "无"
            },
            "InstanceEndpoint": "192.168.1.1:9876",
            "InstanceUsername": "admin",
            "InstancePassword": "****",
            "NetworkType": "PrivateNetwork",
            "VpcId": "vpc-2zeccak5pb0j3ay******",
            "VSwitchId": "vsw-uf62oqt1twuevrt******",
            "SecurityGroupId": "sg-2ze5bmpw6adn0q******"
          },
          "SinkSLSParameters": {
            "Project": {
              "Value": "test-project\n",
              "Form": "CONSTANT",
              "Template": "无"
            },
            "LogStore": {
              "Value": "test-logstore",
              "Form": "CONSTANT",
              "Template": "无"
            },
            "Topic": {
              "Value": "testTopic",
              "Form": "CONSTANT",
              "Template": "无"
            },
            "Body": {
              "Value": {
                "key": "value"
              },
              "Form": "TEMPLATE",
              "Template": "The value of ${key} is ${value}!\n"
            },
            "RoleName": {
              "Value": "testRole",
              "Form": "CONSTANT",
              "Template": "无"
            },
            "ContentType": {
              "Value": "JSON\n",
              "Form": "CONSTANT\n",
              "Template": "无"
            },
            "ContentSchema": {
              "Value": {
                "Key_1": {
                  "form": "CONSTANT",
                  "value": "demoKey"
                },
                "Value_1": {
                  "form": "JSONPATH",
                  "value": "$.data.value"
                }
              },
              "Form": "CONSTANT\n",
              "Template": "无"
            }
          },
          "SinkFnfParameters": {
            "FlowName": {
              "Value": "test-streaming-fnf",
              "Form": "CONSTANT",
              "Template": "无"
            },
            "ExecutionName": {
              "Value": 123,
              "Form": "CONSTANT",
              "Template": "无"
            },
            "Input": {
              "Value": 123,
              "Form": "CONSTANT",
              "Template": "无"
            },
            "RoleName": {
              "Value": "Al****FNF-x****",
              "Form": "CONSTANT",
              "Template": "无"
            }
          },
          "SinkDataHubParameters": {
            "Project": {
              "Value": "demo-project\n",
              "Form": "CONSTANT\n",
              "Template": "无\n\n"
            },
            "Topic": {
              "Value": "demo-topic\n",
              "Form": "CONSTANT",
              "Template": "无"
            },
            "TopicType": {
              "Value": "TUPLE\n",
              "Form": "CONSTANT",
              "Template": "无"
            },
            "TopicSchema": {
              "Value": {
                "k1": "value1",
                "k2": "value2"
              },
              "Form": "TEMPLATE",
              "Template": {
                "k1": "${k1}",
                "k2": "${k2}"
              }
            },
            "Body": {
              "Value": "无",
              "Form": "ORIGINAL",
              "Template": "无"
            },
            "RoleName": {
              "Value": "test-role",
              "Form": "CONSTANT",
              "Template": "无"
            }
          },
          "SinkCustomizedKafkaParameters": {
            "InstanceId": "90be1f96-4229-4535-bb76-34b4f6fb****"
          },
          "SinkCustomizedKafkaConnectorParameters": {
            "ConnectorPackageUrl": "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=rb8q3OpV******",
            "ConnectorParameters": {
              "Name": "mongo-sink",
              "Config": {
                "connector.class": "com.mongodb.kafka.connect.MongoSinkConnector",
                "tasks.max": 1,
                "topics": "sourceA,sourceB"
              }
            },
            "WorkerParameters": {
              "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": {
            "InstanceId": "vrs-cn-lbj3ru1***",
            "Collection": "collection1",
            "ApiKey": "Q34nExQH7sQ****",
            "Operation": "Upsert",
            "Network": "PublicNetwork",
            "PrimaryKeyId": {
              "Form": "JSONPATH",
              "Value": "$.data.requestId",
              "Template": "${ID}"
            },
            "Partition": {
              "Form": "CONSTANT",
              "Value": "default",
              "Template": "无"
            },
            "Vector": {
              "Form": "JSONPATH",
              "Value": "$.data.messageBody",
              "Template": "无"
            },
            "DashVectorSchemaParameters": {
              "Form": "TEMPLATE",
              "Value": {
                "value1": "v1",
                "value2": "v2"
              },
              "Template": [
                {
                  "name": "schema1",
                  "type": "INT",
                  "value": "${value1}"
                },
                {
                  "name": "schema2",
                  "type": "FLOAT",
                  "value": "${value2}"
                }
              ]
            }
          },
          "SinkOpenSourceRabbitMQParameters": {
            "Endpoint": "192.168.1.1:9876",
            "VirtualHostName": "vhost1",
            "TargetType": "Exchange",
            "Exchange": "my-exchange",
            "QueueName": "my-queue",
            "Username": "admin",
            "Password": "****",
            "VpcId": "vpc-uf6of9452b2pba82c ****",
            "VSwitchIds": "vsw-uf6of9452b2pba82c ****",
            "SecurityGroupId": "sg-uf6of9452b2pba82c ****",
            "NetworkType": "PublicNetwork\n",
            "AuthType": "ACL",
            "RoutingKey": {
              "Form": "CONSTANT",
              "Value": {
                "Form": "CONSTANT",
                "Value": "my-routing-key"
              },
              "Template": "The value of ${key} is ${value}!"
            },
            "Body": {
              "Form": "CONSTANT",
              "Value": {
                "key": "value"
              },
              "Template": "The value of ${key} is ${value}!"
            },
            "MessageId": {
              "Form": "CONSTANT",
              "Value": 12345,
              "Template": "无"
            },
            "Properties": {
              "Form": "CONSTANT",
              "Value": {
                "env": "prod"
              },
              "Template": "The value of ${key} is ${value}!\n"
            }
          },
          "SinkBaiLianParameters": {
            "Before": {
              "Form": "",
              "Value": "",
              "Template": ""
            },
            "Context": "",
            "ApplicationType": "",
            "Op": {
              "Form": "",
              "Value": "",
              "Template": ""
            },
            "Partition": {
              "Form": "",
              "Value": "",
              "Template": ""
            },
            "Extend": "",
            "WorkspaceId": "",
            "After": {
              "Form": "",
              "Value": "",
              "Template": ""
            },
            "Offset": {
              "Form": "",
              "Value": "",
              "Template": ""
            }
          }
        },
        "RunOptions": {
          "MaximumTasks": 2,
          "RetryStrategy": {
            "PushRetryStrategy": "BACKOFF_RETRY",
            "MaximumEventAgeInSeconds": 512,
            "MaximumRetryAttempts": 2
          },
          "ErrorsTolerance": "ALL",
          "DeadLetterQueue": {
            "Arn": "acs:ram::155020394332****:role/edskmstoecs",
            "Network": "PrivateNetwork",
            "VpcId": "vpc-2zehizpoendb3****",
            "VSwitchIds": "vsw-m5ev8asdc6h12345****",
            "SecurityGroupId": "sg-2vcgdxz7o1n9zapp****"
          },
          "BatchWindow": {
            "CountBasedWindow": 100,
            "TimeBasedWindow": 10
          },
          "BusinessOption": {
            "BusinessMode": "",
            "MinCapacityUnitCount": 0,
            "MaxCapacityUnitCount": 0
          },
          "Throttling": 0
        },
        "Status": "RUNNING",
        "DetailedStatus": {
          "TPS": 5,
          "DelayTime": 3,
          "DiffOffset": 0,
          "Extensions": {
            "test": "test",
            "test2": 1
          }
        }
      },
      "Code": "Success",
      "Success": true
    }

    错误码

    HTTP status code错误码错误信息
    403ServiceNotEnableService not enable

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

    变更历史

    变更时间变更内容概要操作
    2024-09-10OpenAPI 错误码发生变更、OpenAPI 返回结构发生变更查看变更详情
    2024-08-19OpenAPI 错误码发生变更、OpenAPI 返回结构发生变更查看变更详情
    2024-07-12OpenAPI 错误码发生变更、OpenAPI 返回结构发生变更查看变更详情
    2024-05-31OpenAPI 错误码发生变更、OpenAPI 返回结构发生变更查看变更详情
    2024-04-09OpenAPI 错误码发生变更、OpenAPI 返回结构发生变更查看变更详情
    2024-02-21OpenAPI 错误码发生变更、OpenAPI 返回结构发生变更查看变更详情
    2023-12-28OpenAPI 错误码发生变更、OpenAPI 返回结构发生变更查看变更详情
    2023-11-22OpenAPI 错误码发生变更、OpenAPI 返回结构发生变更查看变更详情
    2023-10-11OpenAPI 错误码发生变更、OpenAPI 返回结构发生变更查看变更详情
    2023-09-13OpenAPI 错误码发生变更、OpenAPI 返回结构发生变更查看变更详情
    2023-04-21OpenAPI 错误码发生变更、OpenAPI 返回结构发生变更查看变更详情
    2023-04-06OpenAPI 错误码发生变更查看变更详情