Esegui 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.

Step Functions può controllare determinati AWS servizi direttamente da Amazon States Language (ASL). Per ulteriori informazioni, consultare Integrazione con altri servizi e Passaggio di parametri a un servizio API in Step Functions.

In che modo l'integrazione Optimized Athena è diversa dall'integrazione Athena AWS SDK

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

• Non ci sono ottimizzazioni per il modello di Richiesta e risposta integrazione.

• Il modello di Attendere un callback con il token dell’attività 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 AthenaAPIs. Non tutti APIs supportano tutti i modelli di integrazione, come illustrato nella tabella seguente.

API	Richiesta e risposta	Esegui un processo (.sync)
StartQueryExecution	✓	✓
StopQueryExecution	✓
GetQueryExecution	✓
GetQueryResults	✓

Amazon Athena APIs supportato:

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 si inviano o si ricevono dati da un altro servizio. Per informazioni, consulta Quote relative alle esecuzioni di macchine a stati.

• StartQueryExecution

  • Sintassi della richiesta

  • Parametri supportati:

    • ClientRequestToken

    • ExecutionParameters

    • QueryExecutionContext

    • QueryString

    • ResultConfiguration

    • WorkGroup

  • Response syntax

• StopQueryExecution

  • Sintassi della richiesta

  • Parametri supportati:

    • QueryExecutionId

• GetQueryExecution

  • Sintassi della richiesta

  • Parametri supportati:

    • QueryExecutionId

  • Response syntax

• GetQueryResults

  • Sintassi della richiesta

  • Parametri supportati:

    • MaxResults

    • NextToken

    • QueryExecutionId

  • Response syntax

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://athenaQueryResult"
    }
  },
  "Next": "Get results of the query"
}

Per informazioni su come configurare le IAM autorizzazioni quando vengono utilizzate Step Functions con altri AWS servizi, consulta. In che modo Step Functions genera IAM politiche per servizi integrati