更新时间:2025-08-06 GMT+08:00
分享

查询所有作业

功能介绍

该API用于查询当前project下的所有作业的信息。

调试

您可以在API Explorer中调试该接口。

URI

  • URI格式:

    GET /v1.0/{project_id}/jobs

  • 参数说明
    表1 URI 参数

    参数名称

    是否必选

    参数类型

    说明

    project_id

    String

    参数解释:

    项目编号,用于资源隔离。获取方式请参考获取项目ID

    示例: 48cc2c48765f481480c7db940d6409d1

    约束限制:

    取值范围:

    只能由英文字母和数字组成,且长度为[1-64]个字符。

    默认取值:

    表2 query参数

    参数名称

    是否必选

    参数类型

    说明

    page-size

    Integer

    参数解释:

    每页显示的最大作业个数  示例: 5

    约束限制:

    取值范围:

    [1, 100]

    默认取值:

    50

    current-page

    Integer

    参数解释:

    当前页码,默认为第一页。

    约束限制:

    取值范围:

    [1, 100]

    默认取值:

    1

    start

    Long

    参数解释:

    用于查询开始时间在该时间点之后的作业。

    约束限制:

    时间格式为unix时间戳,单位:毫秒。

    取值范围:

    默认取值:

    end

    Long

    参数解释:

    用于查询开始时间在该时间点之前的作业。

    约束限制:

    时间格式为unix时间戳,单位:毫秒。

    取值范围:

    默认取值:

    job-type

    String

    参数解释:

    指定查询的作业类型。包含DDL、DCL、IMPORT、EXPORT、QUERY、INSERT、DATA_MIGRATION、UPDATE、DELETE、RESTART_QUEUE、SCALE_QUEUE,若要查询所有类型的作业,则传入ALL。

    job-type适用于单个类型查询,但是支持传入ALL。

    与job_types共存的场景按两者参数的交集取值。

    约束限制:

    取值范围:

    • DDL:数据定义类型的任务(如 CREATE、ALTER、DROP)
    • DCL:数据控制类型的任务(如 GRANT、REVOKE 等权限操作)
    • IMPORT:数据导入任务(从外部源加载数据)
    • EXPORT:数据导出任务(将数据输出到外部系统)
    • QUERY:查询任务(如 SELECT 语句)
    • INSERT:数据插入任务(如 INSERT 语句)
    • DATA_MIGRATION:数据迁移任务(跨库/跨集群数据迁移)
    • UPDATE:数据更新任务(如 UPDATE 语句)
    • DELETE:数据删除任务(如 DELETE 语句)
    • RESTART_QUEUE:重启队列任务(恢复暂停或失败的任务队列)
    • SCALE_QUEUE:队列扩缩容任务(动态调整队列资源)

    默认取值:

    job_types

    Array[string]

    参数解释:

    指定查询的任务类型列表,可选值包括DDL、DCL、IMPORT、EXPORT、QUERY、INSERT、UPDATE、DELETE。

    job_types适用于多个类型查询。与job-type共存的场景按两者参数的交集取值。

    约束限制:

    取值范围:

    • DDL:数据定义类型的任务(如 CREATE、ALTER、DROP 等操作)
    • DCL:数据控制类型的任务(如 GRANT、REVOKE 等权限操作)
    • IMPORT:数据导入任务(如从文件或外部源导入数据)
    • EXPORT:数据导出任务(如将数据导出到文件或外部系统)
    • QUERY:查询任务(如 SELECT 语句)
    • INSERT:数据插入任务(如 INSERT 语句)
    • UPDATE:数据更新任务(如 UPDATE 语句)
    • DELETE:数据删除任务(如 DELETE 语句)

    默认取值:

    job-status

    String

    参数解释:

    指定查询的作业状态。

    约束限制:

    取值范围:

    • RUNNING:运行中
    • SCALING:规格变更中
    • LAUNCHING:提交中
    • FINISHED:已完成
    • FAILED:已失败
    • CANCELLED:已取消

    默认取值:

    job-id

    String

    参数解释:

    指定查询的作业ID。可通过提交SQL作业(推荐)获取。

    约束限制:

    取值范围:

    只能由英文字母和数字组成,且长度为[1-64]个字符。

    默认取值:

    queue_name

    String

    参数解释:

    指定queue_name作为作业过滤条件,查询在指定queue上运行的作业。

    约束限制:

    取值范围:

    默认取值:

    sql_pattern

    String

    参数解释:

    指定sql片段作为作业过滤条件,不区分大小写。

    约束限制:

    取值范围:

    默认取值:

    order

    String

    参数解释:

    指定作业排序方式。

    约束限制:

    取值范围:

    • duration_desc:作业运行时长降序
    • duration_asc:作业运行时长升序
    • start_time_desc:作业提交时间降序
    • start_time_asc:作业提交时间升序

    默认取值:

    默认为start_time_desc:作业提交时间降序

    engine_type

    String

    参数解释:

    引擎类型。

    支持配置spark引擎或hetuEngine引擎。

    约束限制:

    取值范围:

    • spark:spark引擎
    • hetuEngine:hetuEngine引擎

    了解引擎的详细类型和说明请参考DLI简介

    默认取值:

    owner

    String

    参数解释:

    提交作业的用户。

    约束限制:

    取值范围:

    默认取值:

    tags

    String

    指定作业标签作为过滤条件,支持多标签过滤,格式为“key=value”。

    参数解释:

    指定作业标签作为过滤条件,支持多标签过滤,格式为“key=value”。

    约束限制:

    当前只支持所有tags值整体的模糊查询,不支持精确查询。

    取值范围:

    • 单标签场景:

    例如,GET /v1.0/{project_id}/jobs?tags=k1%3Dv1

    其中,“=”需要转义为“%3D”,“k1”为标签键,“v1”为标签值。

    • 多标签场景:

    如果涉及到多个标签的场景,则多个标签之间需要通过“,”号分隔,“,”号需要转义为“%2C”,例如:GET /v1.0/{project_id}/jobs?tags=k1%3Dv1%2Ck2%3Dv2

    其中,“=”需要转义为“%3D”,“k1”为标签键1,“v1”为标签值1,“k2”为标签键2,“v2”为标签值2。

    默认取值:

    带入query参数的URL示例如下:

    GET /v1.0/{project_id}/jobs?page-size={size}&current-page={page_number}&start={start_time}&end={end_time}&job-type={QUERY}&queue_name={test}&order={duration_desc}

