事件源参数
更新时间 2025-12-29 16:48:57
最近更新时间: 2025-12-29 16:48:57
本文介绍事件流中事件源的元数据参数。
请求参数
| 参数 | 类型 | 是否必选 | 描述 |
|---|---|---|---|
eventStreamName | String | 是 | 事件流名。 |
streamSource | Object | 是 | 事件源项。详见表StreamSource，更多信息请参考下文事件源的格式。 |
| desc | String | 否 | 事件源描述。 |
filterPattern | String | 是 | 事件过滤项。 |
transform | Object | 是 | 事件转换项。 |
streamSink | Object | 是 | 事件目标项。详见事件目标参数。 |
表 StreamSource
| 参数 | 类型 | 是否必选 | 描述 |
|---|---|---|---|
type | String | 是 | 事件源类型。 |
params | Array of Objects | 是 | 事件源参数，详见表Params。 |
表 Params
| 参数 | 是否必填 | 参数类型 | 说明 |
|---|---|---|---|
| resourceKey | 是 | String | 事件源参数名。 |
| value | 是 | String | 事件源参数值。 |
| form | 是 | String | 事件源参数格式。 |
| template | 否 | String | 事件源参数模板样式。 |
分布式消息服务Kafka
当事件源的事件提供方选择分布式消息服务Kafka时，请求参数中的type为kafka，params中的resourceKey字段含义如下表所示：
| resourceKey | 是否必传 | form | value | template |
|---|---|---|---|---|
| instanceId | 是 | CONSTANT | 分布式消息服务Kafka实例ID。 | 无 |
| topic | 是 | CONSTANT | 主题名称。 | 无 |
| groupName | 是 | CONSTANT | 消费组名。 | 无 |
| initialOffset | 是 | CONSTANT | 消息位点。
| 无 |
| dataFormat | 否 | CONSTANT | 数据格式,不填时默认为JSON编码格式：
| 无 |
事件源部分的参数示例如下：
{
"type": "kafka",
"params": [
{
"resourceKey": "instanceId",
"value": "b16b04cf0776xxxxxfa31a001a5c48b6",
"form": "constant"
},
{
"resourceKey": "topic",
"value": "eb_source",
"form": "constant"
},
{
"resourceKey": "groupName",
"value": "eb-group",
"form": "constant"
},
{
"resourceKey": "initialOffset",
"value": "latest",
"form": "constant"
},
{
"resourceKey": "dataFormat",
"value": "JSON",
"form": "CONSTANT"
}
]
}分布式消息服务RocketMQ
当事件源的事件提供方选择分布式消息服务RocketMQ时，请求参数中的type为rocketmq，params中的resourceKey字段含义如下表所示：
| resourceKey | 是否必传 | form | value | template |
|---|---|---|---|---|
| instanceId | 是 | CONSTANT | 分布式消息服务RocketMQ实例ID。 | 无 |
| topic | 是 | CONSTANT | 主题名称。 | 无 |
| groupName | 是 | CONSTANT | 消费组名。 | 无 |
| initialOffset | 是 | CONSTANT | 消息位点。
| 无 |
| tag | 否 | CONSTANT | 消息过滤的Tag。 | 无 |
| dataFormat | 否 | CONSTANT | 数据格式,不填时默认为JSON编码格式：
| 无 |
请求示例如下：
{
"type": "rocketmq",
"params": [
{
"resourceKey": "instanceId",
"value": "89ceb110331xxxxx499744c2ccbdbcc",
"form": "CONSTANT"
},
{
"resourceKey": "topic",
"value": "TopicA",
"form": "CONSTANT"
},
{
"resourceKey": "tag",
"value": "",
"form": "CONSTANT"
},
{
"resourceKey": "groupName",
"value": "GID_EVENTBRIDGE_1753671233631",
"form": "CONSTANT"
},
{
"resourceKey": "initialOffset",
"value": "earliest",
"form": "CONSTANT"
},
{
"resourceKey": "dataFormat",
"value": "JSON",
"form": "CONSTANT"
}
]
}分布式消息服务RabbitMQ
当事件源的事件提供方选择分布式消息服务RabbitMQ时，请求参数中的type为rabbitmq，params中的resourceKey字段含义如下表所示：
| resourceKey | 是否必传 | form | value | template |
|---|---|---|---|---|
| instanceId | 是 | CONSTANT | 分布式消息服务RabbitMQ实例ID。 | 无 |
| vhost | 是 | CONSTANT | vhost名称。 | 无 |
| queueName | 是 | CONSTANT | 队列名。 | 无 |
请求示例如下：
{
"type": "rabbitmq",
"params": [
{
"resourceKey": "instanceId",
"value": "e8c05d2c9f44d77a703373c6737df98b",
"form": "CONSTANT"
},
{
"resourceKey": "vhost",
"value": "/",
"form": "CONSTANT"
},
{
"resourceKey": "queueName",
"value": "test1",
"form": "CONSTANT"
}
]
}分布式消息服务MQTT
当事件源的事件提供方选择分布式消息服务MQTT时，请求参数中的type为mqtt，params中的resourceKey字段含义如下表所示：
| resourceKey | 是否必传 | form | value | template |
|---|---|---|---|---|
| instanceId | 是 | CONSTANT | 分布式消息服务MQTT实例ID。 | 无 |
| topic | 是 | CONSTANT | 主题名称。 | 无 |
| dataFormat | 否 | CONSTANT | 数据格式,不填时默认为JSON编码格式：
| 无 |
请求示例如下：
{
"type": "mqtt",
"params": [
{
"resourceKey": "instanceId",
"value": "26554575ff4dxxxxxf69ee17838d11ca",
"form": "CONSTANT"
},
{
"resourceKey": "topic",
"value": "test1",
"form": "CONSTANT"
},
{
"resourceKey": "dataFormat",
"value": "JSON",
"form": "CONSTANT"
}
]
}
