文档首页 > > API参考> API> 作业管理> 随机集群创建作业并执行

随机集群创建作业并执行

分享
更新时间: 2019/07/25 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列表,系统会从里面随机选择一个开机状态的集群,在该集群中创建作业并执行作业。

响应

  • 响应样例
    {
      "name": "es_css"
    }
  • 参数说明

    名称

    是否必须

    类型

    说明

    name

    String

    作业名称。

返回值

  • 正常

    200

  • 异常

    返回值

    说明

    400 Bad Request

    请求错误。

    401 Unauthorized

    鉴权失败。

    403 Forbidden

    没有操作权限。

    404 Not Found

    找不到资源。

    500 Internal Server Error

    服务内部错误,具体返回错误码请参考错误码

    503 Service Unavailable

    服务不可用。

分享:

    相关文档

    相关产品

文档是否有解决您的问题?

提交成功!

非常感谢您的反馈,我们会继续努力做到更好!

反馈提交失败,请稍后再试!

*必选

请至少选择或填写一项反馈信息

字符长度不能超过200

提交反馈 取消

如您有其它疑问,您也可以通过华为云社区问答频道来与我们联系探讨

跳转到云社区