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

参考¶

此条目有帮助吗？