数据湖探索 DLI-创建并提交SQL作业:操作步骤

时间:2025-02-12 14:55:48

操作步骤

  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": ""}
support.huaweicloud.com/api-dli/dli_02_0308.html