数据湖探索 DLI-创建并提交SQL作业:操作步骤
操作步骤
- 创建弹性资源池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": ""}
- 接口相关信息
- 在弹性资源池中添加队列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": ""}
- 接口相关信息
- 提交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": ""}
- 接口相关信息