SQLExecuteQueryOperator 連線 Apache Impala¶

使用 SQLExecuteQueryOperator 對 Apache Impala 叢集執行 SQL 查詢。

注意

之前，可能使用過專門用於 Impala 的 Operator。棄用後，請改用 SQLExecuteQueryOperator。

注意

請確保您已安裝 apache-airflow-providers-apache-impala 包以啟用 Impala 支援。

使用 Operator¶

使用 conn_id 引數連線到您的 Apache Impala 例項，其連線元資料結構如下

Impala Airflow 連線元資料¶
引數	輸入
主機: 字串	Impala 守護程序主機名或 IP 地址
模式: 字串	預設資料庫名稱 (可選)
登入: 字串	用於認證的使用者名稱 (如適用)
密碼: 字串	用於認證的密碼 (如適用)
埠: 整數	Impala 服務埠 (預設: 21050)
額外配置: JSON	額外的連線配置，例如: `{"use_ssl": false, "auth": "NOSASL"}`

SQLExecuteQueryOperator 連線 Apache Impala 的示例用法如下

tests/system/apache/impala/example_impala.py

    create_table_impala_task = SQLExecuteQueryOperator(
        task_id="create_table_impala",
        sql="""
            CREATE TABLE IF NOT EXISTS impala_example (
                a STRING,
                b INT
            )
            PARTITIONED BY (c INT)
        """,
    )

參考¶

更多資訊，請參閱

Apache Impala 文件

注意

直接透過 SQLExecuteQueryOperator() 提供的引數優先於 Airflow 連線元資料中指定的引數 (例如 schema, login, password 等)。