创建并使用跨源链接

场景描述

本章节指导用户通过API创建增强型跨源连接。

约束限制

• 新队列第一次运行作业时，需要一定的时间，通常为6~10分钟。
• 创建增强型跨源连接之前需要获取需要建立连接的服务对应VPC的ID和其所在子网的网络ID。

涉及接口

• 创建弹性资源池：创建弹性资源池。
• 创建队列：在弹性资源池中添加队列。
• 创建增强型跨源连接：创建增强型跨源连接。
• 绑定队列：绑定队列。
• 查询增强型跨源连接：确认增强型跨源连接创建成功。

操作步骤

1. 创建弹性资源池elastic_pool_dli
   • 接口相关信息

     URI格式：POST /v3/{project_id}/elastic-resource-pools

     • {project_id}信息请从获取项目ID获取。
     • 请求参数说明详情，请参见创建弹性资源池。
   • 请求示例
     • 描述：在项目ID为48cc2c48765f481480c7db940d6409d1的项目下创建一个名称为elastic_pool_dli的弹性资源池。
     • 示例URL：POST https://{endpoint}/v3/48cc2c48765f481480c7db940d6409d1/elastic-resource-pools
     • Body：

       {
         "elastic_resource_pool_name" : "elastic_pool_dli",
         "description" : "test",
         "cidr_in_vpc" : "172.16.0.0/14",
         "charging_mode" : "1",
         "max_cu" : 64,
         "min_cu" : 64
       }

   • 响应示例

     {
       "is_success": true,
       "message": ""
     }

2. 在弹性资源池中添加队列queue1
   • 接口相关信息

     URI格式：POST /v1.0/{project_id}/queues

     • {project_id}信息请从获取项目ID获取。
     • 请求参数说明详情，请参见创建队列。
   • 请求示例
     • 描述：在项目ID为48cc2c48765f481480c7db940d6409d1的项目下创建一个名称为queue1的弹性资源池。
     • 示例URL：POST https://{endpoint}/v1.0/48cc2c48765f481480c7db940d6409d1/queues
     • Body：

       {
           "queue_name": "queue1",
           "queue_type": "sql",
           "description": "test",
           "cu_count": 16,
           "enterprise_project_id": "elastic_pool_dli"
       }

   • 响应示例

     {
       "is_success": true,
       "message": ""
     }

3. 创建增强型跨源连接。
   • 接口相关信息

     URI格式：POST /v2.0/{project_id}/datasource/enhanced-connections

     • {project_id}信息请从获取项目ID获取。
     • 请求参数说明详情，请参见创建增强型跨源连接。
   • 请求示例
     • 描述：在项目ID为48cc2c48765f481480c7db940d6409d1下创建名称为test1的增强型跨源连接。
     • 示例URL：POST https://{endpoint}/v2.0/48cc2c48765f481480c7db940d6409d1/datasource/enhanced-connections
     • Body：

       {
         "name": "test1",
         "dest_vpc_id": "22094d8f-c310-4621-913d-4c4d655d8495",
         "dest_network_id": "78f2562a-36e4-4b39-95b9-f5aab22e1281",
         "elastic_resource_pools": "elastic_pool_dli",
         "hosts": [
           {
             "ip":"192.168.0.1",
             "name":"ecs-97f8-0001"
           },
           {
             "ip":"192.168.0.2", 
             "name":"ecs-97f8-0002"
           }
         ]
       }

   • 响应示例

     {
       "is_success": true,
       "message": "",
       "connection_id": "2a620c33-5609-40c9-affd-2b6453071b0f"
     }

4. （可选）如果创建增强型跨源连接时，没有绑定队列，可使用绑定队列接口进行绑定。
5. 确认增强型跨源连接创建成功。
   • 接口相关信息

     URI格式：GET /v2.0/{project_id}/datasource/enhanced-connections/{connection_id}

     • {project_id}信息请从获取项目ID获取。
     • 查询参数说明详情，请参见创建数据库（废弃）。
   • 请求示例
     • 描述：查询项目ID为48cc2c48765f481480c7db940d6409d1下连接ID为2a620c33-5609-40c9-affd-2b6453071b0f的增强型跨源连接。
     • 示例URL：GET https://{endpoint}/v2.0/48cc2c48765f481480c7db940d6409d1/datasource/enhanced-connections/2a620c33-5609-40c9-affd-2b6453071b0f
     • Body：

       {}

   • 响应示例

     {
       "is_success": true,
       "message": "",
       "name": "test1",
       "id": "2a620c33-5609-40c9-affd-2b6453071b0f",
       "elastic_resource_pools": [
         {
           "status": "ACTIVE",
           "name": "elastic_pool_dli",
           "peer_id": "2a620c33-5609-40c9-affd-2b6453071b0f",
           "err_msg": "",
           "update_time": 1566889577861
         }
       ],
       "dest_vpc_id": "22094d8f-c310-4621-913d-4c4d655d8495",
       "dest_network_id": "78f2562a-36e4-4b39-95b9-f5aab22e1281",
       "isPrivis": true,
       "create_time": 1566888011125,
       "status": "ACTIVE",
       "hosts": [
         {
           "ip":"192.168.0.1",
           "name":"ecs-97f8-0001"
         },
         {
           "ip":"192.168.0.2", 
           "name":"ecs-97f8-0002"
         }
       ]
     }