查询 DynamoDB 中的数据 - Amazon DynamoDB
Amazon Web Services 文档中描述的 Amazon Web Services 服务或功能可能因区域而异。要查看适用于中国区域的差异,请参阅中国的 Amazon Web Services 服务入门

查询 DynamoDB 中的数据

以下示例显示使用 HiveQL 查询 DynamoDB 中存储数据的各种方式。

这些示例参考教程 (第 5 步:将数据复制到 DynamoDB) 的 ddb_features 表。

使用聚合函数

HiveQL 提供内置函数汇总数据值。例如,可以使用 MAX 函数查找所选列的最大值。下面的示例返回科罗拉多州中最高特征的海拔。

SELECT MAX(elev_in_ft) FROM ddb_features WHERE state_alpha = 'CO';

使用 GROUP BY 和 HAVING 子句

可以使用 GROUP BY 子句收集多条记录的数据。这通常与聚合函数(如 SUMCOUNTMINMAX)一起使用。也可以使用 HAVING 子句放弃任何不符合特定条件的结果。

下面的示例返回 ddb_features 表中具有 5 个以上地形的州的最高高程列表。

SELECT state_alpha, max(elev_in_ft) FROM ddb_features GROUP BY state_alpha HAVING count(*) >= 5;

求两个 DynamoDB 表的交集

下面的示例将另一个 Hive 表 (east_coast_states) 映射到 DynamoDB 的表。SELECT 语句联接这两个表。联接在集群计算并返回。联接不在 DynamoDB 中进行。

考虑一个名为 EastCoastStates 的 DynamoDB 表,其中包含以下数据:

StateName StateAbbrev Maine ME New Hampshire NH Massachusetts MA Rhode Island RI Connecticut CT New York NY New Jersey NJ Delaware DE Maryland MD Virginia VA North Carolina NC South Carolina SC Georgia GA Florida FL

假设表作为名为 east_coast_states 的 Hive 外部表提供:

CREATE EXTERNAL TABLE ddb_east_coast_states (state_name STRING, state_alpha STRING) STORED BY 'org.apache.hadoop.hive.dynamodb.DynamoDBStorageHandler' TBLPROPERTIES ("dynamodb.table.name" = "EastCoastStates", "dynamodb.column.mapping" = "state_name:StateName,state_alpha:StateAbbrev");

以下联接返回美国东海岸至少具有三个地形的州:

SELECT ecs.state_name, f.feature_class, COUNT(*) FROM ddb_east_coast_states ecs JOIN ddb_features f on ecs.state_alpha = f.state_alpha GROUP BY ecs.state_name, f.feature_class HAVING COUNT(*) >= 3;

求不同来源表的交集

在下面的示例中,s3_east_coast_states 是与 Amazon S3 中存储的 CSV 文件关联的 Hive 表。ddb_features 表与 DynamoDB 中的数据相关联。下面的示例联接这两个表,从名称以“New”开头的州返回地形。

create external table s3_east_coast_states (state_name STRING, state_alpha STRING) ROW FORMAT DELIMITED FIELDS TERMINATED BY ',' LOCATION 's3://bucketname/path/subpath/';
SELECT ecs.state_name, f.feature_name, f.feature_class FROM s3_east_coast_states ecs JOIN ddb_features f ON ecs.state_alpha = f.state_alpha WHERE ecs.state_name LIKE 'New%';