我正在嘗試將大型 dask 數據幀上傳到 sql 服務器,但出現錯誤并且看不到連接字符串有任何問題。我可以使用此連接字符串連接到數據庫,但在運行以下命令時出現錯誤:import sqlalchemy as saimport dask.dataframe as ddfrom dask.diagnostics import ProgressBarpbar = ProgressBar()pbar.register()#windows authentication + fast_executemany=Trueto_sql_uri = sa.create_engine('mssql+pyodbc://TEST-BI/DB_TEST?driver=SQL Server?Trusted_Connection=yes', fast_executemany=True)ddf.to_sql('test', uri=to_sql_uri, if_exists='replace', index=False)ValueError:預期 URI 為字符串,得到 <class 'sqlalchemy.engine.base.Engine'>。我嘗試強制將 to_sql_uri 轉換為字符串,但仍然出現錯誤。
1 回答

料青山看我應如是
TA貢獻1772條經驗 獲得超8個贊
如果文檔不夠清晰(文檔頁面、?API 參考),我很抱歉。但是,您沒有在調用中傳遞字符串,而是傳遞了一個引擎實例,這就是錯誤消息的內容。
你應該做
ddf.to_sql('test',? ????uri='mssql+pyodbc://TEST-BI/DB_TEST?driver=SQL?Server?Trusted_Connection=yes',? ????if_exists='replace',?index=False)
添加回答
舉報
0/150
提交
取消