首页 > 解决方案 > 从 Dataframe 到 SQL Server 时出错

问题描述

我在这里查看文档。

https://pandas.pydata.org/pandas-docs/stable/reference/api/pandas.DataFrame.to_sql.html

我不断收到此错误。

'DataFrame' object has no attribute 'to_sql'

下面,是我所有的代码。我看不出这里有什么问题。到底是怎么回事?

import pandas as pd
from sqlalchemy import create_engine
import urllib
import pyodbc

params = urllib.parse.quote_plus("DRIVER={SQL Server Native Client 11.0};SERVER=server_name.database.windows.net;DATABASE=my_db;UID=my_id;PWD=my_pw")
myeng = sqlalchemy.create_engine("mssql+pyodbc:///?odbc_connect=%s" % params)
                           

df.to_sql(name="dbo.my_table", con=myeng, if_exists='append', index=False)

标签: pythonsql-serverpython-3.xdataframedatabricks

解决方案


事实证明,该对象并不是 Pandas 可以解释的实际数据框。这解决了问题。

# convert pyspark.sql DF to Pandas DF
df = df.toPandas()

推荐阅读