请求消息

无请求参数。

响应消息

表3 响应参数

参数名称

是否必选

参数类型

说明

is_success

Boolean

执行请求是否成功。“true”表示请求执行成功。

message

String

系统提示信息,执行成功时,信息可能为空。

job_count

Integer

作业总个数。

jobs

Array of Objects

作业信息。具体参数请参见表4

表4 jobs参数

参数名称

是否必选

参数类型

说明

job_id

String

参数解释:

作业ID。可通过提交SQL作业(推荐)获取。

job_type

String

参数解释:

查询的作业类型。

取值范围:

  • DDL:数据定义类型的任务(如 CREATE、ALTER、DROP)
  • DCL:数据控制类型的任务(如 GRANT、REVOKE 等权限操作)
  • IMPORT:数据导入任务(从外部源加载数据)
  • EXPORT:数据导出任务(将数据输出到外部系统)
  • QUERY:查询任务(如 SELECT 语句)
  • INSERT:数据插入任务(如 INSERT 语句)
  • DATA_MIGRATION:数据迁移任务(跨库/跨集群数据迁移)
  • UPDATE:数据更新任务(如 UPDATE 语句)
  • DELETE:数据删除任务(如 DELETE 语句)
  • RESTART_QUEUE:重启队列任务(恢复暂停或失败的任务队列)
  • SCALE_QUEUE:队列扩缩容任务(动态调整队列资源)
  • ALL:代表查询所有类型。

