从 Dataframe 到 SQL Server 时出错

Question

我正在这里查看文档。

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)

Answer 1

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

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