Comience un AWS Glue trabajo con Step Functions

Aprenda a usar Step Functions para empezar a ejecutar un trabajo AWS Glue. En esta página se enumeran las acciones de API compatibles y se proporciona un ejemplo de Task estado para iniciar un AWS Glue trabajo.

Para obtener información sobre la integración con AWS los servicios de Step Functions, consulte Integración de los servicios de yCómo pasar parámetros a una API de servicio en Step Functions.

Características principales de la AWS Glue integración optimizada

• El patrón de integración Ejecutar un trabajo (.sync) está disponible.

• El campo JobName se extrae de la solicitud y se inserta en la respuesta, que normalmente solo contiene JobRunID.

A continuación se incluye un Task estado que inicia un AWS Glue trabajo.

"Glue StartJobRun": {
      "Type": "Task",
      "Resource": "arn:aws:states:::glue:startJobRun.sync",
      "Parameters": {
        "JobName": "GlueJob-JTrRO5l98qMG"
      },
      "Next": "ValidateOutput"
    },

Parámetros en Step Functions se expresan en PascalCase

Incluso si la API del servicio nativo está en CamelCase, por ejemplo, la startSyncExecution acción de la API, se especifican parámetros PascalCase en, como:. StateMachineArn

Optimizado AWS Glue APIs

• StartJobRun

Políticas de IAM para llamadas AWS Glue

Las siguientes plantillas de ejemplo muestran cómo se AWS Step Functions generan las políticas de IAM en función de los recursos de la definición de su máquina de estados. Para obtener más información, consulte Generación de políticas de IAM para servicios integrados por Steps Functions y Descubrimiento de los patrones de integración de servicios en Step Functions.

AWS Glue no tiene un control basado en los recursos.

Run a Job (.sync)

{
    "Version": "2012-10-17",
    "Statement": [
        {
            "Effect": "Allow",
            "Action": [
                "glue:StartJobRun",
                "glue:GetJobRun",
                "glue:GetJobRuns",
                "glue:BatchStopJobRun"
            ],
            "Resource": "*"
        }
    ]
}

Request Response and Callback (.waitForTaskToken)

{
    "Version": "2012-10-17",
    "Statement": [
        {
            "Effect": "Allow",
            "Action": [
                "glue:StartJobRun"
            ],
            "Resource": "*"
        }
    ]
}