Amazon Redshift SQL¶

Amazon Redshift 管理設定、操作和擴展資料倉儲的所有工作：佈建容量、監控和備份叢集，以及將修補程式和升級應用於 Amazon Redshift 引擎。您可以專注於使用您的資料來為您的企業和客戶獲取新的見解。

先決條件任務¶

要使用這些運算子，您必須執行以下幾項操作

使用 AWS Console 或 AWS CLI 建立必要的資源。
透過 pip 安裝 API 函式庫。
pip install 'apache-airflow[amazon]'
詳細資訊請參閱 Airflow® 安裝
設定連線.

運算子¶

執行 SQL 查詢¶

通用的 SQLExecuteQueryOperator 可用於針對 Amazon Redshift 叢集執行 SQL 查詢，使用 Amazon Redshift 連線。

若要在不使用 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,
)

參考資料¶

此條目是否有幫助？