Step Functions で Athena を呼び出す

Step Functions AWS は特定のサービスを Amazon ステートメント言語 (ASL) から直接制御できます。詳細については、「他の サービスでの使用」および「サービス API にパラメータを渡す」を参照してください。

最適化された Athena インテグレーションと AWS Athena SDK インテグレーションの違い

• ジョブの実行 (.sync) 統合パターンがサポートされています。

• レスポンスのリクエスト 統合パターンの最適化はありません。

• タスクトークンのコールバックまで待機する 統合パターンはサポートされていません。

Amazon Athena AWS Step Functions とのサービス統合により、Step Functions を使用してクエリの実行を開始および停止し、クエリ結果を取得できます。Step Functions を使用して、アドホックまたはスケジュールされたデータクエリを実行し、S3 データレイクを対象とした結果を取得できます。Athena はサーバーレスであるため、インフラストラクチャの設定や管理は不要です。また、実行したクエリにのみ課金されます。

Amazon Athena AWS Step Functions と統合するには、提供されている Athena サービス統合 API を使用します。

サービス統合 API は、対応する Athena API と同じです。次の表に示すとおり、すべての API がすべての統合パターンをサポートしているわけではありません。

API	レスポンスのリクエスト	ジョブの実行 (.sync)
StartQueryExecution	✓	✓
StopQueryExecution	✓
GetQueryExecution	✓
GetQueryResults	✓

サポートされている Amazon Athena API:

注記

Step Functions のタスクには入力データまたは結果データの最大サイズにはクォータがあります。これにより、別のサービスとの間でデータを送受信するときに、UTF-8 でエンコードされた文字列として 256 KB のデータに制限されます。ステートマシンの実行に関連するクォータ を参照してください。

• StartQueryExecution

  • リクエストの構文

  • サポートされているパラメータ:

    • ClientRequestToken

    • ExecutionParameters

    • QueryExecutionContext

    • QueryString

    • ResultConfiguration

    • WorkGroup

  • Response syntax

• StopQueryExecution

  • リクエストの構文

  • サポートされているパラメータ:

    • QueryExecutionId

• GetQueryExecution

  • リクエストの構文

  • サポートされているパラメータ:

    • QueryExecutionId

  • Response syntax

• GetQueryResults

  • リクエストの構文

  • サポートされているパラメータ:

    • MaxResults

    • NextToken

    • QueryExecutionId

  • Response syntax

以下には、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"
}

IAMStep Functions AWS 他のサービスと併用する場合のアクセス権限の設定方法については、「」を参照してください。統合サービスの IAM ポリシー