SQLExecuteQueryOperator 连接到 Apache Kylin¶

使用 SQLExecuteQueryOperator 对 Apache Kylin 集群执行 SQL 查询。

注意

Apache Kylin 没有专门的操作符。请改用 SQLExecuteQueryOperator。

注意

请确保已安装必要的提供程序包（例如 apache-airflow-providers-apache-kylin），以启用对 Apache Kylin 的支持。

使用操作符¶

使用 conn_id 参数连接到你的 Apache Kylin 实例，连接元数据结构如下：

Kylin Airflow 连接元数据¶
参数	输入
主机: string	Kylin 服务器主机名或 IP 地址
模式: string	默认项目名称（可选）
登录名: string	身份验证的用户名（默认：ADMIN）
密码: string	身份验证的密码（默认：KYLIN）
端口: int	Kylin 服务端口（默认：7070）
额外信息：JSON	其他连接配置，例如：`{\"use_ssl\": false}`

以下是 SQLExecuteQueryOperator 连接到 Apache Kylin 的示例用法

tests/system/apache/kylin/example_kylin.py[source]

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