CreateEventSource - 创建一个事件源

创建一个外部事件源。

接口说明

创建一个外部事件源。

调试

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

调试

授权信息

当前API暂无授权信息透出。

请求参数

名称

类型

必填

描述

示例值

EventSourceName

string

事件源名称。

myrabbitmq.sourc

Description

string

事件源描述详情。

RabbitMQ事件源

LinkedExternalSource

boolean

是否连接外部数据源

true

ExternalSourceType

string

外部数据源类型

RabbitMQ

ExternalSourceConfig

object

外部数据源配置

{\"Schedule\":\"0 */10 * * * *\",\"TimeZone\":\"GMT+0:00\"}

EventBusName

string

与事件源绑定的事件总线的名称。

my-event-bus

SourceMNSParameters

object

轻量消息队列(原 MNS)事件源参数。选择轻量消息队列(原 MNS)事件源时 RegionId、IsBase64Decode 和 QueueName 都是必填参数。

RegionId

string

轻量消息队列(原 MNS)的队列所在的地域。 可以填写以下地域 :cn-qingdao、cn-beijing、cn-zhangjiakou、cn-huhehaote、cn-wulanchabu、cn-hangzhou、cn-shanghai、cn-shenzhen、cn-guangzhou、cn-chengdu、cn-hongkong、ap-southeast-1、ap-southeast-2、ap-southeast-3、ap-southeast-5、ap-northeast-1、eu-central-1、us-west-1、us-east-1、ap-south-1、me-east-1 和 cn-north-2-gov-1

cn-hangzhou

QueueName

string

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

MyQueue

IsBase64Decode

boolean

是否开启 Base64 解码。填写为 true,即开启 Base64 解码。只能填写 true 或者 false。

true

SourceRocketMQParameters

object

请求参数 SourceRocketMQParameters。

RegionId

string

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

cn-hangzhou

InstanceId

string

消息队列 RocketMQ 版的实例 ID。更多信息,请参见使用限制

MQ_INST_164901546557****_BAAN****

Topic

string

消息队列 RocketMQ 版实例的 Topic 名称。更多信息,请参见使用限制

mytopic

Tag

string

消息的过滤标签。

test

Offset

string

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

CONSUME_FROM_LAST_OFFSET

Timestamp

integer

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

1636597951964

GroupID

string

消息队列 RocketMQ 版的 Group ID。

GID-test

InstanceType

string

实例类型 :

  • 4.0 实例填写:Cloud_4

  • 5.0 实例填写:Cloud_5

Cloud_4

InstanceNetwork

string

InstanceVpcId

string

专有网络需要添加 :vpcId

vpc-bp1a4gmlk31hyg6pt****

InstanceVSwitchIds

string

专有网络需要添加 :vSwitchId

vsw-bp10rbrt6rb6vrd89****

InstanceSecurityGroupId

string

专有网络需要添加 :securityGroupId

sg-catalog-eventlist****

AuthType

string

ACL 或者不填。

ACL

InstanceEndpoint

string

实例接入点。

registry-vpc****.aliyuncs.com

InstanceUsername

string

实例用户名。

root

InstancePassword

string

实例密码。

******

SourceRabbitMQParameters

object

请求参数 SourceRabbitMQParameters

RegionId

string

消息队列 RabbitMQ 版实例所在的地域。

cn-hangzhou

InstanceId

string

消息队列 RabbitMQ 版的实例的 ID。更多信息,请参见使用限制。

amqp-cn-nif22u74****

VirtualHostName

string

消息队列 RabbitMQ 版实例的 Vhost 的名称。更多信息,请参见使用限制

eb-connect

QueueName

string

eb-connect 消息队列 RabbitMQ 版实例的 Queue 的名称。更多信息,请参见使用限制

demo

SourceSLSParameters

object

SourceSLSParameters

Project

string

日志服务 SLS 的日志项目。

test-project

LogStore

string

日志服务 SLS 的日志库。

test-logstore

ConsumePosition

string

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

end

RoleName

string

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

testRole

SourceHttpEventParameters

object

请求参数 SourceHttpEventParameters

Type

string

生成的 Webhook 支持的协议类型。取值说明如下:

  • HTTP

  • HTTPS

  • HTTP&HTTPS

HTTPS

Method

array

生成的 Webhook 支持的 HTTP 请求方法。可多选,可选范围如下:

  • GET

  • POST

  • PUT

  • PATCH

  • DELETE

  • HEAD

  • OPTIONS

  • TRACE

  • CONNECT

string

生成的 Webhook 支持的 HTTP 请求方法。可多选,可选范围如下:

  • GET

  • POST

  • PUT

  • PATCH

  • DELETE

  • HEAD

  • OPTIONS

  • TRACE

  • CONNECT

GET

SecurityConfig

string

选择安全配置的类型。可选范围如下:

  • none:无需配置。

  • ip:IP 网段。

  • referer:安全域名。

none

Ip

array

IP 网段安全配置。仅在 SecurityConfig 取值为 ip 时,需要设置该参数。可填写 IP 地址段或 IP 地址。

string

IP 网段安全配置。仅在 SecurityConfig 取值为 ip 时,需要设置该参数。可填写 IP 地址段或 IP 地址。

10.0.0.0/8

Referer

array

安全域名配置。仅在 SecurityConfig 取值为 referer 时,需要设置该参数。可填写域名。

string

安全域名配置。仅在 SecurityConfig 取值为 referer 时,需要设置该参数。可填写域名。

aliyundoc.com

SourceScheduledEventParameters

object

请求参数 SourceScheduledEventParameters

Schedule

string

Cron 表达式。

10 * * * * *

TimeZone

string

Cron 执行时区。

GMT+0:00

UserData

string

JSON 字符串

{"a": "b"}

SourceKafkaParameters

object

请求参数 SourceKafkaParameters

InstanceId

string

实例 ID。

pc-2zehmg67txzuyuuwl****

ConsumerGroup

string

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

wechat_peer_****

Topic

string

Topic 名称。

prod_ma_dispatch_center_call_re****

OffsetReset

string

消费位点。

latest

RegionId

string

地域 ID。

cn-hangzhou

MaximumTasks

integer

并发配额(消费者数)

1

Network

string

网络配置 :Default(默认网络)和 PublicNetwork(自建网络)。

Default

SecurityGroupId

string

如果是自建网络需要添加:安全组 id

sg-8vbf66aoyp0wfzrz****

VSwitchIds

string

如果是自建网络需要添加:vSwitchId

vsw-bp127azpeirmwu4q9****

VpcId

string

如果是自建网络需要添加:vpcId

vpc-2ze5ejm986a73qq3v****

SourceOSSEventParameters

object

EventTypes

array

string

StsRoleArn

string

MatchRules

array

array<object>

object

Prefix

string

Suffix

string

Name

string

MatchState

boolean

请求示例 `POST /openapi/createEventSource HTTP/1.1 Host: 164901546557****.eventbridge.cn-hangzhou.aliyuncs.com Date: Sat, 18 Apr 2020 05:30:41 GMT x-eventbridge-version: 2020-04-01 Authorization: acs vZ3VL0SuJdHi****:Jo2PbT******azYAYoYslKLvWzg= Content-Type: application/json;charset=UTF-8 Content-Length: 26

{ "EventSourceName":"myRabbitMQ.source", "Description":"RabbitMQ 事件源", "SourceRabbitMQParameters":{ "RegionId":"cn-hangzhou", "InstanceId":"amqp-cn-nif22u74****", "VirtualHostName":"eb-connect", "QueueName":"demo" }, "EventBusName":"my-event-bus" }`

返回参数

名称

类型

描述

示例值

object

请求参数。

Message

string

错误信息。

Remote error. requestId: [A8EFABD2-95B9-1C46-9E01-xxxx], error code: [CreateRelatedResourceFailed], message: [Create related resource failed, EntityNotExist.Role : The role not exists: xxxx. \r\nRequestId : xxxx-168C-54ED-8FEB-BF11CB70AEB7]

RequestId

string

请求 id。

2922208e-e1c6-43ee-bfd1-aca50263bc8a

Data

object

返回数据。

EventSourceARN

string

资源 ARN。

acs:eventbridge:cn-hangzhou:164901546557****:eventbus/my-event-bus/eventsource/mymns.source

Code

string

接口返回码:

  • Success:表示成功。

  • 其它:表示错误码。 错误码详情,请参见错误码。

Success

Success

boolean

操作成功返回 true。

true

示例

正常返回示例

JSON格式

{
  "Message": " Remote error. requestId: [A8EFABD2-95B9-1C46-9E01-xxxx], error code: [CreateRelatedResourceFailed], message: [Create related resource failed, EntityNotExist.Role : The role not exists: xxxx. \\r\\nRequestId : xxxx-168C-54ED-8FEB-BF11CB70AEB7]   ",
  "RequestId": "2922208e-e1c6-43ee-bfd1-aca50263bc8a",
  "Data": {
    "EventSourceARN": "acs:eventbridge:cn-hangzhou:164901546557****:eventbus/my-event-bus/eventsource/mymns.source"
  },
  "Code": "Success",
  "Success": true
}

错误码

HTTP status code

错误码

错误信息

描述

403 ServiceNotEnable Service not enable

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

变更历史

更多信息,参考变更详情