我們試圖使用ORM三角洲表插入記錄。看起來隻有SQLAlchemy選擇連接到三角洲表。
我們嚐試以下代碼
從sqlalchemy導入列,字符串,DateTime,整數,create_engine引擎= create_engine(“磚+ pyhive: / /標記:< mytoken > @dbc - 5 - a522242 - 184 b.cloud.www.eheci.com: 443 /默認”,connect_args = {" http_path ": " / sql / 1.0 /端點/ 955 e53e5f53e8105”},回聲= True)引擎= create_engine(“磚+ pyhive: / /標記:< mytoken > @dbc - 5 - a522242 - 184 b.cloud.www.eheci.com: 443 /默認”,connect_args ={“集群”:“啟動倉庫”},回聲= True) Base.metadata.create_all(引擎)
但是有錯誤
EOFError回溯(去年)最近調用<命令- 1061455742937075 > <模塊> 1 # 3 - db(遷移)中創建表2打印(BASE_DIR)——> 3 Base.metadata.create_all(引擎)/ local_disk0 / pythonVirtualEnvDirs / virtualenv - 7 c147b6d - 75 - bb - 4981 - 8 ab3 - 879 a1c8e5fa7 / lib / python3.8 /網站/ sqlalchemy / sql /模式。py create_all(自我、綁定表、checkfirst) 4915如果沒有綁定:4916綁定= _bind_or_error(自我)- > 4917綁定。_run_ddl_visitor (4918 ddl。自我,SchemaGenerator checkfirst = checkfirst表=表4919)/ local_disk0 pythonVirtualEnvDirs / virtualenv - 7 c147b6d - 75 - bb - 4981 - 8 ab3 - 879 a1c8e5fa7 / lib / python3.8 /網站/ sqlalchemy /發動機/基地。py _run_ddl_visitor(自我、visitorcallable元素,* * kwargs) 3225 3226 def _run_ddl_visitor(自我、visitorcallable元素,* * kwargs): - > 3227年self.begin康涅狄格州():3228年conn._run_ddl_visitor (visitorcallable元素,* * kwargs) 3229
下麵是一些例子。也有一個圖書館。
https://github.com/dropbox/PyHive/issues/305
https://dev.to/fruiza/build-a-python-flask-api-for-your-delta-lake-3bgf
我想我們其他方麵是開放的。這隻是與攝入相關的數據。我們有一些交易,我們想讀。使用ORM可以確保其他現有應用程序和代碼可以處理它。