Creating a Metadata Migration Task

Function

This API is used to create a metadata migration task.

Calling Method

For details, see Calling APIs.

URI

POST /v2/{project_id}/instances/{instance_id}/metadata

**Table 1** Path Parameters
Parameter	Mandatory	Type	Description
project_id	Yes	String	Definition Project ID. For details about how to obtain it, see Obtaining a Project ID. Constraints N/A Range N/A Default Value N/A
instance_id	Yes	String	Definition Instance ID. You can call the API for querying all instances to obtain the instance ID. The instance ID is in the response body. Constraints N/A Range N/A Default Value N/A

**Table 2** Query Parameters
Parameter	Mandatory	Type	Description
overwrite	Yes	String	Definition true: Configurations in the metadata file with the same name as the uploaded file will be overwritten. false: An error is reported when a topic or group already exists. Constraints N/A Range N/A Default Value N/A
name	Yes	String	Definition Migration task name. For details about the naming rules, see the API for creating an instance. Constraints N/A Range N/A Default Value N/A
type	Yes	String	Definition Migration task type. The value can be rocketmq or rabbitToRocket. Constraints N/A Range N/A Default Value N/A

Request Parameters

**Table 3** Request body parameters
Parameter	Mandatory	Type	Description
topic_config_table	No	Map<String,MigrationRocketMqTopicConfig>	Definition RocketMQ instance topic metadata. The topic name is the key and the topic configuration is the value. This parameter is mandatory for rocketmq migration tasks (from self-built RocketMQ instances to DMS for RocketMQ). Constraints N/A Range N/A Default Value N/A
subscription_group_table	No	Map<String,MigrationRocketMqSubscriptionGroup>	Definition RocketMQ consumer group metadata. The consumer group name is the key and the configuration is the value. This parameter is mandatory for rocketmq migration tasks (from self-built RocketMQ instances to DMS for RocketMQ). Constraints N/A Range N/A Default Value N/A
vhosts	No	Array of MigrationRabbitVhostMetadata objects	Definition RabbitMQ virtual host metadata list. This parameter is mandatory for rabbitToRocket migration tasks (from self-built RabbitMQ instances to DMS for RocketMQ). Constraints N/A Range N/A Default Value N/A
queues	No	Array of MigrationRabbitQueueMetadata objects	Definition RabbitMQ queue metadata list. This parameter is mandatory for rabbitToRocket migration tasks (from self-built RabbitMQ instances to DMS for RocketMQ). Constraints N/A Range N/A Default Value N/A
exchanges	No	Array of MigrationRabbitExchangeMetadata objects	Definition RabbitMQ exchange metadata list. This parameter is mandatory for rabbitToRocket migration tasks (from self-built RabbitMQ instances to DMS for RocketMQ). Constraints N/A Range N/A Default Value N/A
bindings	No	Array of MigrationRabbitBindingMetadata objects	Definition RabbitMQ binding metadata list. This parameter is mandatory for rabbitToRocket migration tasks (from self-built RabbitMQ instances to DMS for RocketMQ). Constraints N/A Range N/A Default Value N/A

**Table 4** MigrationRocketMqTopicConfig
Parameter	Mandatory	Type	Description
topic_name	No	String	Definition Topic name. Constraints N/A Range N/A Default Value N/A
order	No	Boolean	Definition Whether messages are ordered. Constraints N/A Range true: Yes false" No Default Value false
perm	No	Integer	Definition Topic permissions. Constraints N/A Range PUB: publish permission. SUB: subscribe permission. PUB\|SUB: subscribe and publish permissions. DENY: no permission. Default Value 6
read_queue_nums	No	Integer	Definition Number of read queues. Constraints N/A Range N/A Default Value 16
write_queue_nums	No	Integer	Definition Number of write queues. Constraints N/A Range N/A Default Value 16
topic_filter_type	No	String	Definition Topic filtering type. Constraints N/A Range SINGLE_TAG: single tag MULTI_TAG: multiple tags Default Value N/A
topic_sys_flag	No	Integer	Definition Topic system flag. Constraints N/A Range N/A Default Value 0

