Avvia un AWS Glue lavoro con Step Functions

Impara a usare Step Functions per avviare un job su AWS Glue. Questa pagina elenca le API azioni supportate e fornisce un esempio di Task stato per avviare un AWS Glue lavoro.

Per saperne di più sull'integrazione con AWS servizi in Step Functions, vedere Integrazione dei servizi e. Passaggio di parametri a un servizio API in Step Functions

Caratteristiche principali di Optimized AWS Glue integrazione

• Il modello di Esegui un processo (.sync) integrazione è disponibile.

• Il JobName campo viene estratto dalla richiesta e inserito nella risposta, che normalmente contiene JobRunID solo.

Quanto segue include uno Task stato che avvia un AWS Glue lavoro.

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

Parametri in Step Functions sono espressi in PascalCase

Anche se il servizio nativo API è attivocamelCase, ad esempio l'APIazionestartSyncExecution, si specificano i parametri in PascalCase, ad esempio:StateMachineArn.

Supportato AWS Glue APIs

• StartJobRun

IAMpolitiche per le chiamate AWS Glue

I seguenti modelli di esempio mostrano come AWS Step Functions genera IAM politiche basate sulle risorse nella definizione della macchina a stati. Per ulteriori informazioni, consulta In che modo Step Functions genera IAM politiche per servizi integrati e Scopri i modelli di integrazione dei servizi in Step Functions.

AWS Glue non dispone di un controllo basato sulle risorse.

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