Query Amazon Athena
To query Amazon Athena with Flux:
Import the
sqlpackage.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®ion=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...®ion=us-west-1&secretAccessKey=NnQ7MUMp9PYZsmD47c%2BSsXGOFsd%2F... s3://myorgqueryresults/?accessID=AKIAJLO3F...&db=dbname&missingAsDefault=false&missingAsEmptyString=false®ion=us-west-1&secretAccessKey=NnQ7MUMp9PYZsmD47c%2BSsXGOFsd%2F...&WGRemoteCreation=falseUse the following query parameters in your Athena S3 DSN:
* Required- * region - AWS region
- * accessID - AWS IAM access ID
- * 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.
| Athena data type | Flux data type |
|---|---|
| tinyint, smallint, int, integer, bigint | int |
| float, double, real | float |
| timestamp with time zone | time |
| boolean | bool |
All other Athena data types (including timestamp, date and time) are converted to strings.
Was this page helpful?
Thank you for your feedback!
Support and feedback
Thank you for being part of our community! We welcome and encourage your feedback and bug reports for Flux and this documentation. To find support, use the following resources:
Customers with an annual or support contract can contact InfluxData Support.