Creación de un trabajo

Escenario

Esta API se utiliza para agregar y enviar un trabajo en un clúster MRS. Para obtener más información sobre cómo invocar a las API, consulte Hacer una solicitud de API.

Restricciones

• Se ha creado un clúster que se encuentra en el estado Running .
• Ha obtenido el ID de proyecto de la región donde se va a crear el clúster. Para obtener más información, consulte Obtención de un ID de proyecto.
• Ha obtenido el ID de clúster, es decir, el valor de cluster_id en el resultado del comando devuelto después de crear el clúster correctamente. Para obtener más información acerca de cómo obtener el ID de clúster, consulte Obtención de un ID de clúster.
• Los usuarios de IAM se han sincronizado. En la página de la pestaña Información general de la página de detalles del clúster, haga clic en Click to synchronize a la derecha de IAM User Sync para sincronizar usuarios de IAM.
• Los programas relacionados con el trabajo y los archivos de entrada se han almacenado en OBS.
• En este ejemplo, se agrega un trabajo de MapReduce.

Procedimiento

• API

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

  Para obtener más información, consulte Adición y ejecución de un trabajo.

• Solicitud de ejemplo

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

  • Para obtener más información sobre {endpoint}, consulte Puntos de conexión.
  • Para obtener más información sobre {project_id}, consulte Obtención de un ID de proyecto.
  • {cluster_id} indica el valor de cluster_id en el resultado del comando devuelto después de que el clúster se haya creado correctamente. También puede obtener el valor de cluster_id haciendo referencia a Obtención de un ID de clúster.
  Cuerpo de la solicitud:

  {
      "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"
      }
  }

  Para obtener más información sobre los parámetros, consulte Adición y ejecución de un trabajo.

• Ejemplo de respuesta

  {
    "job_submit_result":{
        "job_id":"44b37a20-ffe8-42b1-b42b-78a5978d7e40",
        "state":"COMPLETE"
    }
  }