Terjemahan disediakan oleh mesin penerjemah. Jika konten terjemahan yang diberikan bertentangan dengan versi bahasa Inggris aslinya, utamakan versi bahasa Inggris.
Jalankan kueri Athena dengan Step Functions
Anda dapat berintegrasi AWS Step Functions dengan Amazon Athena untuk memulai dan menghentikan eksekusi kueri dan mendapatkan hasil kueri dengan Step Functions. 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. Halaman ini mencantumkan Athena yang didukung APIs dan memberikan contoh Task status untuk memulai kueri Athena.
Untuk mempelajari tentang mengintegrasikan dengan AWS layanan di Step Functions, lihat Integrasi layanan danMeneruskan parameter ke API layanan di Step Functions.
Fitur utama dari integrasi Athena yang Dioptimalkan
-
Pola Jalankan Tugas (.sync) integrasi didukung.
-
Tidak ada pengoptimalan khusus untuk pola Minta Tanggapan integrasi.
-
Pola Tunggu Callback dengan Task Token integrasi tidak didukung.
Untuk berintegrasi AWS Step Functions dengan Amazon Athena, Anda menggunakan integrasi layanan Athena yang disediakan. APIs
Integrasi APIs layanan sama dengan Athena APIs yang sesuai. Tidak semua APIs mendukung semua pola integrasi, seperti yang ditunjukkan pada tabel berikut.
| API | Respons Permintaan | Jalankan Tugas (.sync) |
|---|---|---|
StartQueryExecution |
Didukung | Didukung |
StopQueryExecution |
Didukung | Tidak didukung |
GetQueryExecution |
Didukung | Tidak didukung |
GetQueryResults |
Didukung | Tidak didukung |
Berikut ini mencakup status tugas yang memulai kueri Athena.
"Start an Athena query": {
"Type": "Task",
"Resource": "arn:aws:states:::athena:startQueryExecution.sync",
"Arguments": {
"QueryString": "SELECT * FROM \"myDatabase\".\"myTable\" limit 1",
"WorkGroup": "primary",
"ResultConfiguration": {
"OutputLocation": "s3://amzn-s3-demo-bucket"
}
},
"Next": "Get results of the query"
}Amazon Athena APIs yang Dioptimalkan:
Kuota untuk input atau data hasil
Saat mengirim atau menerima data antar layanan, input atau hasil maksimum untuk suatu tugas adalah 256 KiB data sebagai string yang dikodekan UTF-8. Lihat Kuota yang berkaitan dengan eksekusi mesin status.
Kebijakan IAM untuk memanggil Amazon Athena
Contoh templat berikut menunjukkan cara AWS Step Functions menghasilkan kebijakan IAM berdasarkan sumber daya dalam definisi mesin status Anda. Untuk informasi selengkapnya, lihat Bagaimana Step Functions menghasilkan kebijakan IAM untuk layanan terintegrasi dan Temukan pola integrasi layanan di Step Functions.
catatan
Selain kebijakan IAM, Anda mungkin perlu menggunakan AWS Lake Formation untuk memberikan akses ke data dalam layanan, seperti Amazon S3 dan. AWS Glue Data Catalog Untuk informasi selengkapnya, lihat Menggunakan Athena untuk menanyakan data yang terdaftar. AWS Lake Formation
StartQueryExecution
Sumber daya statis
Sumber daya dinamis
StopQueryExecution
Sumber Daya
{
"Version": "2012-10-17",
"Statement":[
{
"Effect": "Allow",
"Action": [
"athena:stopQueryExecution"
],
"Resource": [
"arn:aws:athena:region:account-id:workgroup/*"
]
}
]
}GetQueryExecution
Sumber Daya
{
"Version": "2012-10-17",
"Statement":[
{
"Effect": "Allow",
"Action": [
"athena:getQueryExecution"
],
"Resource": [
"arn:aws:athena:region:account-id:workgroup/*"
]
}
]
}GetQueryResults
Sumber Daya
{
"Version": "2012-10-17",
"Statement":[
{
"Effect": "Allow",
"Action": [
"athena:getQueryResults"
],
"Resource": [
"arn:aws:athena:region:account-id:workgroup/*"
]
},
{
"Effect": "Allow",
"Action": [
"s3:GetObject"
],
"Resource": [
"arn:aws:s3:::*"
]
}
]
}