Démarrez un AWS Glue job chez Step Functions

Apprenez à utiliser Step Functions pour démarrer une tâche AWS Glue. Cette page répertorie les API actions prises en charge et fournit un exemple d'Taskétat pour démarrer un AWS Glue travail.

Pour en savoir plus sur l'intégration avec AWS services dans Step Functions, voir Intégration des services et. Transmission de paramètres à un service API dans Step Functions

Principales fonctionnalités d'Optimized AWS Glue intégration

• Le modèle Exécuter une tâche (.sync) d'intégration est disponible.

• Le JobName champ est extrait de la demande et inséré dans la réponse, qui contient normalement uniquementJobRunID.

Ce qui suit inclut un Task état qui lance un AWS Glue travail.

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

Paramètres dans Step Functions sont exprimés en PascalCase

Même si le service natif API est activécamelCase, par exemple l'APIactionstartSyncExecution, vous spécifiez des paramètres dans PascalCase, tels que :StateMachineArn.

Pris en charge AWS Glue APIs

• StartJobRun

IAMpolitiques relatives aux appels AWS Glue

Les exemples de modèles suivants montrent comment AWS Step Functions génère IAM des politiques basées sur les ressources contenues dans la définition de votre machine à états. Pour plus d’informations, consultez Comment Step Functions génère IAM des politiques pour les services intégrés et Découvrez les modèles d'intégration des services dans Step Functions.

AWS Glue ne dispose pas d'un contrôle basé sur les ressources.

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": "*"
        }
    ]
}