本文属于机器翻译版本。若本译文内容与英语原文存在差异,则一律以英文原文为准。
使用联合查询的示例
以下示例说明如何运行联合查询。
将联合查询与 PostgreSQL 结合使用的示例
以下示例演示如何设置引用 Amazon Redshift 数据库、Aurora PostgreSQL 数据库和 Amazon S3 的联合查询。此示例说明联合查询的工作原理。要在您自己的环境中运行联合查询,请对该查询进行相应更改,使其适合您的环境。有关执行此操作的先决条件,请参阅开始使用对 PostgreSQL 的联合查询。
创建引用 Aurora PostgreSQL 数据库的外部架构。
CREATE EXTERNAL SCHEMA apg FROM POSTGRES DATABASE 'database-1' SCHEMA 'myschema' URI 'endpoint to aurora hostname' IAM_ROLE 'arn:aws:iam::123456789012:role/Redshift-SecretsManager-RO' SECRET_ARN 'arn:aws:secretsmanager:us-west-2:123456789012:secret:federation/test/dataplane-apg-creds-YbVKQw';
创建另一个引用 Amazon S3 的外部架构,该架构使用 Amazon Redshift Spectrum。此外,将使用架构的权限授予 public
。
CREATE EXTERNAL SCHEMA s3 FROM DATA CATALOG DATABASE 'default' REGION 'us-west-2' IAM_ROLE 'arn:aws:iam::123456789012:role/Redshift-S3'; GRANT USAGE ON SCHEMA s3 TO public;
显示 Amazon Redshift 表中的行计数。
SELECT count(*) FROM public.lineitem; count ---------- 25075099
显示 Aurora PostgreSQL 表中的行计数。
SELECT count(*) FROM apg.lineitem; count ------- 11760
显示 Amazon S3 中的行计数。
SELECT count(*) FROM s3.lineitem_1t_part; count ------------ 6144008876
从 Amazon Redshift、Aurora PostgreSQL 和 Amazon S3 中创建表的视图。此视图用于运行联合查询。
CREATE VIEW lineitem_all AS SELECT l_orderkey,l_partkey,l_suppkey,l_linenumber,l_quantity,l_extendedprice,l_discount,l_tax,l_returnflag,l_linestatus, l_shipdate::date,l_commitdate::date,l_receiptdate::date, l_shipinstruct ,l_shipmode,l_comment FROM s3.lineitem_1t_part UNION ALL SELECT * FROM public.lineitem UNION ALL SELECT * FROM apg.lineitem with no schema binding;
使用谓词显示视图 lineitem_all
中的行计数以限制结果。
SELECT count(*) from lineitem_all WHERE l_quantity = 10; count ----------- 123373836
了解每年 1 月份一件商品的销量。
SELECT extract(year from l_shipdate) as year, extract(month from l_shipdate) as month, count(*) as orders FROM lineitem_all WHERE extract(month from l_shipdate) = 1 AND l_quantity < 2 GROUP BY 1,2 ORDER BY 1,2; year | month | orders ------+-------+--------- 1992 | 1 | 196019 1993 | 1 | 1582034 1994 | 1 | 1583181 1995 | 1 | 1583919 1996 | 1 | 1583622 1997 | 1 | 1586541 1998 | 1 | 1583198 2016 | 1 | 15542 2017 | 1 | 15414 2018 | 1 | 15527 2019 | 1 | 151
将联合查询与 MySQL 结合使用的示例
以下是 Amazon Redshift 的 MySQL 联合身份查询功能的预发布文档,目前为预览版。文档和功能均可能随时更改。我们建议您只在测试集群中使用此功能,而不要在生产环境中使用。有关预览版条款和条件,请参阅
AWS 服务条款 |
以下示例演示如何设置引用 Aurora MySQL 数据库的联合查询。此示例说明联合查询的工作原理。要在您自己的环境中运行联合查询,请对该查询进行相应更改,使其适合您的环境。有关执行此操作的先决条件,请参阅开始使用对 MySQL 的联合查询(预览版)。
它取决于以下先决条件:
-
集群位于具有名为 Amazon Redshift 的跟踪的 Preview (预览) 的维护跟踪上。
SQL_PREVIEW
有关更多信息,请参阅 https://docs.amazonaws.cn/redshift/latest/mgmt/working-with-clusters.html#rs-mgmt-maintenance-tracks 中的选择集群维护跟踪Amazon Redshift Cluster Management Guide。 -
在 Secrets Manager 中为 Aurora MySQL 数据库设置的密钥。此密钥在 IAM 访问策略和角色中引用。有关更多信息,请参阅创建密钥和 IAM 角色以使用联合查询。
-
设置链接 Amazon Redshift 和 Aurora MySQL 的安全组。
创建引用 Aurora MySQL 数据库的外部架构。
CREATE EXTERNAL SCHEMA amysql FROM MYSQL DATABASE 'functional' URI 'endpoint to remote hostname' IAM_ROLE 'arn:aws:iam::123456789012:role/Redshift-SecretsManager-RO' SECRET_ARN 'arn:aws:secretsmanager:us-west-2:123456789012:secret:federation/test/dataplane-apg-creds-YbVKQw';
显示 Aurora MySQL 表的示例选择。
SELECT level FROM amysql.employees LIMIT 1; level ------- 8