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