更新时间:2023-06-15 GMT+08:00

查询实时作业运行状态

功能介绍

查询指定实时作业的运行状态。

URI

  • URI格式

    GET /v1/{project_id}/jobs/{job_name}/status

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

    参数名

    是否必选

    参数类型

    说明

    project_id

    String

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

    job_name

    String

    作业名称

请求消息

表2 请求Header参数

参数名

是否必选

参数类型

说明

workspace

String

工作空间id。

  • 如果不设置该参数,默认查询default工作空间下的数据。
  • 如果需要查询其他工作空间的数据,需要带上该消息头。

响应消息

表3 参数说明

参数名

是否必选

参数类型

说明

name

String

解决方案名称

nodes

列表数据结构

节点状态列表

status

String

作业状态:

  • STARTING : 启动中
  • NORMAL:正常
  • EXCEPTION :异常
  • STOPPING :停止中
  • STOPPED:停止

startTime

Date

启动时间

endTime

Date

停止时间

lastUpdateTime

Date

状态最后更新时间

表4 nodes字段数据结构说明

参数名

是否必选

参数类型

说明

name

String

节点名称

status

String

节点状态:

  • STARTING :启动中
  • NORMAL:正常
  • EXCEPTION :异常
  • STOPPING : 停止中
  • STOPPED:停止

logPath

String

节点运行日志路径

type

String

节点类型:

  • Hive SQL :执行Hive SQL脚本
  • Spark SQL :执行Spark SQL脚本
  • DWS SQL : 执行DWS SQL脚本
  • Shell:执行Shell SQL脚本
  • CDM Job:执行CDM作业
  • OBSManager: OBS路径管理,包括创建和删除路径
  • RESTAPI : REST API请求
  • SMN : 发送短信或邮件
  • MRS Spark :执行MRS服务的Spark作业
  • MapReduce :执行MRS服务的MapReduce作业

示例

查询实时作业job_sms作业运行状态以及各个节点运行状态。job_sms有7个节点,如下

图1 job_sms
  • 请求
    GET /v1/b384b9e9ab9b4ee8994c8633aabc9505/jobs/job_sms/status
  • 成功响应(作业运行中,其中DLI_SMS_GES运行异常)
    {
    	"lastUpdateTime": 1551409406000,
    	"name": "job_sms",
    	"nodes": [{
    		"name": "CREATE_GES_DIR",
    		"status": "NORMAL",
    		"totalGetBytes": 0,
    		"totalGetRecords": 0,
    		"totalPutBytes": 0,
    		"totalPutRecords": 0,
    		"type": "Create OBS"
    	},
    	{
    		"logPath": "obs://dlf-log-b384b9e9ab9b4ee8994c8633aabc9505/job_sms/2019-03-01 11_04_24.000/CS_SMS_PROCESS/CS_SMS_PROCESS-IrU8hS82_20190301_110433_183.job",
    		"name": "CS_SMS_PROCESS",
    		"runningData": "{\"jobName\":\"CS_SMS_PROCESS\",\"jobId\":\"107016\",\"App_dis-input\":\"app_sms_process\"}",
    		"status": "NORMAL",
    		"totalGetBytes": 0,
    		"totalGetRecords": 165,
    		"totalPutBytes": 0,
    		"totalPutRecords": 165,
    		"type": "ExecuteCloudStream"
    	},
    	{
    		"name": "DELETE_GES_DIR",
    		"status": "STOPPED",
    		"totalGetBytes": 0,
    		"totalGetRecords": 0,
    		"totalPutBytes": 0,
    		"totalPutRecords": 0,
    		"type": "Delete OBS"
    	},
    	{
    		"logPath": "obs://dlf-log-b384b9e9ab9b4ee8994c8633aabc9505/job_sms/2019-03-01 11_04_24.000/DIS_EVENT/DIS_EVENT-kefeNV5B_20190301_110439_984.job",
    		"name": "DIS_EVENT",
    		"runningData": "{\"app\":\"DLF_job_sms_DLI_SMS_PROCESS\",\"streamName\":\"dis-event\"}",
    		"status": "NORMAL",
    		"totalGetBytes": 0,
    		"totalGetRecords": 8602,
    		"totalPutBytes": 0,
    		"totalPutRecords": 8596,
    		"type": "ExecuteDISStream"
    	},
    	{
    		"logPath": "obs://dlf-log-b384b9e9ab9b4ee8994c8633aabc9505/job_sms/2019-03-01 11_04_24.000/DIS_INPUT/DIS_INPUT-T18JOYTc_20190301_110428_754.job",
    		"name": "DIS_INPUT",
    		"runningData": "{\"streamName\":\"dis-input\"}",
    		"status": "NORMAL",
    		"totalGetBytes": 0,
    		"totalGetRecords": 70341,
    		"totalPutBytes": 0,
    		"totalPutRecords": 70341,
    		"type": "ExecuteDISStream"
    	},
    	{
    		"name": "DLI_SMS_GES",
    		"status": "EXCEPTION",
    		"totalGetBytes": 0,
    		"totalGetRecords": 0,
    		"totalPutBytes": 0,
    		"totalPutRecords": 0,
    		"type": "DLI SQL"
    	},
    	{
    		"name": "DLI_SMS_PROCESS",
    		"status": "NORMAL",
    		"totalGetBytes": 0,
    		"totalGetRecords": 208,
    		"totalPutBytes": 0,
    		"totalPutRecords": 208,
    		"type": "DLI SQL"
    	}],
    	"startTime": 1551409465000,
    	"status": "NORMAL"
    }
  • 失败响应

    HTTP状态码 400

    {
        "error_code":"DLF.0100",
        "error_msg":"The job does not exists."
    }