Rufe Athena mit Step Functions an

Step Functions kann bestimmteAWS Dienste direkt von der Amazon States Language aus steuern. Weitere Informationen zur Arbeit mitAWS Step Functions und ihren Integrationen finden Sie in den folgenden Abschnitten:

• Arbeiten mit anderen Services

• Parameter an eine Service-API übergeben

Wie sich die optimierte Athena-Integration von der AthenaAWS SDK-Integration unterscheidet

• DasAusführen einer Aufgabe (.sync) Integrationsmuster wird unterstützt.

• Es gibt keine Optimierungen für dasRequest Response (Antwort anfordern) Integrationsmuster.

• DasWarten auf einen Callback mit dem Aufgabentoken Integrationsmuster wird nicht unterstützt.

DieAWS Step Functions Serviceintegration mit Amazon Athena ermöglicht es Ihnen, Step Functions zu verwenden, um die Abfrageausführung zu starten und zu beenden und Abfrageergebnisse zu erhalten. Mithilfe von Step Functions können Sie Ad-hoc- oder geplante Datenabfragen ausführen und Ergebnisse abfragen, die auf Ihre S3-Data Lakes abzielen. Athena ist Serverless, weshalb auch keine Infrastruktur eingerichtet oder verwaltet werden muss – und Sie zahlen nur für tatsächlich ausgeführte Abfragen.

Für die IntegrationAWS Step Functions mit Amazon Athena verwenden Sie die bereitgestellten Athena-Serviceintegrations-APIs.

Die Service-Integrations-APIs sind dieselben wie die entsprechenden Athena-APIs. Nicht alle APIs unterstützen alle Integrationsmuster, wie in der folgenden Tabelle dargestellt wird:

API	Request Response (Antwort anfordern)	Ausführen einer Aufgabe (.sync)
StartQueryExecution	✓	✓
StopQueryExecution	✓
GetQueryExecution	✓
GetQueryResults	✓

Unterstützte Amazon Athena Athena-APIs:

Anmerkung

In Step Functions gibt es ein Kontingent für die maximale Eingabe- oder Ergebnisdatengröße für eine Aufgabe. Dadurch sind Sie auf 262.144 Byte Daten als UTF-8-kodierte Zeichenfolge beschränkt, wenn Sie Daten an einen anderen Dienst senden oder von einem anderen Dienst empfangen. Siehe Kontingente im Zusammenhang mit State-Machine-Ausführungen.

• StartQueryExecution

  • Erforderliche Syntax

  • Unterstützte Parameter:

    • ClientRequestToken

    • QueryExecutionContext

    • QueryString

    • ResultConfiguration

    • WorkGroup

  • Response syntax

• StopQueryExecution

  • Erforderliche Syntax

  • Unterstützte Parameter:

    • QueryExecutionId

• GetQueryExecution

  • Erforderliche Syntax

  • Unterstützte Parameter:

    • QueryExecutionId

  • Response syntax

• GetQueryResults

  • Erforderliche Syntax

  • Unterstützte Parameter:

    • MaxResults

    • NextToken

    • QueryExecutionId

  • Response syntax

Das Folgende enthält einen Aufgabenstatus, der eine Athena-Abfrage startet.

"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"
}

Informationen zur Konfiguration von IAM bei der Verwendung von Step Functions mit anderenAWS Diensten finden Sie unterIAM-Richtlinien für integrierte Dienste.