SQLExecuteQueryOperator 連線 Apache Kylin¶

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

注意

沒有專門用於 Apache Kylin 的運算子。請改用 SQLExecuteQueryOperator。

注意

確保您已安裝必要的提供者包（例如 apache-airflow-providers-apache-kylin）以啟用 Apache Kylin 支援。

使用運算子¶

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

Kylin Airflow 連線元資料¶
引數	輸入
Host: string	Kylin 伺服器主機名或 IP 地址
Schema: string	預設專案名稱（可選）
Login: string	用於認證的使用者名稱（預設：ADMIN）
Password: string	用於認證的密碼（預設：KYLIN）
Port: int	Kylin 服務埠（預設：7070）
Extra: JSON	附加連線配置，例如： `{"use_ssl": false}`

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

tests/system/apache/kylin/example_kylin.py

    create_table_kylin_task = SQLExecuteQueryOperator(
        task_id="create_table_kylin",
        sql="""
            CREATE TABLE IF NOT EXISTS kylin_example (
                a VARCHAR(100),
                b INT
            )
        """,
    )

    alter_table_kylin_task = SQLExecuteQueryOperator(
        task_id="alter_table_kylin",
        sql="ALTER TABLE kylin_example ADD COLUMN c INT",
    )

    insert_data_kylin_task = SQLExecuteQueryOperator(
        task_id="insert_data_kylin",
        sql="""
            INSERT INTO kylin_example (a, b, c)
            VALUES ('x', 10, 1), ('y', 20, 2), ('z', 30, 3)
        """,
    )

    select_data_kylin_task = SQLExecuteQueryOperator(
        task_id="select_data_kylin",
        sql="SELECT * FROM kylin_example",
    )

    drop_table_kylin_task = SQLExecuteQueryOperator(
        task_id="drop_table_kylin",
        sql="DROP TABLE kylin_example",
    )

參考資料¶

更多資訊，請參閱

Apache Kylin 文件

注意

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