Memulai sebuah AWS Glue Pekerjaan dengan Step Functions

Belajar menggunakan Step Functions untuk memulai pekerjaan AWS Glue. Halaman ini mencantumkan API tindakan yang didukung dan memberikan contoh Task status untuk memulai AWS Glue pekerjaan.

Untuk belajar tentang berintegrasi dengan AWS servicesin Step Functions, lihat Integrasi layanan dan. Meneruskan parameter ke layanan API di Step Functions

Fitur utama dari Optimized AWS Glue integrasi

• Pola Jalankan Tugas (.sync) integrasi tersedia.

• JobNameBidang diekstraksi dari permintaan dan dimasukkan ke dalam respons, yang biasanya hanya berisiJobRunID.

Berikut ini mencakup Task status yang memulai AWS Glue pekerjaan.

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

Parameter di Step Functions dinyatakan dalam PascalCase

Bahkan jika layanan asli API adacamelCase, misalnya API tindakanstartSyncExecution, Anda menentukan parameter di PascalCase, seperti:StateMachineArn.

Didukung AWS Glue APIs

• StartJobRun

IAMkebijakan untuk menelepon AWS Glue

Contoh template berikut menunjukkan bagaimana AWS Step Functions menghasilkan IAM kebijakan berdasarkan sumber daya dalam definisi mesin negara Anda. Untuk informasi selengkapnya, silakan lihat Bagaimana Step Functions menghasilkan IAM kebijakan untuk layanan terintegrasi dan Temukan pola integrasi layanan di Step Functions.

AWS Glue tidak memiliki kontrol berbasis sumber daya.

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