更新时间:2022-08-12 GMT+08:00

获取SQL结果

功能介绍

在MRS集群中查询SparkSql和SparkScript两种类型作业的SQL语句运行完成后返回的查询结果。

URI

  • URI格式

    GET /v2/{project_id}/clusters/{cluster_id}/job-executions/{job_execution_id}/sql-result

  • 参数说明
    表1 URI参数说明

    名称

    是否必选

    说明

    project_id

    项目编号。获取方法,请参见获取项目ID

    cluster_id

    集群ID。获取方法,请参见获取集群ID

    job_execution_id

    作业ID。获取方法,请参见获取作业ID

请求消息

请求参数

无。

响应参数

表2 响应参数说明

参数名

参数类型

说明

sql-results

Object

SQL语句查询结果。

示例

  • 请求示例
    {
    	"job_name": "111",
    	"job_type": "SparkSql",
    	"arguments": [
                 "create table src_wordcount (id int,name string);
                  show tables;
                  insert INTO src_wordcount VALUES (1, 'a');
                  insert INTO src_wordcount VALUES (2, 'b');SELECT * FROM src_wordcount;"
                      ],
    	"properties": {}
    }
  • 响应示例
    • 成功示例
      {
      	"sql_results": {
      		"0": [{
      			"result": "succeed"
      		}],
      		"1": [{
      			"database": "default",
      			"isTemporary": "false",
      			"tableName": "src_wordcount"
      		}],
      		"2": [{
      			"result": "succeed"
      		}],
      		"3": [{
      			"result": "succeed"
      		}],
      		"4": [{
      			"name": "a",
      			"id": "1"
      		}, {
      			"name": "b",
      			"id": "2"
      		}]
      	}
      }
    • 失败示例
      {
      "error_msg":"收集SQL作业结果失败",
      "error_code":"0172"
      }

状态码

状态码请参见状态码