**Table 5** MigrationRocketMqSubscriptionGroup
Parameter	Mandatory	Type	Description
group_name	No	String	Definition Consumer group name. Constraints N/A Range N/A Default Value N/A
consume_broadcast_enable	No	Boolean	Definition Whether to allow broadcast. Constraints N/A Range true: Yes false: No Default Value N/A
consume_enable	No	Boolean	Definition Whether to enable consumption. Constraints N/A Range true: Yes false: No Default Value true
consume_from_min_enable	No	Boolean	Definition Whether to enable consumption from the earliest offset. Constraints N/A Range true: Yes false: No Default Value true
notify_consumer_ids_changed_enable	No	Boolean	Definition Whether to notify consumer ID changes. Constraints N/A Range true: Yes false: No Default Value true
retry_max_times	No	Integer	Definition Maximum number of consumption retries. Constraints N/A Range N/A Default Value 16
retry_queue_nums	No	Integer	Definition Maximum number of consumption retries. Constraints N/A Range N/A Default Value 1
which_broker_when_consume_slow	No	Long	Definition ID of the broker selected for slow consumption Constraints N/A Range N/A Default Value 1

**Table 6** MigrationRabbitVhostMetadata
Parameter	Mandatory	Type	Description
name	No	String	Definition Virtual host name. Constraints N/A Range N/A Default Value N/A

**Table 7** MigrationRabbitQueueMetadata
Parameter	Mandatory	Type	Description
vhost	No	String	Definition Virtual host name. Constraints N/A Range N/A Default Value N/A
name	No	String	Definition Queue name. Constraints N/A Range N/A Default Value N/A
durable	No	Boolean	Definition Whether to enable data persistence. Constraints N/A Range true: Yes false: No Default Value N/A

**Table 8** MigrationRabbitExchangeMetadata
Parameter	Mandatory	Type	Description
vhost	No	String	Definition Virtual host name. Constraints N/A Range N/A Default Value N/A
name	No	String	Definition Exchange name. Constraints N/A Range N/A Default Value N/A
type	No	String	Definition Exchange type. Constraints N/A Range topic: Fuzzy match by routing key is supported. direct: Messages are routed in exact match by routing key. fanout: broadcast mode. Messages are sent to all bound queues, regardless of routing keys. headers: Routing is based on the key-value pair in the message header (headers) instead of on the routing key. Default Value N/A
durable	No	Boolean	Definition Whether to enable data persistence. Constraints N/A Range true: Yes false: No Default Value N/A

**Table 9** MigrationRabbitBindingMetadata
Parameter	Mandatory	Type	Description
vhost	No	String	Definition Virtual host name. Constraints N/A Range N/A Default Value N/A
source	No	String	Definition Message source. Constraints N/A Range N/A Default Value N/A
destination	No	String	Definition Message target. Constraints N/A Range N/A Default Value N/A
destination_type	No	String	Definition Target type. Constraints N/A Range exchange queue RabbitMQ AMQP only supports queue bindings. Default Value N/A
routing_key	No	String	Definition Routing key. Constraints N/A Range N/A Default Value N/A

Response Parameters

Status code: 200

**Table 10** Response body parameters
Parameter	Type	Description
task_id	String	Definition Task ID. Constraints N/A Range N/A Default Value N/A

Example Requests

Creating a metadata migration task to migrate the metadata from other vendors' or self-built RocketMQ instances to DMS for RocketMQ.

POST https://{endpoint}/v2/{project_id}/instances/{instance_id}/metadata?overwrite=true&name=task-123&type=rocketmq

{
  "topic_config_table" : {
    "topic-test1" : {
      "order" : false,
      "perm" : 6,
      "read_queue_nums" : 3,
      "topic_filter_type" : "SINGLE_TAG",
      "topic_name" : "topic-test1",
      "topic_sys_flag" : 0,
      "write_queue_nums" : 3
    }
  },
  "subscription_group_table" : {
    "group-test1" : {
      "consume_broadcast_enable" : true,
      "consume_enable" : true,
      "consume_from_min_enable" : true,
      "group_name" : "group-test1",
      "notify_consumer_ids_changed_enable" : true,
      "retry_max_times" : 2,
      "retry_queue_nums" : 1,
      "which_broker_when_consume_slow" : 1
    }
  }
}

Creating a metadata migration task to migrate the metadata of RabbitMQ instances to DMS for RocketMQ.

POST https://{endpoint}/v2/{project_id}/instances/{instance_id}/metadata?overwrite=true&name=task-123&type=rabbitToRocket

