Query Amazon Athena

To query Amazon Athena with Flux:

1. Import the sql package.

2. Use sql.from() and provide the following parameters:

   • driverName: awsathena
   • dataSourceName: See data source name
   • query: SQL query to execute

import "sql"

sql.from(
    driverName: "awsathena",
    dataSourceName:
        "s3://myorgqueryresults/?accessID=12ab34cd56ef&region=region-name&secretAccessKey=y0urSup3rs3crEtT0k3n",
    query: "GO SELECT * FROM Example.Table",
)

Amazon Athena data source name

The awsathena driver uses the following data source name (DSN) syntaxes (also known as a connection string):

s3://myorgqueryresults/?accessID=AKIAJLO3F...&region=us-west-1&secretAccessKey=NnQ7MUMp9PYZsmD47c%2BSsXGOFsd%2F...
s3://myorgqueryresults/?accessID=AKIAJLO3F...&db=dbname&missingAsDefault=false&missingAsEmptyString=false&region=us-west-1&secretAccessKey=NnQ7MUMp9PYZsmD47c%2BSsXGOFsd%2F...&WGRemoteCreation=false

Use the following query parameters in your Athena S3 DSN:

{{< req type="key" >}}

• {{< req "*" >}} region - AWS region
• {{< req "*" >}} accessID - AWS IAM access ID
• {{< req "*" >}} secretAccessKey - AWS IAM secret key
• db - database name
• WGRemoteCreation - controls workgroup and tag creation
• missingAsDefault - replace missing data with default values
• missingAsEmptyString - replace missing data with empty strings

Athena to Flux data type conversion

sql.from() converts Athena data types to Flux data types.

{{% caption %}} All other Athena data types (including timestamp, date and time) are converted to strings. {{% /caption %}}