Panggil Athena dengan Step Functions

Step Functions dapat mengontrol AWS layanan tertentu langsung dari Amazon States Language (ASL). Untuk mempelajari selengkapnya, lihat Bekerja dengan layanan yang lain dan Meneruskan parameter ke API layanan.

Bagaimana integrasi Athena yang Dioptimalkan berbeda dari integrasi Athena SDK AWS

• Pola Jalankan Tugas (.sync) integrasi didukung.

• Tidak ada pengoptimalan untuk pola Minta Tanggapan integrasi.

• Pola Tunggu Panggilan Balik dengan Token Tugas integrasi tidak didukung.

Integrasi AWS Step Functions layanan dengan Amazon Athena memungkinkan Anda menggunakan Step Functions untuk memulai dan menghentikan eksekusi kueri, dan mendapatkan hasil kueri. Menggunakan Step Functions, Anda dapat menjalankan kueri ad-hoc atau data terjadwal, dan mengambil hasil yang menargetkan danau data S3 Anda. Athena bersifat nirserver, sehingga tidak ada infrastruktur yang disiapkan atau dikelola dan Anda hanya membayar untuk kueri yang Anda jalankan.

Untuk berintegrasi AWS Step Functions dengan Amazon Athena, Anda menggunakan API integrasi layanan Athena yang disediakan.

API integrasi layanan sama dengan API Athena yang sesuai. Tidak semua API mendukung semua pola integrasi, seperti yang ditunjukkan dalam tabel berikut.

API	Respons Permintaan	Jalankan Tugas (.sync)
StartQueryExecution	✓	✓
StopQueryExecution	✓
GetQueryExecution	✓
GetQueryResults	✓

API Amazon Athena yang didukung:

catatan

Ada kuota untuk input maksimum atau ukuran data hasil untuk tugas di Step Functions. Ini membatasi Anda untuk 256 KB data sebagai string UTF-8 yang dikodekan ketika Anda mengirim ke, atau menerima data dari, layanan lain. Lihat Kuota yang berkaitan dengan eksekusi mesin status.

• StartQueryExecution

  • Permintaan sintaks

  • Parameter yang didukung:

    • ClientRequestToken

    • ExecutionParameters

    • QueryExecutionContext

    • QueryString

    • ResultConfiguration

    • WorkGroup

  • Response syntax

• StopQueryExecution

  • Permintaan sintaks

  • Parameter yang didukung:

    • QueryExecutionId

• GetQueryExecution

  • Permintaan sintaks

  • Parameter yang didukung:

    • QueryExecutionId

  • Response syntax

• GetQueryResults

  • Permintaan sintaks

  • Parameter yang didukung:

    • MaxResults

    • NextToken

    • QueryExecutionId

  • Response syntax

Berikut ini mencakup status tugas yang memulai kueri Athena.

"Start an Athena query": {
  "Type": "Task",
  "Resource": "arn:aws:states:::athena:startQueryExecution.sync",
  "Parameters": {
    "QueryString": "SELECT * FROM \"myDatabase\".\"myTable\" limit 1",
    "WorkGroup": "primary",
    "ResultConfiguration": {
       "OutputLocation": "s3://athenaQueryResult"
    }
  },
  "Next": "Get results of the query"
}

Untuk informasi tentang cara mengonfigurasi IAM izin saat menggunakan Step Functions dengan AWS layanan lain, lihatKebijakan IAM untuk layanan terintegrasi.