{
  "vhosts" : [ {
    "name" : "DeleteVhost123"
  } ],
  "queues" : [ {
    "name" : "test-001",
    "vhost" : "/",
    "durable" : false
  } ],
  "exchanges" : [ {
    "name" : "direct",
    "vhost" : "/",
    "type" : "topic",
    "durable" : false
  } ],
  "bindings" : [ {
    "source" : "direct",
    "vhost" : "/",
    "destination" : "test-001",
    "destination_type" : "queue",
    "routing_key" : "test-001"
  } ]
}

Example Responses

Status code: 200

Successful

{
  "task_id" : "6cf4dcd3-8471-4139-8b5b-8a3a71f704c7"
}

SDK Sample Code

The SDK sample code is as follows.

Creating a metadata migration task to migrate the metadata from other vendors' or self-built RocketMQ instances to DMS for RocketMQ.

        
         
           
           
             package com.huaweicloud.sdk.test;

import com.huaweicloud.sdk.core.auth.ICredential;
import com.huaweicloud.sdk.core.auth.BasicCredentials;
import com.huaweicloud.sdk.core.exception.ConnectionException;
import com.huaweicloud.sdk.core.exception.RequestTimeoutException;
import com.huaweicloud.sdk.core.exception.ServiceResponseException;
import com.huaweicloud.sdk.rocketmq.v2.region.RocketMQRegion;
import com.huaweicloud.sdk.rocketmq.v2.*;
import com.huaweicloud.sdk.rocketmq.v2.model.*;


public class CreateRocketMqMigrationTaskSolution {

    public static void main(String[] args) {
        // The AK and SK used for authentication are hard-coded or stored in plaintext, which has great security risks. It is recommended that the AK and SK be stored in ciphertext in configuration files or environment variables and decrypted during use to ensure security.
        // In this example, AK and SK are stored in environment variables for authentication. Before running this example, set environment variables CLOUD_SDK_AK and CLOUD_SDK_SK in the local environment
        String ak = System.getenv("CLOUD_SDK_AK");
        String sk = System.getenv("CLOUD_SDK_SK");
        String projectId = "{project_id}";

        ICredential auth = new BasicCredentials()
                .withProjectId(projectId)
                .withAk(ak)
                .withSk(sk);

        RocketMQClient client = RocketMQClient.newBuilder()
                .withCredential(auth)
                .withRegion(RocketMQRegion.valueOf("<YOUR REGION>"))
                .build();
        CreateRocketMqMigrationTaskRequest request = new CreateRocketMqMigrationTaskRequest();
        request.withInstanceId("{instance_id}");
        body.withCreateRocketMqMigrationTaskReq("{\"subscription_group_table\":{\"group-test1\":{\"consume_enable\":true,\"consume_from_min_enable\":true,\"group_name\":\"group-test1\",\"which_broker_when_consume_slow\":1,\"consume_broadcast_enable\":true,\"notify_consumer_ids_changed_enable\":true,\"retry_queue_nums\":1,\"retry_max_times\":2}},\"topic_config_table\":{\"topic-test1\":{\"read_queue_nums\":3,\"write_queue_nums\":3,\"perm\":6,\"topic_name\":\"topic-test1\",\"topic_filter_type\":\"SINGLE_TAG\",\"order\":false,\"topic_sys_flag\":0}}}");
        request.withBody(listCreateRocketMqMigrationTaskReqCreateRocketMqMigrationTaskReq);
        try {
            CreateRocketMqMigrationTaskResponse response = client.createRocketMqMigrationTask(request);
            System.out.println(response.toString());
        } catch (ConnectionException e) {
            e.printStackTrace();
        } catch (RequestTimeoutException e) {
            e.printStackTrace();
        } catch (ServiceResponseException e) {
            e.printStackTrace();
            System.out.println(e.getHttpStatusCode());
            System.out.println(e.getRequestId());
            System.out.println(e.getErrorCode());
            System.out.println(e.getErrorMsg());
        }
    }
}

            

          

        
       

Creating a metadata migration task to migrate the metadata of RabbitMQ instances to DMS for RocketMQ.

        
         
           
           
             package com.huaweicloud.sdk.test;

import com.huaweicloud.sdk.core.auth.ICredential;
import com.huaweicloud.sdk.core.auth.BasicCredentials;
import com.huaweicloud.sdk.core.exception.ConnectionException;
import com.huaweicloud.sdk.core.exception.RequestTimeoutException;
import com.huaweicloud.sdk.core.exception.ServiceResponseException;
import com.huaweicloud.sdk.rocketmq.v2.region.RocketMQRegion;
import com.huaweicloud.sdk.rocketmq.v2.*;
import com.huaweicloud.sdk.rocketmq.v2.model.*;

