查询实时作业运行状态 - ShowJobStatus
功能介绍
查询指定实时作业的运行状态。
授权信息
账号具备所有API的调用权限,如果使用账号下的IAM用户调用当前API,该IAM用户需具备调用API所需的权限。
- 如果使用角色与策略授权,具体权限要求请参见权限和授权项。
- 如果使用身份策略授权,当前API调用无需身份策略权限。
URI
- 参数说明
表1 URI参数说明 参数名
是否必选
参数类型
说明
project_id
是
String
项目编号,获取方法请参见项目ID和账号ID。
job_name
是
String
作业名称。
请求参数
|
参数名 |
是否必选 |
参数类型 |
说明 |
|---|---|---|---|
|
workspace |
否 |
String |
工作空间id。
|
响应参数
|
参数名 |
是否必选 |
参数类型 |
说明 |
|---|---|---|---|
|
name |
是 |
String |
解决方案名称。 |
|
nodes |
否 |
列表数据结构 |
节点状态列表。 |
|
status |
否 |
String |
作业状态:
|
|
startTime |
是 |
Date |
启动时间。 |
|
endTime |
否 |
Date |
停止时间。 |
|
lastUpdateTime |
否 |
Date |
状态最后更新时间。 |
|
createUser |
否 |
String |
创建人。 |
|
lastModifiyUser |
否 |
String |
最后修改人。 |
|
参数名 |
是否必选 |
参数类型 |
说明 |
|---|---|---|---|
|
name |
是 |
String |
节点名称。 |
|
status |
否 |
String |
节点状态:
|
|
logPath |
否 |
String |
节点运行日志路径 |
|
type |
是 |
String |
节点类型:
|
|
lastInstanceStatus |
是 |
String |
上一次实例的执行状态。 |
|
speed |
否 |
double |
写入速率。 |
|
runningData |
否 |
String |
节点运行时内部存放的部分数据。 |
|
totalPutBytes |
否 |
long |
写入(输出)的总字节数。 |
|
bufferRecords |
否 |
long |
缓冲区中的记录数。 |
|
jobInstanceId |
是 |
long |
节点实例Id。 |
|
extendCounter |
否 |
String |
扩展计数器。 |
|
totalGetBytes |
否 |
long |
读取(输入)的总字节数 。 |
|
totalPutRecords |
否 |
long |
写入的总记录数。 |
|
totalGetRecords |
否 |
long |
读取的总记录数。 |
请求示例
GET /v1/b384b9e9ab9b4ee8994c8633aabc9505/jobs/job_sms/status
响应示例
- 成功响应
{ "name": "job_sms", "nodes": [ { "bufferRecords": 0, "jobInstanceId": 0, "LastInstanceStatus": "waiting", "name": "MRS_Flink_Job_8635", "speed": 0, "totalGetBytes": 0, "totalGetRecords": 0, "totalPutBytes": 0, "totalPutRecords": 0 } ], "status": "NORMAL" } - 失败响应
{ "error_code":"DLF.30100", "error_msg":"The job does not exists." }