cdm
随机集群创建作业并执行
更新时间:2020/12/18 GMT+08:00
功能介绍
在指定的CDM集群列表中,随机选择一个开机状态的集群,在该集群中创建作业并执行作业。
URI
- URI格式
POST /v1.1/{projectId}/clusters/job
- URI参数说明
参数
是否必选
类型
说明
project_id
是
String
项目ID,获取方法请参见获取项目ID/账号名/AK/SK。
请求
- 请求样例
POST /v1.1/ad359ede62234598a962ccb952e3e332/clusters/job { "jobs": [ { "job_type": "NORMAL_JOB", "name": "es_css", "from-link-name": "css", "from-connector-name": "elasticsearch-connector", "to-link-name": "dis", "to-connector-name": "dis-connector", "from-config-values": { "configs": [ { "inputs": [ { "name": "fromJobConfig.index", "value": "52est" }, { "name": "fromJobConfig.type", "value": "est_array" }, { "name": "fromJobConfig.columnList", "value": "array_f1_int:long&array_f2_text:string&array_f3_object:nested" }, { "name": "fromJobConfig.splitNestedField", "value": "false" } ], "name": "fromJobConfig" } ] }, "to-config-values": { "configs": [ { "inputs": [ { "name": "toJobConfig.streamName", "value": "dis-lkGm" }, { "name": "toJobConfig.separator", "value": "|" }, { "name": "toJobConfig.columnList", "value": "1&2&3" } ], "name": "toJobConfig" } ] }, "driver-config-values": { "configs": [ { "inputs": [ { "name": "throttlingConfig.numExtractors", "value": "1" }, { "name": "throttlingConfig.submitToCluster", "value": "false" }, { "name": "throttlingConfig.numLoaders", "value": "1" }, { "name": "throttlingConfig.recordDirtyData", "value": "false" } ], "name": "throttlingConfig" }, { "inputs": [], "name": "jarConfig" }, { "inputs": [ { "name": "schedulerConfig.isSchedulerJob", "value": "false" }, { "name": "schedulerConfig.disposableType", "value": "NONE" } ], "name": "schedulerConfig" }, { "inputs": [], "name": "transformConfig" }, { "inputs": [ { "name": "retryJobConfig.retryJobType", "value": "NONE" } ], "name": "retryJobConfig" } ] } } ], "clusters": [ "b0791496-e111-4e75-b7ca-9277aeab9297", "c2db1191-eb6c-464a-a0d3-b434e6c6df26", "9917ab56-7ac9-4a0b-8422-a806cf7b96e9" ] }
- 参数说明
参数
是否必选
类型
说明
jobs
是
列表数据结构
作业列表,请参见jobs数据结构说明。
clusters
是
String
CDM集群ID列表,系统会从里面随机选择一个开机状态的集群,在该集群中创建作业并执行作业。集群ID列表,可通过查询集群列表获取。
响应
- 响应样例
{ "name": "es_css" }
- 参数说明
名称
是否必须
类型
说明
name
是
String
作业名称。
返回值
- 正常
- 异常
返回值
说明
400 Bad Request
请求错误,具体返回错误码请参考错误码。
401 Unauthorized
鉴权失败。
403 Forbidden
没有操作权限。
404 Not Found
找不到资源。
500 Internal Server Error
服务内部错误。
503 Service Unavailable
服务不可用。
父主题: 作业管理
