查询所有外部事件源。
接口说明
查询所有外部事件源。
调试
您可以在OpenAPI Explorer中直接运行该接口,免去您计算签名的困扰。运行成功后,OpenAPI Explorer可以自动生成SDK代码示例。
调试
授权信息
请求参数
|
名称 |
类型 |
必填 |
描述 |
示例值 |
| NamePrefix |
string |
否 |
事件源名称。 |
testName |
| EventBusName |
string |
否 |
事件总线名称。 |
testBus |
| Limit |
integer |
否 |
限定每次返回的最大条数,可以和 NextToken 搭配使用实现翻页能力。 注意每次返回的最大条数不超过 100。 |
50 |
| NextToken |
string |
否 |
当指定 Limit 时,如果还有多余的返回值则会返回 NextToken。 |
100 |
返回参数
|
名称 |
类型 |
描述 |
示例值 |
|
object |
|||
| Message |
string |
错误信息。 |
InvalidArgument |
| RequestId |
string |
阿里云为该请求生成的唯一标识符。 |
5169654A-7059-57E3-BFD9-33C7E012**** |
| Data |
object |
返回数据。 |
|
| NextToken |
string |
当指定 Limit 时,如果还有多余的返回值则会返回 NextToken。 |
100 |
| Total |
integer |
总条数 |
18 |
| EventSourceList |
array<object> |
事件源列表。 |
|
|
array<object> |
事件源数据结构。 |
||
| Name |
string |
查询到的事件源的名称。 |
rocketmq.source |
| Arn |
string |
查询到的事件源在阿里云上的统一资源标识(ARN)。 |
acs:eventbridge:cn-hangzhou:164901546557****:eventbus/my-event-bus/eventsource/myRocketMQ.source |
| Status |
string |
查询到的事件源的状态。 取值说明如下: Activated:激活状态 |
Activated |
| Type |
string |
查询到的事件源的类型。 取值说明如下: UserDefined:外部事件源 |
UserDefined |
| Ctime |
number |
创建时间戳。 |
1607071602000 |
| ExternalSourceType |
string |
事件来源类型。 |
RabbitMQ |
| EventBusName |
string |
事件总线的名称。 |
test-custom-bus |
| SourceMNSParameters |
object |
轻量消息队列(原 MNS)事件源参数。 |
|
| RegionId |
string |
轻量消息队列(原 MNS)的队列所在的地域。 |
cn-hangzhou |
| QueueName |
string |
轻量消息队列(原 MNS)的 Queue 的名称。 |
queue.openapi-sign-callback |
| IsBase64Decode |
boolean |
是否开启 Base64 解码。默认为勾选,即开启 Base64 解码。 |
true |
| SourceRocketMQParameters |
object |
请求参数 SourceRocketMQParameters。 |
|
| RegionId |
string |
消息队列 RocketMQ 版的实例所属地域。 |
cn-shenzhen |
| InstanceId |
string |
消息队列 RocketMQ 版的实例 ID。更多信息,请参见使用限制。 |
bastionhost-cn-7mz293s9d1p |
| Topic |
string |
消息队列 RocketMQ 版实例的 Topic 名称。更多信息,请参见使用限制。 |
migration_instance |
| Tag |
string |
消息的过滤标签。 |
dataact |
| Offset |
string |
消息的消费位点。取值说明如下:
默认值:CONSUME_FROM_LAST_OFFSET。 |
CONSUMEFROMLASTOFFSET |
| Timestamp |
number |
时间戳。仅当参数 Offset 取值为 CONSUME_FROM_TIMESTAMP 时,该参数有效。 |
1664591760 |
| GroupId |
string |
消息队列 RocketMQ 版的 Group ID。 |
GID-test |
| InstanceType |
string |
实例类型。只能填写 CLOUD_4(云上 4.0 实例)、CLOUD_5(云上 5.0 实例)和 SELF_BUILT(自建 MQ)。 |
CLOUD_5 |
| InstanceNetwork |
string |
实例网络。 |
PublicNetwork |
| InstanceVpcId |
string |
专有网络 VPC 的 ID。 |
vpc-*** |
| InstanceVSwitchIds |
string |
交换机 ID。 |
vsw-bp1iu*** |
| InstanceSecurityGroupId |
string |
安全组 ID。 |
eb-167adad548*** |
| AuthType |
string |
ACL 或者不填。 |
ACL |
| InstanceEndpoint |
string |
实例接入点。 |
registry-vpc.cn-hangzhou.aliyuncs.com |
| InstanceUsername |
string |
实例用户名。 |
root |
| InstancePassword |
string |
实例密码。 |
*** |
| SourceRabbitMQParameters |
object |
请求参数 SourceRabbitMQParameters。 |
|
| RegionId |
string |
消息队列 RabbitMQ 版实例所在的地域。 |
cn-hangzhou |
| InstanceId |
string |
消息队列 RabbitMQ 版的实例的 ID。更多信息,请参见使用限制。 |
bastionhost-cn-0ju2x28fj07 |
| VirtualHostName |
string |
消息队列 RabbitMQ 版实例的 Vhost 的名称。更多信息,请参见使用限制。 |
eb-connect |
| QueueName |
string |
消息队列 RabbitMQ 版实例的 Queue 的名称。更多信息,请参见使用限制。 |
file-upload-queue |
| SourceSLSParameters |
object |
请求参数 SourceSLSParameters。 |
|
| Project |
string |
日志服务 SLS 的日志项目。 |
VideoTestProject |
| LogStore |
string |
日志服务 SLS 的日志库。 |
cloudfirewall-logstore |
| ConsumePosition |
string |
起始消费位点,可以选择最早或最新位点,分别对应“begin”,“end”,也可以从指定时间开始消费,以秒为单位。 |
end |
| RoleName |
string |
授权事件总线 EventBridge 使用此角色读取 SLS 日志内容时,需满足条件:在 RAM 控制台创建服务所使用的角色时,需要选择“阿里云服务”,并且“受信服务”需要选择“事件总线”。此角色权限策略可参考自定义事件源日志服务 SLS。 |
testRole |
| SourceHttpEventParameters |
object |
请求参数 SourceHttpEventParameters。 |
|
| Type |
string |
生成的 Webhook 支持的协议类型。取值说明如下:
|
HTTPS |
| Method |
array |
生成的 Webhook 支持的 HTTP 请求方法。可多选,可选范围如下:
|
|
|
string |
生成的 Webhook 支持的 HTTP 请求方法。可多选,可选范围如下:
|
GET |
|
| SecurityConfig |
string |
选择安全配置的类型。可选范围如下:
|
none |
| Ip |
array |
IP 网段安全配置。仅在 SecurityConfig 取值为 ip 时,需要设置该参数。可填写 IP 地址段或 IP 地址。 |
|
|
string |
IP 网段安全配置。仅在 SecurityConfig 取值为 ip 时,需要设置该参数。可填写 IP 地址段或 IP 地址。 |
8.212.139.16/32 |
|
| Referer |
array |
安全域名配置。仅在 SecurityConfig 取值为 referer 时,需要设置该参数。可填写域名。 |
|
|
string |
安全域名配置。仅在 SecurityConfig 取值为 referer 时,需要设置该参数。可填写域名。 |
aliyundoc.com |
|
| PublicWebHookUrl |
array |
公网请求 URL。 |
|
|
string |
公网请求 URL。 |
http://***.eventbridge.cn-hangzhou.aliyuncs.com/webhook/putEvents?token=*** |
|
| VpcWebHookUrl |
array |
内网请求 URL。 |
|
|
string |
内网请求 URL。 |
http://***.eventbridge.cn-hangzhou-vpc.aliyuncs.com/webhook/putEvents?token=0f6705c9253540e1a53e06db011a25b52068562ca50d4818828fffd61c5af*** |
|
| SourceKafkaParameters |
object |
Kafka 事件源参数。 |
|
| InstanceId |
string |
实例 ID。 |
i-2ze6kiwzkebf04s5h8ds |
| ConsumerGroup |
string |
订阅该 Topic 的消费者所对应的 Group ID。 |
test-gid |
| Topic |
string |
主题名称。 |
topic_api_1674441611897 |
| OffsetReset |
string |
消费位点。 |
earliest |
| RegionId |
string |
地域 ID。 |
cn-hangzhou |
| MaximumTasks |
integer |
并发配额(消费者数)。 |
2 |
| Network |
string |
网络配置 :Default(默认网络)和 PublicNetwork(自建网络)。 |
Default |
| SecurityGroupId |
string |
安全组 ID。 |
sg-f8zatts5g97x0j*** |
| VpcId |
string |
VPC ID。 |
vpc-bp1kz3ohhzgrau2*** |
| VSwitchIds |
string |
交换机 ID。 |
vsw-bp1hcrxq3mkcik***e |
| SourceScheduledEventParameters |
object |
时间事件源参数。 |
|
| Schedule |
string |
Cron 表达式 |
0 1 * * * * |
| TimeZone |
string |
Cron 执行时区。 |
GMT+0:00 |
| UserData |
string |
JSON 字符串 |
{"a": "b"} |
| SourceOSSEventParameters |
object |
||
| EventTypes |
array |
||
|
string |
|||
| StsRoleArn |
string |
||
| MatchRules |
any |
||
| Code |
string |
接口返回码:
|
Success |
| Success |
boolean |
操作成功返回 true。 |
true |
返回示例 : `HTTP/1.1 200 OK Server: AliyunEventBridge Connection: keep-alive Content-Type: application/json;charset=utf-8 Content-Length: 79 x-eventbridge-request-id: 608C6467-3195-42A3-97B5-C51FB976**** Date: Sat, 18 Apr 2020 05:30:41 GMT
{ "code":"200", "data":{ "RequestId":"608C6467-3195-42A3-97B5-C51FB976****", "Data":{ "eventSourceList":[ { "Status":"Activated", "Type":"UserDefined", "Ctime":1626360902642, "EventBusName": "demo-bus", "SourceRocketMQParameters":{ "InstanceId":"MQ_INST_164901546557_BXmr", "Tag":"", "RegionId":"cn-hangzhou", "Topic":"demo-topic", "GroupID":"GID_SOURCE", "Offset":"CONSUME_FROM_LAST_OFFSET" }, "ARN":"acs:eventbridge:cn-hangzhou:164901546557****:eventbus/my-event-bus/eventsource/myRocketMQ.source", "Name":"demo.source" } ] }, "Code":"Success", "Success":true }, "httpStatusCode":"200", "requestId":"608C6467-3195-42A3-97B5-C51FB976****", "successResponse":true }`
示例
正常返回示例
JSON格式
{
"Message": "InvalidArgument",
"RequestId": "5169654A-7059-57E3-BFD9-33C7E012****",
"Data": {
"NextToken": "100",
"Total": 18,
"EventSourceList": [
{
"Name": "rocketmq.source",
"Arn": "acs:eventbridge:cn-hangzhou:164901546557****:eventbus/my-event-bus/eventsource/myRocketMQ.source",
"Status": "Activated",
"Type": "UserDefined",
"Ctime": 1607071602000,
"ExternalSourceType": "RabbitMQ",
"EventBusName": "test-custom-bus",
"SourceMNSParameters": {
"RegionId": "cn-hangzhou",
"QueueName": "queue.openapi-sign-callback",
"IsBase64Decode": true
},
"SourceRocketMQParameters": {
"RegionId": "cn-shenzhen",
"InstanceId": "bastionhost-cn-7mz293s9d1p",
"Topic": "migration_instance",
"Tag": "dataact",
"Offset": "CONSUMEFROMLASTOFFSET",
"Timestamp": 1664591760,
"GroupId": "GID-test",
"InstanceType": "CLOUD_5",
"InstanceNetwork": "PublicNetwork",
"InstanceVpcId": "vpc-***",
"InstanceVSwitchIds": "vsw-bp1iu***",
"InstanceSecurityGroupId": "eb-167adad548***",
"AuthType": "ACL",
"InstanceEndpoint": "registry-vpc.cn-hangzhou.aliyuncs.com",
"InstanceUsername": "root",
"InstancePassword": "***"
},
"SourceRabbitMQParameters": {
"RegionId": "cn-hangzhou",
"InstanceId": "bastionhost-cn-0ju2x28fj07",
"VirtualHostName": "eb-connect",
"QueueName": "file-upload-queue"
},
"SourceSLSParameters": {
"Project": "VideoTestProject",
"LogStore": "cloudfirewall-logstore",
"ConsumePosition": "end",
"RoleName": "testRole"
},
"SourceHttpEventParameters": {
"Type": "HTTPS",
"Method": [
"GET"
],
"SecurityConfig": "none",
"Ip": [
"8.212.139.16/32"
],
"Referer": [
"aliyundoc.com\t"
],
"PublicWebHookUrl": [
"http://***.eventbridge.cn-hangzhou.aliyuncs.com/webhook/putEvents?token=***"
],
"VpcWebHookUrl": [
"http://***.eventbridge.cn-hangzhou-vpc.aliyuncs.com/webhook/putEvents?token=0f6705c9253540e1a53e06db011a25b52068562ca50d4818828fffd61c5af***"
]
},
"SourceKafkaParameters": {
"InstanceId": "i-2ze6kiwzkebf04s5h8ds",
"ConsumerGroup": "test-gid",
"Topic": "topic_api_1674441611897",
"OffsetReset": "earliest",
"RegionId": "cn-hangzhou",
"MaximumTasks": 2,
"Network": "Default",
"SecurityGroupId": "sg-f8zatts5g97x0j***",
"VpcId": "vpc-bp1kz3ohhzgrau2***",
"VSwitchIds": "vsw-bp1hcrxq3mkcik***e"
},
"SourceScheduledEventParameters": {
"Schedule": "0 1 * * * *",
"TimeZone": "GMT+0:00",
"UserData": "{\"a\": \"b\"}"
},
"SourceOSSEventParameters": {
"EventTypes": [
""
],
"StsRoleArn": "",
"MatchRules": ""
}
}
]
},
"Code": "Success",
"Success": true
}
错误码
|
HTTP status code |
错误码 |
错误信息 |
描述 |
|---|---|---|---|
| 403 | ServiceNotEnable | Service not enable |
访问错误中心查看更多错误码。
变更历史
更多信息,参考变更详情。