查询 Amazon Athena

要使用 Flux 查询 Amazon Athena，请执行以下操作

1. 导入 sql 包。

2. 使用 sql.from() 并提供以下参数

   • driverName: awsathena
   • dataSourceName: 请参阅 数据源名称
   • query: 要执行的 SQL 查询

import "sql"

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

Amazon Athena 数据源名称

awsathena 驱动程序使用以下数据源名称 (DSN) 语法（也称为连接字符串）

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

在您的 Athena S3 DSN 中使用以下查询参数

• * region - AWS 区域
• * accessID - AWS IAM 访问 ID
• * secretAccessKey - AWS IAM 密钥
• db - 数据库名称
• WGRemoteCreation - 控制工作组和标签创建
• missingAsDefault - 将缺失数据替换为默认值
• missingAsEmptyString - 将缺失数据替换为空字符串

Athena 到 Flux 数据类型转换

sql.from() 将 Athena 数据类型转换为 Flux 数据类型。