tests.system.databricks.example_databricks_sql

這是一個範例 DAG,它使用 DatabricksSqlOperator 和 DatabricksCopyIntoOperator。第一個任務建立表格並將值插入其中。第二個任務使用 DatabricksSqlOperator 選擇資料。第三個任務選擇資料,並將所選資料的輸出儲存在指定檔案路徑和格式中。第四個任務執行在 test.sql 檔案中撰寫的 select SQL 語句。最後一個任務使用 DatabricksCopyIntoOperator 從傳入 Delta 表格的 file_location 載入資料。

模組內容

tests.system.databricks.example_databricks_sql.ENV_ID[source]
tests.system.databricks.example_databricks_sql.DAG_ID = 'example_databricks_sql_operator'[source]
tests.system.databricks.example_databricks_sql.connection_id = 'my_connection'[source]
tests.system.databricks.example_databricks_sql.test_run[source]

這個條目對您有幫助嗎?