import java.util.List;
import java.util.ArrayList;

public class CreateRocketMqMigrationTaskSolution {

    public static void main(String[] args) {
        // The AK and SK used for authentication are hard-coded or stored in plaintext, which has great security risks. It is recommended that the AK and SK be stored in ciphertext in configuration files or environment variables and decrypted during use to ensure security.
        // In this example, AK and SK are stored in environment variables for authentication. Before running this example, set environment variables CLOUD_SDK_AK and CLOUD_SDK_SK in the local environment
        String ak = System.getenv("CLOUD_SDK_AK");
        String sk = System.getenv("CLOUD_SDK_SK");
        String projectId = "{project_id}";

        ICredential auth = new BasicCredentials()
                .withProjectId(projectId)
                .withAk(ak)
                .withSk(sk);

        RocketMQClient client = RocketMQClient.newBuilder()
                .withCredential(auth)
                .withRegion(RocketMQRegion.valueOf("<YOUR REGION>"))
                .build();
        CreateRocketMqMigrationTaskRequest request = new CreateRocketMqMigrationTaskRequest();
        request.withInstanceId("{instance_id}");
        CreateRocketMqMigrationTaskReq body = new CreateRocketMqMigrationTaskReq();
        List<MigrationRabbitBindingMetadata> listbodyBindings = new ArrayList<>();
        listbodyBindings.add(
            new MigrationRabbitBindingMetadata()
                .withVhost("/")
                .withSource("direct")
                .withDestination("test-001")
                .withDestinationType("queue")
                .withRoutingKey("test-001")
        );
        List<MigrationRabbitExchangeMetadata> listbodyExchanges = new ArrayList<>();
        listbodyExchanges.add(
            new MigrationRabbitExchangeMetadata()
                .withVhost("/")
                .withName("direct")
                .withType("topic")
                .withDurable(false)
        );
        List<MigrationRabbitQueueMetadata> listbodyQueues = new ArrayList<>();
        listbodyQueues.add(
            new MigrationRabbitQueueMetadata()
                .withVhost("/")
                .withName("test-001")
                .withDurable(false)
        );
        List<MigrationRabbitVhostMetadata> listbodyVhosts = new ArrayList<>();
        listbodyVhosts.add(
            new MigrationRabbitVhostMetadata()
                .withName("DeleteVhost123")
        );
        body.withBindings(listbodyBindings);
        body.withExchanges(listbodyExchanges);
        body.withQueues(listbodyQueues);
        body.withVhosts(listbodyVhosts);
        request.withBody(body);
        try {
            CreateRocketMqMigrationTaskResponse response = client.createRocketMqMigrationTask(request);
            System.out.println(response.toString());
        } catch (ConnectionException e) {
            e.printStackTrace();
        } catch (RequestTimeoutException e) {
            e.printStackTrace();
        } catch (ServiceResponseException e) {
            e.printStackTrace();
            System.out.println(e.getHttpStatusCode());
            System.out.println(e.getRequestId());
            System.out.println(e.getErrorCode());
            System.out.println(e.getErrorMsg());
        }
    }
}

            

          

        
       

Creating a metadata migration task to migrate the metadata from other vendors' or self-built RocketMQ instances to DMS for RocketMQ.

        
         
           
           
             # coding: utf-8

import os
from huaweicloudsdkcore.auth.credentials import BasicCredentials
from huaweicloudsdkrocketmq.v2.region.rocketmq_region import RocketMQRegion
from huaweicloudsdkcore.exceptions import exceptions
from huaweicloudsdkrocketmq.v2 import *

if __name__ == "__main__":
    # The AK and SK used for authentication are hard-coded or stored in plaintext, which has great security risks. It is recommended that the AK and SK be stored in ciphertext in configuration files or environment variables and decrypted during use to ensure security.
    # In this example, AK and SK are stored in environment variables for authentication. Before running this example, set environment variables CLOUD_SDK_AK and CLOUD_SDK_SK in the local environment
    ak = os.environ["CLOUD_SDK_AK"]
    sk = os.environ["CLOUD_SDK_SK"]
    projectId = "{project_id}"

    credentials = BasicCredentials(ak, sk, projectId)

    client = RocketMQClient.new_builder() \
        .with_credentials(credentials) \
        .with_region(RocketMQRegion.value_of("<YOUR REGION>")) \
        .build()

    try:
        request = CreateRocketMqMigrationTaskRequest()
        request.instance_id = "{instance_id}"
        request.body = listCreateRocketMqMigrationTaskReqCreateRocketMqMigrationTaskReq
        response = client.create_rocket_mq_migration_task(request)
        print(response)
    except exceptions.ClientRequestException as e:
        print(e.status_code)
        print(e.request_id)
        print(e.error_code)
        print(e.error_msg)

            

          

        
       

