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

參考資料¶

此條目有幫助嗎？