CreateEventStreaming

URL

/eventstreaming/createEventStreaming

Usage notes

• In an EventStreaming, you can specify only one of the SourceMNSParameters, SourceRocketMQParameters, and SourceRabbitMQParameters parameters.
• In an EventStreaming, you can specify only one of the SinkMNSParameters, SinkRocketMQParameters, and SinkRabbitMQParameters parameters.

Request parameters

Request parameter SourceMNSParameters

If you specify the SourceMNSParameters parameter, you can set the parameters described in the following table.

Request parameter SourceRocketMQParameters

If you specify the SourceRocketMQParameters parameter, you can set the parameters described in the following table.

Request parameter SourceRabbitMQParameters

If you specify the SourceRabbitMQParameters parameter, you can set the parameters described in the following table.

Request parameter SinkMNSParameters

If you specify the SinkMNSParameters parameter, you can set the parameters described in the following table.

{
  "key": "value"
}

Request parameter SinkRocketMQParameters

If you specify the SinkRocketMQParameters parameter, you can set the parameters described in the following table.

{
  "key": "value"
}

{
  "key": "value"
}

{
  "key": "value"
}

{
  "key": "value"
}

Request parameter SinkRabbitMQParameters

If you specify the SinkRabbitMQParameters parameter, you can set the parameters described in the following table.

{
  "key": "value"
}

{
  "key": "value"
}

{
  "key": "value"
}

Response parameters

Examples

In the following sample requests and responses, events are routed from the custom event source of the Message Queue for Apache RocketMQ type to the event target MNS.

Sample requests

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"
        }
    }
}

Sample responses

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
}