查询作业详情

功能介绍

此接口可以查询指定DLF作业定义。

URI

• URI格式

  GET /v1/{project_id}/jobs/{name}

• 参数说明

  参数名	是否必选	参数类型	说明
  project_id	是	String	项目编号，获取方法请参见项目ID和帐号ID。
  name	是	String	作业名称。

请求消息

响应消息

参考创建作业的请求参数。

示例

查询作业myJob的详情。

• 请求

  GET /v1/b384b9e9ab9b4ee8994c8633aabc9505/jobs/myJob

• 成功响应

  {
  	"basicConfig": {
  		"instanceTimeout": 0,
  		"priority": 0
  	},
  	"logPath": "obs://dlf-log-b384b9e9ab9b4ee8994c8633aabc9505",
  	"name": "myJob",
  	"nodes": [{
  		"failPolicy": "FAIL",
  		"location": {
  			"x": "385.0",
  			"y": "150.0"
  		},
  		"maxExecutionTime": 60,
  		"name": "DIS_INPUT",
  		"pollingInterval": 1,
  		"preNodeName": [],
  		"properties": [{
  			"name": "streamName",
  			"value": "csinput"
  		}],
  		"resources": [],
  		"retryInterval": 120,
  		"retryTimes": 0,
  		"type": "DISStream"
  	},
  	{
  		"failPolicy": "FAIL",
  		"location": {
  			"x": "572.0",
  			"y": "151.0"
  		},
  		"maxExecutionTime": 60,
  		"name": "CS_PROCESS",
  		"pollingInterval": 10,
  		"preNodeName": ["DIS_INPUT"],
  		"properties": [{
  			"name": "scriptName",
  			"value": "CS_PROCESS_TRIP"
  		},
  		{
  			"name": "jobName",
  			"value": "CS_PROCESS"
  		},
  		{
  			"name": "jobType",
  			"value": "flink_sql_job"
  		},
  		{
  			"name": "clusterName",
  			"value": "-1"
  		},
  		{
  			"name": "spuNumber",
  			"value": "2"
  		},
  		{
  			"name": "parallelNumber",
  			"value": "1"
  		}],
  		"resources": [],
  		"retryInterval": 120,
  		"retryTimes": 0,
  		"type": "CSJob"
  	},
  	{
  		"failPolicy": "FAIL",
  		"location": {
  			"x": "718.0",
  			"y": "121.0"
  		},
  		"maxExecutionTime": 60,
  		"name": "DIS_EVENT",
  		"pollingInterval": 1,
  		"preNodeName": ["CS_PROCESS"],
  		"properties": [{
  			"name": "streamName",
  			"value": "dis-event"
  		}],
  		"resources": [],
  		"retryInterval": 120,
  		"retryTimes": 0,
  		"type": "DISStream"
  	},
  	{
  		"eventTrigger": {
  			"channel": "dis-event",
  			"concurrent": 1,
  			"engineType": "DIS",
  			"failPolicy": "CONTINUE",
  			"readPolicy": "LAST"
  		},
  		"failPolicy": "FAIL",
  		"location": {
  			"x": "848.0",
  			"y": "167.0"
  		},
  		"maxExecutionTime": 60,
  		"name": "TRIP_RAW_STANDARD",
  		"pollingInterval": 10,
  		"preNodeName": ["DIS_EVENT"],
  		"properties": [{
  			"name": "scriptName",
  			"value": "TRIP_RAW_STANDARD"
  		},
  		{
  			"name": "database",
  			"value": "lixinlong"
  		},
  		{
  			"name": "queueName",
  			"value": "default"
  		}],
  		"resources": [],
  		"retryInterval": 120,
  		"retryTimes": 0,
  		"type": "DLISQL"
  	}],
  	"params": [{
  		"name": "dis_channel",
  		"value": "dis_input"
  	}],
  	"processType": "REAL_TIME",
  	"resources": [],
  	"schedule": {
  		"type": "EXECUTE_ONCE"
  	},
  	"version": "1.0"
  }
  

• 失败响应

  HTTP状态码 400

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