在 Athena 中加载和 SQL 查询 DynamoDB Map 数据类型

如何解决在 Athena 中加载和 SQL 查询 DynamoDB Map 数据类型

我在 DynamoDB 中有这个项目，它包含一个 Map 属性：

{
  "orgName": {
    "S": "example"
  },"typeSavings": {
    "M": {
      "TELECOMS": {
        "N": "50"
      },"GAS": {
        "N": "393"
    }
  }
}

我已使用 DynamoDB 导出功能将此 DynamoDB 数据导出到 S3。

我可以像这样创建一个 Athena 表：

CREATE EXTERNAL TABLE IF NOT EXISTS mytable (
  Item struct <
  orgName:struct<S:string>,typeSavings:MAP<string,string>
  >
)
...

我可以像这样选择表格中的项目：

SELECT
    Item.orgname,Item.typeSavings
FROM mytable

结果在哪里：

orgname               typeSavings 
-------               --------------------
{s=Aaron's Pets Ltd}  {m={"telecoms":{"n":"50"},"gas":{"n":"393"}}}

如何选择 gas typeSavings 大于 50 的项目？

我可以很简单地访问 orgName（例如 WHERE Item.orgname.s = 'example'），但我不确定如何访问地图数据。

我会对在 sql 查询步骤或将数据加载到 Athena 的步骤中解决的解决方案感兴趣。例如，我很乐意将 TELECOMS 储蓄和 GAS 储蓄加载到不同的列中，此时 sql 查询很简单。

解决方法

我使用 element_at 访问地图，然后使用 json_extract 访问 json 值。

SELECT Item.orgname.S as name,CAST(json_extract(element_at(Item.typeSavings,'m'),'$.gas.n') AS DOUBLE) AS gassavings
FROM mytable
WHERE gassavings > 50