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

查询批处理作业列表

功能介绍

该API用于查询Project下某队列批处理作业的列表。

URI

  • URI格式:

    GET /v2.0/{project_id}/batches

  • 参数说明
    表1 URI参数

    参数名称

    是否必选

    参数类型

    说明

    project_id

    String

    参数解释:

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

    示例: 48cc2c48765f481480c7db940d6409d1

    约束限制:

    取值范围:

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

    默认取值:

    表2 query参数说明

    参数名称

    是否必选

    参数类型

    说明

    job_name

    String

    参数解释:

    批处理作业的名称。

    约束限制:

    取值范围:

    默认取值:

    job-id

    String

    参数解释:

    根据作业ID查询批作业。示例: 03923a72-5ace-466a-a573-e8c7b08b8cf3

    约束限制:

    取值范围:

    默认取值:

    cluster_name

    String

    参数解释:

    DLI队列名称,不填写则获取当前Project下所有批处理作业(不推荐使用)。

    约束限制:

    取值范围:

    默认取值:

    queue_name

    String

    参数解释:

    DLI队列名称,根据队列查询批作业(推荐使用)。

    约束限制:

    取值范围:

    默认取值:

    from

    Integer

    参数解释:

    起始批处理作业的索引号,默认从0开始。

    约束限制:

    取值范围:

    默认取值:

    size

    Integer

    参数解释:

    查询批处理作业的数量。

    约束限制:

    取值范围:

    默认取值:

    state

    String

    参数解释:

    根据作业状态查询批作业。

    约束限制:

    取值范围:

    • starting:正在启动
    • running:正在执行任务
    • dead:session已退出
    • success:session停止成功
    • recovering:正在恢复

    默认取值:

    owner

    String

    参数解释:

    提交作业的用户。

    约束限制:

    取值范围:

    默认取值:

请求消息

无请求参数。

响应消息

表3 响应参数说明

参数名称

是否必选

参数类型

说明

from

Integer

参数解释:

起始批处理作业的索引号。

取值范围:

total

Integer

参数解释:

返回批处理作业的总数。

取值范围:

sessions

Array of objects

参数解释:

批处理作业信息。详细说明请参见表4

取值范围:

create_time

Long

参数解释:

批处理作业的创建时间。

取值范围:

表4 sessions参数

参数名称

是否必选

参数类型

说明

duration

Long

参数解释:

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

取值范围:

id

String

参数解释:

批处理作业的ID。

取值范围:

state

String

参数解释:

批处理作业的状态。

取值范围:

  • starting:正在启动
  • running:正在执行任务
  • dead:session已退出
  • success:session停止成功
  • recovering:正在恢复

appId

String

参数解释:

批处理作业的后台app ID。

取值范围:

log

Array of Strings

参数解释:

显示当前批处理作业的最后10条记录。

取值范围:

sc_type

String

参数解释:

计算资源类型。目前可接受参数A, B, C。用户自定义时返回CUSTOMIZED。

取值范围:

  • A:物理资源:8核32G内存,
    • driverCores:2;
    • executorCores:1;
    • driverMemory:7G;
    • executorMemory:4G;
    • numExecutor:6。
  • B:物理资源:16核64G内存
    • driverCores:2;
    • executorCores:2;
    • driverMemory:7G;
    • executorMemory:8G;
    • numExecutor:7。
  • C:物理资源:32核128G内存
    • driverCores:4;
    • executorCores:2;
    • driverMemory:15G;
    • executorMemory:8G;
    • numExecutor:14。

cluster_name

String

参数解释:

批处理作业所在队列。

取值范围:

create_time

Long

参数解释:

批处理作业的创建时间。是单位为“毫秒”的时间戳。

取值范围:

name

String

参数解释:

批处理作业名称。

取值范围:

owner

String

参数解释:

批处理作业所属用户。

取值范围:

proxyUser

String

参数解释:

批处理作业所属代理用户(资源租户)。

取值范围:

kind

String

参数解释:

批处理作业类型,只支持spark类型参数。

取值范围:

queue

String

参数解释:

批处理作业所在队列。

取值范围:

image

String

参数解释:

自定义镜像。格式为:组织名/镜像名:镜像版本。

当用户设置“feature”“custom”时,该参数生效。用户可通过与“feature”参数配合使用,指定作业运行使用自定义的Spark镜像。

取值范围:

req_body

String

参数解释:

请求参数详情。

取值范围:

update_time

Long

参数解释:

批处理作业的更新时间。是单位为“毫秒”的时间戳。

取值范围:

请求示例

响应示例

{
    "from": 0,
    "total": 1,
    "sessions": [
        {
            "id": "178fa687-2e8a-41ed-a439-b00de60bb176",
            "state": "dead",
            "appId": null,
            "log": [
             "stdout: ",
             "stderr: ",
             "YARN Diagnostics: "
           ],
           "sc_type": "A",
           "cluster_name": "test",
           "create_time": 1531906043036
        }
    ]
}

状态码

状态码如表5所示。

表5 状态码

状态码

描述

200

查询成功。

400

请求错误。

500

内部服务器错误。

错误码

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