カスタムイベントソースを作成します。
URL
/openapi/createEventSource
使用上の注意
イベントソースに対して、SourceMNSParameters、SourceRocketMQParameters、SourceRabbitMQParameters、SourceHttpEventParameters、SourceSLSParameters パラメーターのいずれか 1 つのみを指定できます。
リクエストパラメーター
| パラメーター | タイプ | 必須 | 例 | 説明 |
| EventSourceName | String | はい | myrabbitmq.source | イベントソースの名前。詳細については、「詳細については、「制限」をご参照ください。」をご参照ください。 |
| Description | String | はい | Event source of the Message Queue for RabbitMQ type | イベントソースの説明。 |
| SourceMNSParameters | Object | いいえ | イベントプロバイダーが シンプルメッセージキュー(旧MNS) であることを指定します。詳細については、「リクエストパラメーター SourceMNSParameters」をご参照ください。 | |
| SourceRocketMQParameters | Object | いいえ | イベントプロバイダーが RocketMQ であることを指定します。詳細については、「リクエストパラメーター SourceRocketMQParameters」をご参照ください。 | |
| SourceRabbitMQParameters | Object | いいえ | イベントプロバイダーが RabbitMQ であることを指定します。詳細については、「リクエストパラメーター SourceRabbitMQParameters」をご参照ください。 | |
| SourceHttpEventParameters | Object | いいえ | イベントプロバイダーが HTTP または HTTPS であることを指定します。詳細については、「リクエストパラメーター SourceHttpEventParameters」をご参照ください。 | |
| SourceSLSParameters | Object | いいえ | イベントプロバイダーがログサービスであることを指定します。詳細については、「リクエストパラメーター SourceSLSParameters」をご参照ください。 | |
| EventBusName | String | はい | my-event-bus | イベントソースを関連付けるイベントバスの名前。詳細については、「詳細については、「制限」をご参照ください。」をご参照ください。 |
リクエストパラメーター SourceMNSParameters
SourceMNSParameters パラメーターを指定する場合、次の表に示すパラメーターを設定できます。
| パラメーター | タイプ | 必須 | 例 | 説明 |
| RegionId | String | はい | cn-zhangjiakou | シンプルメッセージキュー(旧MNS) キューが存在するリージョンの ID。 |
| QueueName | String | はい | MyQueue | シンプルメッセージキュー(旧MNS) インスタンスのキューの名前。 |
| IsBase64Decode | String | はい | true | Base64 デコードを有効にするかどうかを指定します。デフォルト値:true。 |
リクエストパラメーター SourceRocketMQParameters
SourceRocketMQParameters パラメーターを指定する場合、次の表に示すパラメーターを設定できます。
| パラメーター | タイプ | 必須 | 例 | 説明 |
| RegionId | String | はい | cn-zhangjiakou | RocketMQ インスタンスが存在するリージョンの ID。 |
| InstanceId | String | はい | MQ_INST_164901546557****_BAAN**** | RocketMQ インスタンスの ID。詳細については、「制限」をご参照ください。 |
| Topic | String | はい | mytopic | RocketMQ インスタンスのトピックの名前。詳細については、「制限」をご参照ください。 |
| Tag | String | いいえ | test | メッセージのフィルタリングに使用されるタグ。 |
| Offset | String | いいえ | CONSUME_FROM_TIMESTAMP | メッセージのコンシューマーオフセット。有効な値:
デフォルト値:CONSUME_FROM_LAST_OFFSET。 |
| Timestamp | Long | いいえ | 1636597951964 | 消費を開始するオフセットのタイムスタンプ。単位:ミリ秒。このパラメーターは、Offset パラメーターを CONSUME_FROM_TIMESTAMP に設定した場合にのみ有効です。 |
| GroupID | String | はい | GID_group1 | RocketMQ インスタンスのグループの ID。 |
リクエストパラメーター SourceRabbitMQParameters
SourceRabbitMQParameters パラメーターを指定する場合、次の表に示すパラメーターを設定できます。
| パラメーター | タイプ | 必須 | 例 | 説明 |
| RegionId | String | はい | cn-zhangjiakou | RabbitMQ インスタンスが存在するリージョンの ID。 |
| InstanceId | String | はい | amqp-cn-nif22u74**** | RabbitMQ インスタンスの ID。詳細については、「制限」をご参照ください。 |
| VirtualHostName | String | はい | eb-connect | RabbitMQ インスタンスの vhost の名前。詳細については、「制限」をご参照ください。 |
| QueueName | String | はい | demo | RabbitMQ インスタンスのキューの名前。詳細については、「制限」をご参照ください。 |
リクエストパラメーター SourceHttpEventParameters
SourceHttpEventParameters パラメーターを指定する場合、次の表に示すパラメーターを設定できます。
| パラメーター | タイプ | 必須 | 例 | 説明 |
| Type | String | はい | HTTPS | 生成された webhook URL でサポートされるプロトコルタイプ。有効な値:
|
| Method | List | はい | GET | 生成された webhook URL でサポートされる HTTP リクエストメソッド。複数の値を選択できます。有効な値:
|
| SecurityConfig | String | はい | ip | セキュリティ設定のタイプ。有効な値:
|
| Ip | List | いいえ | 10.0.0.0/8 | セキュリティ設定に使用される CIDR ブロック。SecurityConfig パラメーターを ip に設定した場合にのみ必須です。CIDR ブロックまたは IP アドレスを入力できます。複数の CIDR ブロックまたは IP アドレスはコンマ(,)で区切ります。 |
| Referer | List | いいえ | aliyundoc.com | セキュリティドメイン名。このパラメーターは、SecurityConfig パラメーターを referer に設定した場合にのみ必須です。ドメイン名を入力できます。 |
リクエストパラメーター SourceSLSParameters
SourceSLSParameters パラメーターを指定する場合、次の表に示すパラメーターを設定できます。
| パラメーター | タイプ | 必須 | 例 | 説明 |
| Project | String | はい | test-project | ログサービスプロジェクト。 |
| LogStore | String | はい | test-logstore | ログサービスログストア。 |
| ConsumePosition | String | いいえ | end | 開始コンシューマーオフセット。begin 値は最も古いオフセットを示し、end 値は最新のオフセットを示します。消費を開始する時間を秒単位で指定することもできます。 |
| RoleName | String | はい | testRole | ロールの名前。 EventBridge がこのロールを使用してログサービスのログを読み取ることを承認するには、RAM コンソールでロールを作成するときに、[選択された信頼エンティティ] パラメーターで [Alibaba Cloud サービス] を選択し、[信頼されたサービスを選択] パラメーターで [EventBridge] を選択する必要があります。このロールの許可ポリシーについては、「ログサービスタイプのカスタムイベントソースを作成する」をご参照ください。 |
レスポンスパラメーター
| パラメーター | タイプ | 例 | 説明 |
| EventSourceARN | String | acs:eventbridge:cn-hangzhou:164901546557****:eventbus/my-event-bus/eventsource/mymns.source | イベントソースの Alibaba Cloud Resource Name(ARN)。 |
例 1:MNS タイプのカスタムイベントソース
リクエストの例
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":"mymns.source",
"Description":"Event source of the MNS type", // MNS タイプのイベントソース
"SourceMNSParameters":{
"RegionId":"cn-zhangjiakou",
"QueueName":"MyQueue",
"IsBase64Decode":true
},
"EventBusName":"my-event-bus"
}レスポンスの例
HTTP/1.1 200 OK
Server: AliyunEventBridge
Connection: keep-alive
Content-Type: application/json;charset=utf-8
Content-Length: 79
x-eventbridge-request-id: 244BED53-719A-15D7-B7F9-1C404273****
Date: Sat, 18 Apr 2020 05:30:41 GMT
{
"code":"200",
"data":{
"RequestId":"244BED53-719A-15D7-B7F9-1C404273****",
"Data":{
"EventSourceARN":"acs:eventbridge:cn-hangzhou:164901546557****:eventbus/my-event-bus/eventsource/mymns.source"
},
"Code":"Success",
"Success":true
},
"httpStatusCode":"200",
"requestId":"244BED53-719A-15D7-B7F9-1C404273****",
"successResponse":true
}例 2:RocketMQ タイプのカスタムイベントソース
リクエストの例
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":"myRocketMQ.source",
"Description":"Event source of the Message Queue for Apache RocketMQ type", // RocketMQ タイプのイベントソース
"SourceRocketMQParameters":{
"InstanceId":"MQ_INST_164901546557****_BAAN****",
"GroupID":"GID_group1",
"Topic":"mytopic",
"Offset":"CONSUME_FROM_TIMESTAMP",
"Tag":"test",
"RegionId":"cn-hangzhou",
"Timestamp":1636597951964
},
"EventBusName":"my-event-bus"
}レスポンスの例
HTTP/1.1 200 OK
Server: AliyunEventBridge
Connection: keep-alive
Content-Type: application/json;charset=utf-8
Content-Length: 79
x-eventbridge-request-id: 244BED53-719A-15D7-B7F9-1C404273****
Date: Sat, 18 Apr 2020 05:30:41 GMT
{
"code":"200",
"data":{
"RequestId":"244BED53-719A-15D7-B7F9-1C404273****",
"Data":{
"EventSourceARN":"acs:eventbridge:cn-hangzhou:164901546557****:eventbus/my-event-bus/eventsource/myRocketMQ.source"
},
"Code":"Success",
"Success":true
},
"httpStatusCode":"200",
"requestId":"244BED53-719A-15D7-B7F9-1C404273****",
"successResponse":true
}例 3:RabbitMQ タイプのカスタムイベントソース
リクエストの例
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":"Event source of the Message Queue for RabbitMQ type", // RabbitMQ タイプのイベントソース
"SourceRabbitMQParameters":{
"RegionId":"cn-hangzhou",
"InstanceId":"amqp-cn-nif22u74****",
"VirtualHostName":"eb-connect",
"QueueName":"demo"
},
"EventBusName":"my-event-bus"
}レスポンスの例
HTTP/1.1 200 OK
Server: AliyunEventBridge
Connection: keep-alive
Content-Type: application/json;charset=utf-8
Content-Length: 79
x-eventbridge-request-id: 244BED53-719A-15D7-B7F9-1C404273****
Date: Sat, 18 Apr 2020 05:30:41 GMT
{
"code":"200",
"data":{
"RequestId":"244BED53-719A-15D7-B7F9-1C404273****",
"Data":{
"EventSourceARN":"acs:eventbridge:cn-hangzhou:164901546557****:eventbus/my-event-bus/eventsource/myRabbitMQ.source"
},
"Code":"Success",
"Success":true
},
"httpStatusCode":"200",
"requestId":"244BED53-719A-15D7-B7F9-1C404273****",
"successResponse":true
}例 4:HTTP/HTTPS タイプのカスタムイベントソース
リクエストの例
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":"myhttp.source",
"Description":"Event source of the HTTP or HTTPS type", // HTTP または HTTPS タイプのイベントソース
"SourceHttpEventParameters":{
"Type":"HTTPS",
"Method":["GET","POST"],
"SecurityConfig":"ip",
"Ip":["10.0.0.0/8", "192.168.XX.XX"]
},
"EventBusName":"my-event-bus"
}レスポンスの例
HTTP/1.1 200 OK
Server: AliyunEventBridge
Connection: keep-alive
Content-Type: application/json;charset=utf-8
Content-Length: 79
x-eventbridge-request-id: 244BED53-719A-15D7-B7F9-1C404273****
Date: Sat, 18 Apr 2020 05:30:41 GMT
{
"code":"200",
"data":{
"RequestId":"325BED98-734A-15D7-P7F1-7B409088****",
"Data":{
"EventSourceARN":"acs:eventbridge:cn-hangzhou:164901546557****:eventbus/my-event-bus/eventsource/myhttp.source"
},
"Code":"Success",
"Success":true
},
"httpStatusCode":"200",
"requestId":"325BED98-734A-15D7-P7F1-7B409088****",
"successResponse":true
}例 5:ログサービスタイプのカスタムイベントソース
リクエストの例
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":"mySLS.source",
"Description":"Event source of the Log Service type", // ログサービスタイプのイベントソース
"SourceSLSParameters":{
"RegionId":"cn-hangzhou",
"Project":"test-project",
"LogStore":"test-logstore",
"ConsumePosition":"end",
"RoleName":"testRole"
},
"EventBusName":"my-event-bus"
}レスポンスの例
HTTP/1.1 200 OK
Server: AliyunEventBridge
Connection: keep-alive
Content-Type: application/json;charset=utf-8
Content-Length: 79
x-eventbridge-request-id: 244BED53-719A-15D7-B7F9-1C404273****
Date: Sat, 18 Apr 2020 05:30:41 GMT
{
"code":"200",
"data":{
"RequestId":"325BED98-734A-15D7-P7F1-7B409088****",
"Data":{
"EventSourceARN":"acs:eventbridge:cn-hangzhou:164901546557****:eventbus/my-event-bus/eventsource/mySLS.source"
},
"Code":"Success",
"Success":true
},
"httpStatusCode":"200",
"requestId":"325BED98-734A-15D7-P7F1-7B409088****",
"successResponse":true
}