:CreateEventStreaming

URL

/eventstreaming/createEventStreaming

使用上の注意

• イベントストリームでは、SourceMNSParameters、SourceRocketMQParameters、SourceRabbitMQParameters、SourceSLSParameters パラメーターのいずれか 1 つのみが返されます。
• イベントストリームでは、SinkMNSParameters、SinkRocketMQParameters、SinkRabbitMQParameters、SinkSLSParameters パラメーターのいずれか 1 つのみを指定できます。

使用上の注意

リクエストパラメーター SourceMNSParameters

SourceMNSParameters パラメーターを指定する場合、次の表に示すパラメーターを設定できます。

リクエストパラメータ SourceRocketMQParameters

SourceRocketMQParameters パラメータを指定する場合、次の表に示すパラメータを設定できます。

リクエストパラメータ SourceRabbitMQParameters

SourceRabbitMQParameters パラメータを指定する場合、次の表に示すパラメータを設定できます。

リクエストパラメーター SourceSLSParameters

SourceMNSParameters パラメーターを指定する場合、次の表に示すパラメーターを設定できます。

リクエストパラメーター SinkMNSParameters

SinkMNSParameters パラメーターを指定すると、次の表に示すパラメーターを設定できます。

{
  "key": "value"
}

リクエストパラメーターSinkRocketMQ パラメーター

SinkRocketMQParameters パラメーターを指定する場合、次の表に示すパラメーターを構成できます。

{
  "key": "value"
}

{
  "key": "value"
}

{
  "key": "value"
}

{
  "key": "value"
}

リクエストパラメータ SinkRabbitMQParameters

SinkRabbitMQParameters パラメータを指定する場合、次の表に示すパラメータを設定できます。

{
  "key": "value"
}

{
  "key": "value"
}

{
  "key": "value"
}

リクエストパラメータ SinkSLSParameters

SinkRabbitMQParameters パラメータを指定する場合、次の表に示すパラメータを設定できます。

レスポンスパラメーター

例

以下のサンプルリクエストとレスポンスでは、ApsaraMQ for RocketMQ タイプのカスタムイベントソースから、イベントターゲット Simple Message Queue (旧称 MNS) にイベントがルーティングされます。

サンプルリクエスト

POST /eventstreaming/creatEventStreaming 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

{
    "EventStreamingName":"myeventstreaming",
    "Description":"rocketmq2mns",
    "FilterPattern":"{}",
    "Source":{
        "SourceRocketMQParameters":{
            "InstanceId":"MQ_INST_164901546557****_BAAN****",
            "GroupID":"GID_group1",
            "Topic":"mytopic",
            "Offset":"CONSUME_FROM_TIMESTAMP",
            "Tag":"",
            "RegionId":"cn-hangzhou",
            "Timestamp":1636597951964
        }
    },
    "Sink":{
        "SinkMNSParameters":{
            "QueueName":{
                "Value":"MyQueue",
                "Form":"CONSTANT"
            },
            "IsBase64Encode":{
                "Value":"true",
                "Form":"CONSTANT"
            },
            "Body":{
                "Value":{
                    "key":"value"
                },
                "Form":"TEMPLATE",
                "Template":"The value of ${key} is ${value}!"
            }
        }
    },
    "RunOptions":{
        "ErrorsTolerance":"ALL",
        "RetryStrategy":{
            "PushRetryStrategy":"BACKOFF_RETRY"
        },
        "DeadLetterQueue":{
            "Arn":"acs:mq:cn-chengdu:164901546557****:/instances/MQ_INST_164901546557****_BXxk0KXx/topic/Mytopic"
        }
    }
}

サンプルレスポンス

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":{
            "EventStreamingARN":"acs:eventbridge:cn-hangzhou:164901546557****:eventstreaming/myeventstreaming"
        },
        "Code":"Success",
        "Success":true
    },
    "httpStatusCode":"200",
    "requestId":"244BED53-719A-15D7-B7F9-1C404273****",
    "successResponse":true
}