Amazon Redshift SQL¶

Amazon Redshift 负责数据仓库设置、操作和扩展的所有工作：包括预置容量、监控和备份集群，以及对 Amazon Redshift 引擎应用补丁和升级。您可以专注于使用数据为您的业务和客户获取新的见解。

先决条件任务¶

要使用这些操作符，您必须执行以下操作：

使用 AWS 控制台或 AWS CLI 创建所需的资源。
通过 pip 安装 API 库。
pip install 'apache-airflow[amazon]'
详细信息请参阅安装 Apache Airflow®
设置连接.

操作符¶

执行 SQL 查询¶

通用 SQLExecuteQueryOperator 可用于使用 Amazon Redshift 连接对 Amazon Redshift 集群执行 SQL 查询。

要在不使用 Redshift 连接的情况下对 Amazon Redshift 集群执行 SQL 查询，请查看 RedshiftDataOperator。

common/sql/tests/system/common/sql/example_sql_execute_query.py

execute_query = SQLExecuteQueryOperator(
    task_id="execute_query",
    sql=f"SELECT 1; SELECT * FROM {AIRFLOW_DB_METADATA_TABLE} LIMIT 1;",
    split_statements=True,
    return_last=False,
)

参考资料¶

此条目有帮助吗？