Creating a metadata migration task to migrate the metadata of RabbitMQ instances to DMS for RocketMQ.

        
         
           
           
             # coding: utf-8

import os
from huaweicloudsdkcore.auth.credentials import BasicCredentials
from huaweicloudsdkrocketmq.v2.region.rocketmq_region import RocketMQRegion
from huaweicloudsdkcore.exceptions import exceptions
from huaweicloudsdkrocketmq.v2 import *

if __name__ == "__main__":
    # The AK and SK used for authentication are hard-coded or stored in plaintext, which has great security risks. It is recommended that the AK and SK be stored in ciphertext in configuration files or environment variables and decrypted during use to ensure security.
    # In this example, AK and SK are stored in environment variables for authentication. Before running this example, set environment variables CLOUD_SDK_AK and CLOUD_SDK_SK in the local environment
    ak = os.environ["CLOUD_SDK_AK"]
    sk = os.environ["CLOUD_SDK_SK"]
    projectId = "{project_id}"

    credentials = BasicCredentials(ak, sk, projectId)

    client = RocketMQClient.new_builder() \
        .with_credentials(credentials) \
        .with_region(RocketMQRegion.value_of("<YOUR REGION>")) \
        .build()

    try:
        request = CreateRocketMqMigrationTaskRequest()
        request.instance_id = "{instance_id}"
        listBindingsbody = [
            MigrationRabbitBindingMetadata(
                vhost="/",
                source="direct",
                destination="test-001",
                destination_type="queue",
                routing_key="test-001"
            )
        ]
        listExchangesbody = [
            MigrationRabbitExchangeMetadata(
                vhost="/",
                name="direct",
                type="topic",
                durable=False
            )
        ]
        listQueuesbody = [
            MigrationRabbitQueueMetadata(
                vhost="/",
                name="test-001",
                durable=False
            )
        ]
        listVhostsbody = [
            MigrationRabbitVhostMetadata(
                name="DeleteVhost123"
            )
        ]
        request.body = CreateRocketMqMigrationTaskReq(
            bindings=listBindingsbody,
            exchanges=listExchangesbody,
            queues=listQueuesbody,
            vhosts=listVhostsbody
        )
        response = client.create_rocket_mq_migration_task(request)
        print(response)
    except exceptions.ClientRequestException as e:
        print(e.status_code)
        print(e.request_id)
        print(e.error_code)
        print(e.error_msg)

            

          

        
       

Creating a metadata migration task to migrate the metadata from other vendors' or self-built RocketMQ instances to DMS for RocketMQ.

        
         
           
           
             package main

import (
	"fmt"
	"github.com/huaweicloud/huaweicloud-sdk-go-v3/core/auth/basic"
    rocketmq "github.com/huaweicloud/huaweicloud-sdk-go-v3/services/rocketmq/v2"
	"github.com/huaweicloud/huaweicloud-sdk-go-v3/services/rocketmq/v2/model"
    region "github.com/huaweicloud/huaweicloud-sdk-go-v3/services/rocketmq/v2/region"
)

