更新时间:2022-12-08 GMT+08:00

新增作业

场景描述

在MRS集群中新增并提交一个作业。API的调用方法请参见如何调用API

约束限制

  • 集群已创建成功并处于“运行中”。
  • 已获取待创建集群区域的项目ID,请参考获取项目ID获取。
  • 已获取集群ID,即创建集群成功后返回结果中的“cluster_id” 或参考获取集群ID获取。
  • IAM用户已同步完成,可通过在集群详情页的“概览”页签,单击“IAM用户同步”右侧的“单击同步”进行IAM用户同步。
  • 作业相关程序和输入文件已存放在OBS中。
  • 该示例以新增MapReduce作业为例。

操作步骤

  • 接口相关信息

    URI格式:POST /v2/{project_id}/clusters/{cluster_id}/job-executions

    详情请参见新增并执行作业

  • 请求示例

    POST: https://{endpoint}/v2/{project_id}/clusters/{cluster_id}/job-executions

    • {endpoint}信息请向管理员获取获取。
    • {project_id}信息请通过获取项目ID获取。
    • {cluster_id}信息即创建集群成功后返回结果中的“cluster_id” 或参考获取集群ID获取。
    Body:
    {
        "job_name":"MapReduceTest",
        "job_type":"MapReduce",
        "arguments":[
            "obs://obs-test/program/hadoop-mapreduce-examples-x.x.x.jar",
            "wordcount",
            "obs://obs-test/input/",
            "obs://obs-test/job/mapreduce/output"
        ],
        "properties":{
            "fs.obs.endpoint":"obs endpoint",
            "fs.obs.access.key":"xxx",
            "fs.obs.secret.key":"yyy"
        }
    }

    参数详细信息请参考新增并执行作业获取。

  • 响应示例
    {
      "job_submit_result":{
          "job_id":"44b37a20-ffe8-42b1-b42b-78a5978d7e40",
          "state":"COMPLETE"
      }
    }