Le traduzioni sono generate tramite traduzione automatica. In caso di conflitto tra il contenuto di una traduzione e la versione originale in Inglese, quest'ultima prevarrà.
Esegui le query Athena con Step Functions
Puoi integrarti AWS Step Functions con Amazon Athena per avviare e interrompere l'esecuzione delle query e ottenere risultati delle query con Step Functions. Utilizzando Step Functions, puoi eseguire query di dati ad hoc o pianificate e recuperare risultati destinati ai tuoi data lake S3. Athena è un servizio serverless, perciò non occorre installare o gestire alcuna infrastruttura e vengono addebitati solo i costi relativi all'esecuzione delle query. Questa pagina elenca gli Athena supportati APIs e fornisce Task uno stato di esempio per avviare una query Athena.
Per ulteriori informazioni sull'integrazione con AWS i servizi in Step Functions, vedere Integrazione dei servizi ePassaggio di parametri a un'API di servizio in Step Functions.
Caratteristiche principali dell'integrazione con Optimized Athena
-
Il modello di Esegui un processo (.sync) integrazione è supportato.
-
Non ci sono ottimizzazioni per il modello di Richiesta e risposta integrazione.
-
Il modello di Attendi una richiamata con Task Token integrazione non è supportato.
Per l'integrazione AWS Step Functions con Amazon Athena, utilizzi l'integrazione del servizio Athena fornita. APIs
L'integrazione APIs del servizio è la stessa della corrispondente Athena APIs. Non tutti APIs supportano tutti i modelli di integrazione, come illustrato nella tabella seguente.
| API | Richiesta e risposta | Esegui un processo (.sync) |
|---|---|---|
StartQueryExecution |
Supportato | Supportato |
StopQueryExecution |
Supportato | Non supportato |
GetQueryExecution |
Supportata | Non supportato |
GetQueryResults |
Supportata | Non supportato |
Quanto segue include uno stato Task che avvia una query 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://amzn-s3-demo-bucket"
}
},
"Next": "Get results of the query"
}Amazon APIs Athena ottimizzato:
-
-
Parametri supportati:
-
-
Parametri supportati:
-
-
Parametri supportati:
Nota
Esiste una quota per la dimensione massima dei dati di input o risultato per un'attività in Step Functions. Ciò limita a 256 KB di dati come stringa con codifica UTF-8 quando invii o ricevi dati da un altro servizio. Per informazioni, consulta Quote relative alle esecuzioni di macchine a stati.
Politiche IAM per le chiamate ad Amazon Athena
I seguenti modelli di esempio mostrano come AWS Step Functions generare le politiche IAM in base alle risorse nella definizione della macchina a stati. Per ulteriori informazioni, consulta In che modo Step Functions genera policy IAM per servizi integrati e Scopri i modelli di integrazione dei servizi in Step Functions.
StartQueryExecution
Risorse statiche
Risorse dinamiche
StopQueryExecution
Risorse
{
"Version": "2012-10-17",
"Statement":[
{
"Effect": "Allow",
"Action": [
"athena:stopQueryExecution"
],
"Resource": [
"arn:aws:athena:{{region}}:{{accountId}}:workgroup/*"
]
}
]
}GetQueryExecution
Risorse
{
"Version": "2012-10-17",
"Statement":[
{
"Effect": "Allow",
"Action": [
"athena:getQueryExecution"
],
"Resource": [
"arn:aws:athena:{{region}}:{{accountId}}:workgroup/*"
]
}
]
}GetQueryResults
Risorse
{
"Version": "2012-10-17",
"Statement":[
{
"Effect": "Allow",
"Action": [
"athena:getQueryResults"
],
"Resource": [
"arn:aws:athena:{{region}}:{{accountId}}:workgroup/*"
]
},
{
"Effect": "Allow",
"Action": [
"s3:GetObject"
],
"Resource": [
"arn:aws:s3:::*"
]
}
]
}