amazon-athena 相关问题

Amazon Athena是一种针对存储在Amazon S3上的数据运行SQL查询的服务。 Amazon Athena是Amazon Web Services(AWS)的一部分。

雅典娜/急速逃脱下划线

我试图转义类似运算符中的下划线,但没有得到任何结果。 我正在尝试查找具有“aa_”之类值的任何行。 哪里的值像'%aa\_%'

回答 1 投票 0

导入错误:无法从“dbt.adapters.base”导入名称“凭据”

我正在尝试使用 dbt-core 设置 AWS Athena 适配器 设置 python -m pip 安装 dbt-core dbt-athena 遵循此文档:Athena 设置 | dbt 开发者中心 〜/.dbt/profiles.yml 默认: 出来...

回答 1 投票 0

错误。在雅典娜它有效

我收到此错误: pyspark.sql.utils.ParseException:不匹配的输入“my_schema”期望{')',','}(第86行,第33位) 对于这段代码: 选择 my_table.id AS ID, my_table.name AS 名称, ... '

回答 1 投票 0

表中存储的数据是Unix时间戳,如何使用DateTime格式查询数据?

在 Amazon Athena 上,我有我的桌子: 姓名 服务器时间 登记 鲁迪 1718251764 是的 约翰 1718294964 是的 查尔斯 1718035764 是的 而不必去 unixtimestamp web 来获取 Unix 时间戳......

回答 1 投票 0

AWS dynamoDB 到 Athena 跨账户

我刚刚开始使用AWS,我有一个问题。 我正在尝试将数据从 DynamoDB(账户 A)发送到 Athena(账户 B)。 我想做的是, 每天传输和更新表格...

回答 2 投票 0

Athena 查询未从之前的 CTE 中找到正确的列

我有一个 athena 查询,它从当前日期开始并创建过去 364 天的一日间隔。间隔部分正在抱怨,因为 DateSeries 只有一列“end_date&quo...

回答 1 投票 0

Athena 上的 AWS QuickSight 自定义 SQL 查询

我有一个管道,AWS Kinesis Firehose 接收数据,根据 Athena 表将其转换为 parquet 格式,并根据日期分区 (date_int: YYYYMMdd) 将其存储在 S3 存储桶中。当...

回答 2 投票 0

Athena 查询查找直到下一个值

我有以下记录 逻辑是索引将相同,直到找到下一个价格,计数只是行号 我正在尝试编写查询,但甚至无法开始我应该如何继续,我...

回答 1 投票 0

如何加载整个文本文件作为 AWS Athena 中的记录

我有一堆小文本文件,其中包含多行非结构化数据,存储在 S3 中。 由于这些文件没有常规格式,我想创建一个 Athena 表,其中每个文件都被解析为

回答 1 投票 0

Athena DynamoDB 连接器超时

由于 Athena DynamoDB 连接器 (https://docs.aws.amazon.com/athena/latest/ug/connectors-dynamodb.html) 基于 Lambda,Lambda 时间限制是否会影响执行查询? 怎么回事...

回答 1 投票 0

单日运行 dag 时气流 dag 出现错误:HIVE_TOO_MANY_OPEN_PARTITIONS

我正在使用 DBT 管道和气流 DAG。 SQL查询运行流畅,无需任何DBT代码。然而,当我执行一天的 DAG 时,它会抛出一个标记为

回答 1 投票 0

AWS athena 解析 JSON 数组

我之前曾问过一个问题,并且得到了回答(AWS Athena Parse array of JSON object to rows),关于使用 Athena 解析 JSON 数组,但遇到了一个变体。 使用示例: ...

回答 1 投票 0

如何确定 Athena 中 Iceberg 表的“表类型”

我有一些 Athena 数据库,其中包含许多表,我知道其中一些表使用 Iceberg 格式。对我来说,知道哪些是 Iceberg 表很重要,因为这些表会允许...

回答 1 投票 0

AWS athena 将行转换为列

我有以下疑问 选择 “钥匙”, sum(coalesce(try_cast (sre as double),0)) as sre, sum(coalesce(try_cast ("lacy" as double),0)) as "lacy", 总和(合并(try_cast(&quo...

回答 1 投票 0

get_query_execution 完成后如何执行 get_query_results?

我的 lambda 中有我的代码: 导入 json 导入boto3 导入时间 def lambda_handler(事件,上下文): 客户端 = boto3.client('雅典娜') #执行查询以检索 athena 元数据

回答 1 投票 0

Athena - 创建字段名称与镶木地板列名称不同的外部表

我正在尝试使用 Athena 创建外部表。正在读取的数据格式为镶木地板,我的外部表脚本是: 如果不存在则创建外部表 my_table ( 一个字符串, ...

回答 1 投票 0

AWS Athena 将 JSON 对象数组解析为行

使用 AWS Athena 并尝试解析具有定义的数组数据类型的列中的数据,以便将数组中的每个 JSON 对象分解为单独的行。 当我运行这个查询时: ...

回答 1 投票 0

AWS athena 正则表达式替换除第一次出现之外的情况

我在列中有一些字符串值,如下所示 hel_some_data h_some_data_more_data 你好_一些_更多_数据_数据 我需要如下输出 hel_一些数据 h_some数据 更多数据 你好_更多...

回答 1 投票 0

AWS athena 正则表达式替换(第一次出现除外)

我在列中有一些字符串值,如下所示 hel_some_data h_some_data_more_data 你好_一些_更多_数据_数据 我需要如下输出 hel_一些数据 h_some数据 更多数据 你好_更多...

回答 1 投票 0

Trino 字符串拆分 > 每个字符

我想对在字段中看到的字符进行一些分析,其前身是将字符串值拆分为其组成字符。 有了 SQL Server,我就会求助于 dar...

回答 1 投票 0

© www.soinside.com 2019 - 2024. All rights reserved.