Step Functions で Athena クエリを実行する - AWS Step Functions

翻訳は機械翻訳により提供されています。提供された翻訳内容と英語版の間で齟齬、不一致または矛盾がある場合、英語版が優先します。

Step Functions で Athena クエリを実行する

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

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

最適化 Athena 統合と Athena AWS SDK 統合の違い

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

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

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

サポートされている Amazon Athena APIs：

注記

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

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

を他の AWS サービスStep Functionsで使用するときにIAMアクセス許可を設定する方法については、「」を参照してくださいStep Functions が統合サービスのIAMポリシーを生成する方法。