URL
/eventstreaming/listEventStreamings
使用上の注意
- イベントストリームでは、SourceMNSParameters、SourceRocketMQParameters、SourceRabbitMQParameters、SourceSLSParameters パラメーターのうち 1 つのみが返されます。
- イベントストリームでは、SinkMNSParameters、SinkRocketMQParameters、SinkRabbitMQParameters、 SinkSLSParameters パラメーターのうち 1 つのみが返されます。
レスポンスパラメーター
| パラメーター | タイプ | 例 | 説明 |
| EventStreamingName | String | rocketmq-sync | 返されるイベントストリームの名前。 |
| Description | String | RocketMQ-to-RocketMQ | 返されるイベントストリームの説明。 |
| Status | String | RUNNING | 返されるイベントストリームのステータス。有効な値:- READY
- STARTING
- STARTING_FAILED
- RUNNING
- RUNNING_FAILED
- PAUSED
|
| Source | Object | SourceRocketMQParameters | イベントプロバイダー。 |
| SourceMNSParameters | Object | | イベントプロバイダーが Simple Message Queue (旧 MNS) であることを示します。 |
| SourceRocketMQParameters | Object | | イベントプロバイダーが RocketMQ であることを示します。 |
| SourceRabbitMQParameters | Object | | イベントプロバイダーが RabbitMQ であることを示します。 |
| SourceSLSParameters | Object | | イベントプロバイダーがログサービスであることを示します。 |
| FilterPattern | Map | なし | イベントをフィルタリングするために使用されるルール。このパラメーターを空のままにすると、すべてのイベントが一致しま す。 |
| Sink | Object | SinkRocketMQParameters | イベントターゲット。 |
| SinkMNSParameters | Object | | イベントターゲットが Simple Message Queue (旧 MNS) であることを示します。 |
| SinkRocketMQParameters | Object | | イベントターゲットが RocketMQ であることを示します。 |
| SinkRabbitMQParameters | Object | | イベントターゲットが RabbitMQ であることを示します。 |
| SinkSLSParameters | Object | | イベントターゲットがログサービスであることを示します。 |
| RunOptions | Map | | ランタイム環境。 |
| RetryStrategy | String | BACKOFF_RETRY | イベントのプッシュに失敗した場合に使用される再試行ポリシー。有効な値:- BACKOFF_RETRY: バックオフ再試行。リクエストは最大 3 回まで再試行できます。2 回の連続した再試行の間隔は、10 ~ 20 秒のランダムな値です。
- EXPONENTIAL_DECAY_RETRY: 指数関数的減衰再試行。リクエストは最大 176 回まで再試行できます。2 回の連続した再試行の間隔は指数関数的に増加して 512 秒になり、合計再試行時間は 1 日です。具体的な再試行間隔は、1、2、4、8、16、32、64、128、256、512、512、...、512 秒で、最大 167 回の 512 秒を含みます。
|
| ErrorsTolerance | String | ALL | フォールトトレランスポリシー。このポリシーは、エラーが発生した場合にエラーを無視するかどうかを指定します。有効な値:- ALL: エラーを無視します。
- NONE: エラーを無視しません。
|
レスポンスパラメーター SourceMNSParameters
| パラメーター | タイプ | 例 | 説明 |
| QueueName | String | demo | Simple Message Queue (旧 MNS) インスタンス内のキューの名前。 |
| IsBase64Decode | String | true | Base64 エンコーディングが有効になっているかどうかを示します。 |
レスポンスパラメーター SourceRocketMQParameters
| パラメーター | タイプ | 例 | 説明 |
| RegionId | String | cn-hangzhou | RocketMQ インスタンスが存在するリージョンの ID。ApsaraMQ for RocketMQ |
| InstanceId | String | MQ_INST_164901546557****_BAAN**** | RocketMQ インスタンスの ID。詳細については、「ApsaraMQ for RocketMQ制限」をご参照ください。 |
| Topic | String | mytopic | RocketMQ インスタンス内のトピックの名前。詳細については、「ApsaraMQ for RocketMQ制限」をご参照ください。 |
| Tag | String | test | メッセージのフィルタリングに使用されるタグ。 |
| Offset | String | CONSUME_FROM_TIMESTAMP | メッセージのコンシューマーオフセット。有効な値:- CONSUME_FROM_LAST_OFFSET: 最新のオフセットから消費を開始します。
- CONSUME_FROM_FIRST_OFFSET: 最も古いオフセットから消費を開始します。
- CONSUME_FROM_TIMESTAMP: 指定された時点のオフセットから消費を開始します。
|
| Timestamp | Long | 1636597951964 | 消費を開始するオフセットのタイムスタンプ。このパラメーターは、Offset パラメーターを CONSUME_FROM_TIMESTAMP に設定した場合にのみ有効です。 |
| GroupID | String | GID_group1 | RocketMQ インスタンスのグループ ID。ApsaraMQ for RocketMQ |
レスポンスパラメーター SourceRabbitMQParameters
| パラメーター | タイプ | 例 | 説明 |
| InstanceId | String | amqp-cn-nif22u74**** | RabbitMQ インスタンスの ID。詳細については、「ApsaraMQ for RabbitMQ制限」をご参照ください。 |
| VirtualHostName | String | eb-connect | RabbitMQ インスタンスの vhost の名前。詳細については、「ApsaraMQ for RabbitMQ制限」をご参照ください。 |
| QueueName | String | demo | RabbitMQ インスタンスのキューの名前。詳細については、「ApsaraMQ for RabbitMQ制限」をご参照ください。 |
レスポンスパラメーター SourceSLSParameters
| パラメーター | タイプ | 必須 | 例 | 説明 |
| Project | String | はい | test-project | ログサービスプロジェクト。 |
| LogStore | String | はい | test-logstore | ログサービスログストア。 |
| ConsumePosition | String | いいえ | end | 開始コンシューマーオフセット。値 begin は最も古いオフセットを示し、値 end は最新のオフセットを示します。消費を開始する時間を秒単位で指定することもできます。 |
| RoleName | String | はい | testRole | ロールの名前。EventBridge がこのロールを使用してログサービスのログを読み取ることを承認するには、RAM コンソールでロールを作成するときに、[選択された信頼エンティティ] パラメーターで [Alibaba Cloud サービス] を選択し、[信頼されたサービスを選択] パラメーターで [EventBridge] を選択する必要があります。EventBridge |
レスポンスパラメーター SinkMNSParameters
| パラメーター | タイプ | 例 | 説明 |
| QueueName | TargetParameter | | イベントターゲットが Simple Message Queue (旧 MNS) の場合に指定するキューの名前。 |
| Form | String | CONSTANT | 変換方法。 |
| Value | String | MyQueue | Simple Message Queue (旧 MNS) インスタンスのキューの名前。簡易メッセージキュー (旧称 MNS) |
| IsBase64Encode | TargetParameter | | Base64 エンコーディングが有効になっているかどうかを示します。 |
| Value | String | true | Base64 エンコーディングが有効になっていることを示します。 |
| Form | String | CONSTANT | 変換方法。 |
| Body | TargetParameter | | メッセージの内容。 |
| Form | String | TEMPLATE | 変換方法。 |
| Value | String | {
"key": "value"
}
| 変換前の値。 |
レスポンスパラメーター SinkRocketMQParameters
| パラメーター | タイプ | 例 | 説明 |
| InstanceId | TargetParameter | | イベントターゲットが RocketMQ の場合に指定するインスタンスの ID。ApsaraMQ for RocketMQ |
| Value | String | MQ_INST_164901546557****_BAAN5UF8 | RocketMQ インスタンスの ID。詳細については、「ApsaraMQ for RocketMQ制限」をご参照ください。 |
| Form | String | CONSTANT | 変換方法。 |
| Topic | TargetParameter | | RocketMQ インスタンスのトピック。ApsaraMQ for RocketMQ |
| Value | String | Mytopic | RocketMQ インスタンスのトピックの名前。詳細については、「ApsaraMQ for RocketMQ制限」をご参照ください。 |
| Form | String | CONSTANT | 変換方法。 |
| Body | TargetParameter | | メッセージの内容。 |
| Form | String | いいえ | TEMPLATE |
| Value | String | {
"key": "value"
}
| 変換前の値。 |
| Template | String | The value of ${key} is ${value}! | イベントが変換されるテンプレート。 |
| Properties | TargetParameter | | メッセージのフィルタリングに使用されるプロパティ。 |
| Value | String | {
"key": "value"
}
| 変換前の値。 |
| Form | String | TEMPLATE | 変換方法。 |
| Template | String | The value of ${key} is ${value}! | イベントが変換されるテンプレート。 |
| Keys | TargetParameter | | メッセージのフィルタリングに使用されるプロパティ。 |
| Value | String | {
"key": "value"
}
| 変換前の値。 |
| Form | String | TEMPLATE | 変換方法。 |
| Template | String | The value of ${key} is ${value}! | イベントが変換されるテンプレート。 |
| Tags | TargetParameter | | メッセージのフィルタリングに使用されるプロパティ。 |
| Value | String | {
"key": "value"
}
| 変換前の値。 |
| Form | String | TEMPLATE | 変換方法。 |
| Template | String | The value of ${key} is ${value}! | イベントが変換されるテンプレート。 |
レスポンスパラメーター SinkRabbitMQParameters
| パラメーター | タイプ | 例 | 説明 |
| InstanceId | TargetParameter | | イベントターゲットが RabbitMQ の場合に指定するインスタンスの ID。ApsaraMQ for RabbitMQ |
| Value | String | amqp-cn-2r42e73o**** | RabbitMQ インスタンスの ID。詳細については、「ApsaraMQ for RabbitMQ制限」をご参照ください。 |
| Form | String | CONSTANT | 変換方法。 |
| VirtualHostName | TargetParameter | | RabbitMQ インスタンスの vhost の名前。ApsaraMQ for RabbitMQ |
| Value | String | rabbit-host | RabbitMQ インスタンスの vhost の名前。詳細については、「ApsaraMQ for RabbitMQ制限」をご参照ください。 |
| Form | String | CONSTANT | 変換方法。 |
| TargetType | TargetParameter | | イベントのプッシュ先のリソースのタイプ。 |
| Value | String | Exchange/Queue | イベントのプッシュ先のリソースのタイプ。有効な値: |
| Form | String | CONSTANT | 変換方法。 |
| Exchange | TargetParameter | | 宛先インスタンスでイベントのプッシュ先の交換の名前。 このパラメーターは、TargetType パラメーターを Exchange に設定した場合にのみ有効です。 |
| Value | String | a_exchange | RabbitMQ インスタンスの交換の名前。詳細については、「ApsaraMQ for RabbitMQ制限」をご参照ください。 |
| Form | String | CONSTANT | 変換方法。 |
| RoutingKey | TargetParameter | | メッセージのルーティングルール。 このパラメーターは、TargetType パラメーターを Exchange に設定した場合にのみ有効です。 |
| Value | String | housekeeping | メッセージのルーティングルール。 |
| Form | String | CONSTANT | 変換方法。 |
| QueueName | TargetParameter | | 宛先インスタンスでイベントのプッシュ先のキューの名前。 このパラメーターは、TargetType パラメーターを Queue に設定した場合にのみ有効です。 |
| Value | String | MyQueue | RabbitMQ インスタンスのキューの名前。詳細については、「制限」をご参照ください。 |
| Form | String | CONSTANT | 変換方法。 |
| Body | TargetParameter | | メッセージの内容。 |
| Form | String | TEMPLATE | 変換方法。 |
| Value | String | {
"key": "value"
}
| 変換前の値。 |
| Template | String | The value of ${key} is ${value}! | イベントが変換されるテンプレート。 |
| MessageId | TargetParameter | | メッセージの ID。 |
| Value | String | {
"key": "value"
}
| 変換前の値。 |
| Form | String | TEMPLATE | 変換方法。 |
| Template | String | The value of ${key} is ${value}! | イベントが変換されるテンプレート。 |
| Properties | TargetParameter | | メッセージのフィルタリングに使用されるプロパティ。 |
| Value | String | {
"key": "value"
}
| 変換前の値。 |
| Form | String | TEMPLATE | 変換方法。 |
| Template | String | The value of ${key} is ${value}! | イベントが変換されるテンプレート。 |
レスポンスパラメーター SinkSLSParameters
| パラメーター | タイプ | 必須 | 例 | 説明 |
| Project | String | はい | test-project | ログサービスプロジェクト。 |
| LogStore | String | はい | test-logstore | ログサービスログストア。 |
| Topic | String | いいえ | testTopic | ログが存在するトピック。このパラメーターの値は、ログサービスの予約フィールド「__topic__」の値と同じです。 |
| RoleName | String | はい | testRole | ロールの名前。EventBridge がこのロールを使用してログサービスのログを読み取ることを承認するには、RAM コンソールでロールを作成するときに、[選択された信頼エンティティ] パラメーターで [Alibaba Cloud サービス] を選択し、[信頼されたサービスを選択] パラメーターで [EventBridge] を選択する必要があります。EventBridge |
例
リクエストの例
POST /eventstreaming/listEventStreaming 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
成功レスポンスの例
{
"code":"200",
"data":{
"RequestId":"0BC5C278-5ADC-1F46-B2E5-3699C207****",
"Data":{
"EventStreamings":[
{
"Status":"READY",
"FilterPattern":"{}",
"Description":"RocketMQ-to-RocketMQ",
"Sink":{
"SinkRocketMQParameters":{
"InstanceId":{
"Form":"CONSTANT",
"Value":"MQ_INST_164901546557****_BAAN5UF8"
},
"Keys":{
"Form":"JSONPATH",
"Value":"systemProperties.KEYS"
},
"Topic":{
"Form":"CONSTANT",
"Value":"mytopic"
},
"Properties":{
"Form":"JSONPATH",
"Value":"systemProperties"
},
"Body":{
"Form":"TEMPLATE",
"Value":"{\n \"key\": \"value\"\n}",
"Template":"The value of ${key} is ${value}!"
},
"Tags":{
"Form":"JSONPATH",
"Value":"systemProperties.TAGS"
}
}
},
"EventStreamingName":"rocketmq-sync",
"Source":{
"SourceRocketMQParameters":{
"InstanceId":"MQ_INST_164901546557****_BAAN5UF8",
"RegionId":"cn-hangzhou",
"Tag":"test",
"Topic":"mytopic",
"Offset":"CONSUME_FROM_LAST_OFFSET",
"GroupID":"GID_group1"
}
},
"RunOptions":{
"ErrorsTolerance":"ALL",
"DeadLetterQueue":{
},
"MaximumTasks":0,
"RetryStrategy":{
"PushRetryStrategy":"BACKOFF_RETRY",
"MaximumRetryAttempts":0,
"MaximumEventAgeInSeconds":0
}
}
},
{
"Status":"READY",
"FilterPattern":"{}",
"Description":"rocketmq-2-mns",
"Sink":{
"SinkMNSParameters":{
"IsBase64Encode":{
"Form":"CONSTANT",
"Value":"true"
},
"QueueName":{
"Form":"CONSTANT",
"Value":"MyQueue"
},
"Body":{
"Form":"TEMPLATE",
"Value":"{\n \"key\": \"value\"\n}",
"Template":"The value of ${key} is ${value}!"
}
}
},
"EventStreamingName":"my-streaming",
"Source":{
"SourceRocketMQParameters":{
"InstanceId":"MQ_INST_164901546557****_BAAN5UF8",
"RegionId":"cn-hangzhou",
"Tag":"",
"Topic":"my-topic",
"Timestamp":1636597951964,
"Offset":"CONSUME_FROM_TIMESTAMP",
"GroupID":"GID-pz-order"
}
},
"RunOptions":{
"ErrorsTolerance":"ALL",
"DeadLetterQueue":{
},
"MaximumTasks":0,
"RetryStrategy":{
"PushRetryStrategy":"BACKOFF_RETRY",
"MaximumRetryAttempts":0,
"MaximumEventAgeInSeconds":0
}
}
}
],
"NextToken":"2",
"Total":2
},
"Code":"Success",
"Success":true
},
"httpStatusCode":"200",
"requestId":"0BC5C278-5ADC-1F46-B2E5-3699C207****",
"successResponse":true
}