示例:地理空间查询 - Amazon Athena
AWS 文档中描述的 AWS 服务或功能可能因区域而异。要查看适用于中国区域的差异,请参阅中国的 AWS 服务入门

本文属于机器翻译版本。若本译文内容与英语原文存在差异,则一律以英文原文为准。

示例:地理空间查询

本主题中的示例从 上可用的示例数据创建两个表GitHub,并根据数据查询这些表。以下文件中的示例数据仅用于说明目的,并不能保证准确性:

  • earthquakes.csv – 列出了加利福尼亚发生的地震。示例 earthquakes 表使用此数据中的字段。

  • california-counties.json – 列出采用 ESRI 兼容GeoJSON格式的加利福尼亚州的县数据。数据包括许多字段,例如 AREAPERIMETERSTATECOUNTYNAME,但示例counties表仅使用两个字段Name:(字符串)和 BoundaryShape (二进制)。

    注意

    Athena 使用 com.esri.json.hadoop.EnclosedJsonInputFormat 将 JSON 数据转换为地理空间二进制格式。

以下代码示例创建一个名为 的表:earthquakes:

CREATE external TABLE earthquakes ( earthquake_date string, latitude double, longitude double, depth double, magnitude double, magtype string, mbstations string, gap string, distance string, rms string, source string, eventid string ) ROW FORMAT DELIMITED FIELDS TERMINATED BY ',' STORED AS TEXTFILE LOCATION 's3://my-query-log/csv/';

以下代码示例创建一个名为 的表:counties:

CREATE external TABLE IF NOT EXISTS counties ( Name string, BoundaryShape binary ) ROW FORMAT SERDE 'com.esri.hadoop.hive.serde.JsonSerde' STORED AS INPUTFORMAT 'com.esri.json.hadoop.EnclosedJsonInputFormat' OUTPUTFORMAT 'org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat' LOCATION 's3://my-query-log/json/';

以下示例查询对 CROSS JOINcounties 表使用 earthquake 函数。该示例使用 ST_CONTAINS 查询其边界包含地震位置的县,地震位置由 指定ST_POINT。 查询按名称对这些县进行分组,按计数对其进行排序,并按降序返回它们。查询使用 。

注意

在 中, 等函数ST_CONTAINS不再支持 VARBINARY 类型作为输入。因此,该示例使用 ST_GeomFromLegacyBinary(varbinary) 函数将boundaryshape二进制值转换为几何体。如果您使用的是 ,则无需进行此转换。有关更多信息,请参阅 对地理空间函数的更改 参考中的 。

SELECT counties.name, COUNT(*) cnt FROM counties CROSS JOIN earthquakes WHERE ST_CONTAINS (ST_GeomFromLegacyBinary(counties.boundaryshape), ST_POINT(earthquakes.longitude, earthquakes.latitude)) GROUP BY counties.name ORDER BY cnt DESC

此查询返回:

+------------------------+ | name | cnt | +------------------------+ | Kern | 36 | +------------------------+ | San Bernardino | 35 | +------------------------+ | Imperial | 28 | +------------------------+ | Inyo | 20 | +------------------------+ | Los Angeles | 18 | +------------------------+ | Riverside | 14 | +------------------------+ | Monterey | 14 | +------------------------+ | Santa Clara | 12 | +------------------------+ | San Benito | 11 | +------------------------+ | Fresno | 11 | +------------------------+ | San Diego | 7 | +------------------------+ | Santa Cruz | 5 | +------------------------+ | Ventura | 3 | +------------------------+ | San Luis Obispo | 3 | +------------------------+ | Orange | 2 | +------------------------+ | San Mateo | 1 | +------------------------+

其他资源

有关地理空间查询的更多示例,请参阅以下博客文章: