嘿,
我想創建一個DLT管道從一個JDBC的數據源讀取,和代碼我使用python看起來像這樣:
進口dlt @dlt。表def table_name():司機= ' oracle.jdbc.driver。OracleDriver url = '……“查詢= '選擇……從…' df = spark.read.format (jdbc) \ .option(“司機”,司機)\ .option (“url”, url) \ .option(“用戶”,用戶名)\ .option(“密碼”,密碼)\ .option(“查詢”,查詢)\ .load()返回df
效果非常好當DLT以外的管道,我知道“df”DataFrame應該創建成功。
我得到一個錯誤在我的DLT管道日誌失敗在“設置表”階段說:“未能解決流程:table_name”。
我試著創建一個基本的DLT表讀取從現有的三角洲(讀取相同的JDBC表但DLT管道外的),效果很好,所以我知道我的環境設置工作正常。
誰能確定是什麼問題呢?
