功能介绍

在指定的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	作业名称。

返回值

• 正常

  200

• 异常

  返回值	说明
  400 Bad Request	请求错误，具体返回错误码请参考错误码。
  401 Unauthorized	鉴权失败。
  403 Forbidden	没有操作权限。
  404 Not Found	找不到资源。
  500 Internal Server Error	服务内部错误。
  503 Service Unavailable	服务不可用。