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

编辑作业

功能介绍

此接口可以对一个作业进行编辑。

URI

  • URI格式

    PUT /v1/{project_id}/jobs/{job_name}

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

    参数名

    是否必选

    参数类型

    说明

    project_id

    String

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

    job_name

    String

    作业名称

请求消息

参考请求消息

示例

修改作业dliJob1的属性。

  • 请求
    PUT /v1/b384b9e9ab9b4ee8994c8633aabc9505/jobs/dliJob1
    {
    	"logPath":"obs://dlf-log-b384b9e9ab9b4ee8994c8633aabc9505",
    	"name":"dliJob1",
    	"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":"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,
    			        "eventType:"DIS",
    				"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状态码 204

  • 失败响应

    HTTP状态码 400

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