创建并提交SQL作业

场景描述

本章节指导用户通过API提交SQL作业创建数据库和表，并查询数据。

涉及接口

• 创建弹性资源池
• 创建队列
• 提交SQL作业（推荐）

操作步骤

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

       {endpoint}信息请从地区和终端节点获取。

     • 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

       {endpoint}信息请从地区和终端节点获取。

     • Body：

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

   • 响应示例

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

3. 提交SQL作业：提交SQL作业，创建数据库db1、表tb1、在表中插入数据，并查询数据
   • 接口相关信息

     URI格式：POST /v1.0/{project_id}/jobs/submit-job

     • {project_id}信息请从获取项目ID获取。
     • 请求参数说明详情，请参见提交SQL作业（推荐）。
   • 请求示例
     • 描述：在项目ID为48cc2c48765f481480c7db940d6409d1的项目下，提交SQL作业，创建数据库db1、表tb1、在表中插入数据，并查询数据。
     • 示例URL：POST https://{endpoint}/v1.0/48cc2c48765f481480c7db940d6409d1/jobs/submit-job

       {endpoint}信息请从地区和终端节点获取。

     • 创建数据库db1

       {
       	"queue_name": "queue1",
       	"sql": "create DATABASE db1"
       }

     • 创建表tb1

       {
       	"currentdb": "db1",
       	"queue_name": "queue1",
       	"sql": "create table\n  my_table (id int, name string)"
       }

     • 在表tb1中插入数据

       {
       	"currentdb": "db1",
       	"queue_name": "queue1",
       	"sql": "insert into tb1 (id, name) values (1, 'Ann'), (2, 'Jane')"
       }

     • 查询表数据

       {
       	"currentdb": "db1",
       	"queue_name": "queue1",
       	"sql": "select * from tb1 limit 10",
       }

   • 响应示例

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