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 等）。