func main() {
    // The AK and SK used for authentication are hard-coded or stored in plaintext, which has great security risks. It is recommended that the AK and SK be stored in ciphertext in configuration files or environment variables and decrypted during use to ensure security.
    // In this example, AK and SK are stored in environment variables for authentication. Before running this example, set environment variables CLOUD_SDK_AK and CLOUD_SDK_SK in the local environment
    ak := os.Getenv("CLOUD_SDK_AK")
    sk := os.Getenv("CLOUD_SDK_SK")
    projectId := "{project_id}"

    auth := basic.NewCredentialsBuilder().
        WithAk(ak).
        WithSk(sk).
        WithProjectId(projectId).
        Build()

    client := rocketmq.NewRocketMQClient(
        rocketmq.RocketMQClientBuilder().
            WithRegion(region.ValueOf("<YOUR REGION>")).
            WithCredential(auth).
            Build())

    request := &model.CreateRocketMqMigrationTaskRequest{}
	request.InstanceId = "{instance_id}"
	var createRocketMqMigrationTaskReqCreateRocketMqMigrationTaskReq interface{} = "{\"subscription_group_table\":{\"group-test1\":{\"consume_enable\":true,\"consume_from_min_enable\":true,\"group_name\":\"group-test1\",\"which_broker_when_consume_slow\":1,\"consume_broadcast_enable\":true,\"notify_consumer_ids_changed_enable\":true,\"retry_queue_nums\":1,\"retry_max_times\":2}},\"topic_config_table\":{\"topic-test1\":{\"read_queue_nums\":3,\"write_queue_nums\":3,\"perm\":6,\"topic_name\":\"topic-test1\",\"topic_filter_type\":\"SINGLE_TAG\",\"order\":false,\"topic_sys_flag\":0}}}"
	request.Body = listCreateRocketMqMigrationTaskReqCreateRocketMqMigrationTaskReq
	response, err := client.CreateRocketMqMigrationTask(request)
	if err == nil {
        fmt.Printf("%+v\n", response)
    } else {
        fmt.Println(err)
    }
}

            

          

        
       

Creating a metadata migration task to migrate the metadata of RabbitMQ instances to DMS for RocketMQ.

        
         
           
           
             package main

import (
	"fmt"
	"github.com/huaweicloud/huaweicloud-sdk-go-v3/core/auth/basic"
    rocketmq "github.com/huaweicloud/huaweicloud-sdk-go-v3/services/rocketmq/v2"
	"github.com/huaweicloud/huaweicloud-sdk-go-v3/services/rocketmq/v2/model"
    region "github.com/huaweicloud/huaweicloud-sdk-go-v3/services/rocketmq/v2/region"
)

func main() {
    // The AK and SK used for authentication are hard-coded or stored in plaintext, which has great security risks. It is recommended that the AK and SK be stored in ciphertext in configuration files or environment variables and decrypted during use to ensure security.
    // In this example, AK and SK are stored in environment variables for authentication. Before running this example, set environment variables CLOUD_SDK_AK and CLOUD_SDK_SK in the local environment
    ak := os.Getenv("CLOUD_SDK_AK")
    sk := os.Getenv("CLOUD_SDK_SK")
    projectId := "{project_id}"

    auth := basic.NewCredentialsBuilder().
        WithAk(ak).
        WithSk(sk).
        WithProjectId(projectId).
        Build()

    client := rocketmq.NewRocketMQClient(
        rocketmq.RocketMQClientBuilder().
            WithRegion(region.ValueOf("<YOUR REGION>")).
            WithCredential(auth).
            Build())

    request := &model.CreateRocketMqMigrationTaskRequest{}
	request.InstanceId = "{instance_id}"
	vhostBindings:= "/"
	sourceBindings:= "direct"
	destinationBindings:= "test-001"
	destinationTypeBindings:= "queue"
	routingKeyBindings:= "test-001"
	var listBindingsbody = []model.MigrationRabbitBindingMetadata{
        {
            Vhost: &vhostBindings,
            Source: &sourceBindings,
            Destination: &destinationBindings,
            DestinationType: &destinationTypeBindings,
            RoutingKey: &routingKeyBindings,
        },
    }
	vhostExchanges:= "/"
	nameExchanges:= "direct"
	typeExchanges:= "topic"
	durableExchanges:= false
	var listExchangesbody = []model.MigrationRabbitExchangeMetadata{
        {
            Vhost: &vhostExchanges,
            Name: &nameExchanges,
            Type: &typeExchanges,
            Durable: &durableExchanges,
        },
    }
	vhostQueues:= "/"
	nameQueues:= "test-001"
	durableQueues:= false
	var listQueuesbody = []model.MigrationRabbitQueueMetadata{
        {
            Vhost: &vhostQueues,
            Name: &nameQueues,
            Durable: &durableQueues,
        },
    }
	nameVhosts:= "DeleteVhost123"
	var listVhostsbody = []model.MigrationRabbitVhostMetadata{
        {
            Name: &nameVhosts,
        },
    }
	request.Body = &model.CreateRocketMqMigrationTaskReq{
		Bindings: &listBindingsbody,
		Exchanges: &listExchangesbody,
		Queues: &listQueuesbody,
		Vhosts: &listVhostsbody,
	}
	response, err := client.CreateRocketMqMigrationTask(request)
	if err == nil {
        fmt.Printf("%+v\n", response)
    } else {
        fmt.Println(err)
    }
}

            

          

        
       