CreateEventSource - 创建一个事件源 - 事件总线EventBridge

创建一个外部事件源。

接口说明

创建一个外部事件源。

调试

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

调试

授权信息

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

操作：是指具体的权限点。
访问级别：是指每个操作的访问级别，取值为写入（Write）、读取（Read）或列出（List）。
资源类型：是指操作中支持授权的资源类型。具体说明如下：
- 对于必选的资源类型，用背景高亮的方式表示。
- 对于不支持资源级授权的操作，用全部资源表示。
条件关键字：是指云产品自身定义的条件关键字。
关联操作：是指成功执行操作所需要的其他权限。操作者必须同时具备关联操作的权限，操作才能成功。

操作	访问级别	资源类型	条件关键字	关联操作
eventbridge:CreateEventSource	create	EventSource `acs:eventbridge:{#regionId}:{#accountId}:eventbus/{#EventBusName}/eventsource/`	无	无

请求参数

名称	类型	必填	描述	示例值
EventSourceName	string	是	事件源名称。	myrabbitmq.sourc
Description	string	否	事件源描述详情。	RabbitMQ事件源
LinkedExternalSource	boolean	否	是否连接外部数据源	true
ExternalSourceType	byte	否	外部数据源类型	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	long	否	时间戳。仅当参数 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****

请求示例 `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

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

变更历史

变更时间	变更内容概要	操作
2023-10-19	OpenAPI 错误码发生变更	查看变更详情
2023-08-01	OpenAPI 错误码发生变更	查看变更详情
2023-08-01	OpenAPI 错误码发生变更	查看变更详情
2023-04-21	OpenAPI 错误码发生变更、OpenAPI 入参发生变更	查看变更详情
2023-04-06	OpenAPI 错误码发生变更	查看变更详情