queue_name

String

参数解释:

作业提交的队列。

取值范围:

owner

String

参数解释:

提交作业的用户。

取值范围:

start_time

Long

参数解释:

作业开始的时间。是单位为“毫秒”的时间戳。

取值范围:

duration

Long

参数解释:

作业运行时长,单位毫秒。

取值范围:

status

String

参数解释:

此作业的当前状态。

取值范围:

  • RUNNING:运行中
  • SCALING:规格变更中
  • LAUNCHING:提交中
  • FINISHED:已完成
  • FAILED:已失败
  • CANCELLED:已取消

input_row_count

Long

参数解释:

Insert作业执行过程中扫描的记录条数。

取值范围:

bad_row_count

Long

参数解释:

Insert作业执行过程中扫描到的错误记录数。

取值范围:

input_size

Long

参数解释:

作业执行过程中扫描文件的大小。

取值范围:

result_count

Integer

参数解释:

当前作业返回的结果总条数或insert作业插入的总条数。

取值范围:

database_name

String

参数解释:

记录其操作的表所在的数据库名称。类型为Import和Export作业才有“database_name”属性。

取值范围:

table_name

String

参数解释:

记录其操作的表名称。类型为Import和Export作业才有“table_name”属性。

取值范围:

with_column_header

Boolean

参数解释:

Import类型的作业,记录其导入的数据是否包括列名。

取值范围:

detail

String

参数解释:

SQL查询的相关列信息的Json字符串。

取值范围:

engine_type

String

参数解释:

引擎类型。

显示队列配置的spark引擎或hetuEngine引擎。

取值范围:

  • spark:spark引擎
  • hetuEngine:hetuEngine引擎

了解引擎的详细类型和说明请参考DLI简介

statement

String

参数解释:

作业执行的SQL语句。

取值范围:

message

String

参数解释:

系统提示信息。

取值范围:

end_time

Long

参数解释:

作业结束的时间。是单位为“毫秒”的时间戳。

取值范围:

tags

Array of Objects

参数解释:

作业标签。具体请参考表5

取值范围:

output_byte

String

参数解释:

作业的输出字节数。

取值范围:

cpu_cost

String

参数解释:

作业的CPU累计使用量。

取值范围:

result_format

String

参数解释:

作业结果的存储格式,当前只支持csv。

取值范围:

result_path

String

参数解释:

作业结果的OBS路径。

取值范围:

execution_details_path

String

参数解释:

作业执行计划的存储路径。

例如:obs://bucketName/jobs/execution_details/xxx/2023/11/10/xxx

取值范围:

表5 tags参数

参数名称

是否必选

参数类型

说明

key

String

参数解释:

标签的键。

取值范围:

value

String

参数解释:

标签的值。

取值范围:

请求示例

响应示例

{
 "is_success": true,
  "message": "",
  "job_count": 1,
  "jobs": [
    {

      "detail": "{\"type\":\"struct\",\"fields\":[{\"name\":\"name\",\"type\":\"string\",\"nullable\":true,\"metadata\":{}},{\"name\":\"age\",\"type\":\"integer\",\"nullable\":true,\"metadata\":{}}]}",
      "duration": 17731,

      "end_time": 1502349821460,
      "input_size": 0,
      "job_id": "37286cc7-0508-4ffd-b636-951c8a5c75de",
      "job_type": "QUERY",
      "message": "",
      "owner": "tenant1",
      "queue_name": "queue1",
      "result_count": 3,
      "start_time": 1502349803729,
      "statement": "select * from t_json_002",
      "status": "FINISHED",
      "with_column_header": false
    }
  ]
}

状态码

状态码如表6所示。

表6 状态码

状态码

描述

200

查询成功。

400

请求错误。

500

内部服务器错误。

错误码

调用接口出错后,将不会返回上述结果,而是返回错误码和错误信息,更多介绍请参见错误码

相关文档