查询批处理作业列表
功能介绍
该API用于查询Project下某队列批处理作业的列表。
URI
- URI格式:
- 参数说明
表1 URI参数 参数名称
是否必选
参数类型
说明
project_id
是
String
项目编号,用于资源隔离。获取方式请参考获取项目ID。
表2 query参数说明 参数名称
是否必选
参数类型
说明
job_name
否
String
批处理作业的名称。
job_id
否
String
根据作业ID查询批作业。
cluster_name
否
String
DLI队列名称,不填写则获取当前Project下所有批处理作业(不推荐使用)。
queue_name
否
String
DLI队列名称,根据队列查询批作业(推荐使用)。
from
否
Integer
起始批处理作业的索引号,默认从0开始。
size
否
Integer
查询批处理作业的数量。
state
否
String
根据作业状态查询批作业。
owner
否
String
提交作业的用户。
请求消息
无请求参数。
响应消息
|
参数名称 |
是否必选 |
参数类型 |
说明 |
|---|---|---|---|
|
from |
否 |
Integer |
起始批处理作业的索引号。 |
|
total |
否 |
Integer |
返回批处理作业的总数。 |
|
sessions |
否 |
Array of objects |
|
|
create_time |
否 |
Long |
批处理作业的创建时间。 |
|
参数名称 |
是否必选 |
参数类型 |
说明 |
|---|---|---|---|
|
duration |
否 |
Long |
作业运行时长,单位毫秒。 |
|
id |
否 |
String |
批处理作业的id。 |
|
state |
否 |
String |
批处理作业的状态。 |
|
appId |
否 |
Array of strings |
批处理作业的后台app id。 |
|
log |
否 |
Array of Strings |
显示当前批处理作业的最后10条记录。 |
|
sc_type |
否 |
String |
计算资源类型。用户自定义时返回CUSTOMIZED。 |
|
cluster_name |
否 |
String |
批处理作业所在队列。 |
|
create_time |
否 |
Long |
批处理作业的创建时间。是单位为“毫秒”的时间戳。 |
|
name |
否 |
String |
批处理作业名称。 |
|
owner |
否 |
String |
批处理作业所属用户。 |
|
proxyUser |
否 |
String |
批处理作业所属代理用户(资源租户)。 |
|
kind |
否 |
String |
批处理作业类型,只支持spark类型参数。 |
|
queue |
否 |
String |
批处理作业所在队列。 |
|
image |
否 |
String |
自定义镜像。格式为:组织名/镜像名:镜像版本。 当用户设置“feature”为“custom”时,该参数生效。用户可通过与“feature”参数配合使用,指定作业运行使用自定义的Spark镜像。 |
|
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
}
]
}
错误码
调用接口出错后,将不会返回上述结果,而是返回错误码和错误信息,更多介绍请参见错误码。