Amazon Redshift SQL¶

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

先决条件任务¶

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

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

操作符¶

执行 SQL 查询¶

通用的 SQLExecuteQueryOperator 可以用来针对使用 Amazon Redshift 连接的 Amazon Redshift 集群执行 SQL 查询。

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

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,
)

参考¶

此条目是否有帮助？