透過 SQLExecuteQueryOperator 連線到 Apache Drill¶

前提條件¶

使用 SQLExecuteQueryOperator，在 Drill 查詢引擎中執行 SQL 命令。

要連線到 Drill，您必須配置一個 Drill 連線，並將其作為 conn_id 傳遞給 SQLExecuteQueryOperator。

警告

之前使用 DrillOperator 執行此類操作。但目前 DrillOperator 已棄用，並將在提供包的未來版本中移除。請儘快考慮切換到 SQLExecuteQueryOperator。

SQLExecuteQueryOperator¶

在 Apache Drill 伺服器上執行一個或多個 SQL 查詢。sql 引數是可模板化的，並且可以是外部的 .sql 檔案。

使用 Operator¶

tests/system/apache/drill/example_drill_dag.py

sql_task = SQLExecuteQueryOperator(
    task_id="json_to_parquet_table",
    sql="""
    drop table if exists dfs.tmp.employee;
    create table dfs.tmp.employee as select * from cp.`employee.json`;
    """,
)

參考¶

更多資訊，請參閱有關查詢資料的 Drill 文件。