Führen Sie Athena-Abfragen mit Step Functions aus - AWS Step Functions

Die vorliegende Übersetzung wurde maschinell erstellt. Im Falle eines Konflikts oder eines Widerspruchs zwischen dieser übersetzten Fassung und der englischen Fassung (einschließlich infolge von Verzögerungen bei der Übersetzung) ist die englische Fassung maßgeblich.

Führen Sie Athena-Abfragen mit Step Functions aus

Sie können Amazon Athena AWS Step Functions integrieren, um die Abfrageausführung zu starten und zu beenden und Abfrageergebnisse mit Step Functions zu erhalten. Mithilfe von Step Functions können Sie Ad-hoc-Datenabfragen oder geplante Datenabfragen ausführen und Ergebnisse abrufen, die auf Ihre S3-Datenseen abzielen. Athena ist Serverless, weshalb auch keine Infrastruktur eingerichtet oder verwaltet werden muss – und Sie zahlen nur für tatsächlich ausgeführte Abfragen. Diese Seite listet die unterstützten Athena auf APIs und bietet einen Task Beispielstatus zum Starten einer Athena-Abfrage.

Step Functions kann bestimmte AWS Dienste direkt von Amazon States Language (ASL) aus steuern. Weitere Informationen hierzu finden Sie unter Integration anderer Services und Übergeben von Parametern an einen Dienst API in Step Functions.

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

Für die Integration AWS Step Functions mit Amazon Athena verwenden Sie die bereitgestellte Athena-Serviceintegration. APIs

Die Serviceintegration APIs ist dieselbe wie bei der entsprechenden AthenaAPIs. Nicht alle APIs unterstützen alle Integrationsmuster, wie in der folgenden Tabelle dargestellt.

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

Unterstütztes Amazon AthenaAPIs:

Anmerkung

In Step Functions gibt es ein Kontingent für die maximale Eingabe- oder Ergebnisdatengröße für eine Aufgabe. Dadurch sind Sie auf 256 KB an 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 der Ausführung von Zustandsmaschinen.

Das Folgende beinhaltet einen Task-Status, 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 Berechtigungen bei der Verwendung Step Functions mit anderen AWS Diensten finden Sie unterSo generiert Step Functions IAM Richtlinien für integrierte Dienste.