Считайте данные из файла паркета и запишите их в таблицу SQL.Python

Программы на Python
Anonymous
Считайте данные из файла паркета и запишите их в таблицу SQL.

Сообщение Anonymous »

У меня есть код для записи файла паркета в таблицу базы данных SQL, но он не работает

Код: Выделить всё

import pandas as pd
import pyodbc

try:
cnxn = pyodbc.connect(
r'Driver={SQL Server};'
r'Server=localhost,1433;'  # Assuming the default port 1433
r'Database=fatigue_life_test_db;'
r'Trusted_Connection=yes;'
)
cursor = cnxn.cursor()
print("Connection established.")
except pyodbc.Error as e:
print("Error in connection:", e)
finally:
path = r'path\to\parquert\test.parquet'

df = pd.read_parquet(path)
df.to_sql('Test_data_table', con=cnxn, if_exists='append')
if 'cnxn' in locals() and cnxn:
cnxn.close()
Код выдает следующую ошибку: pandas.errors.DatabaseError: Не удалось выполнить sql ' SELECT name FROM sqlite_master WHERE type IN ('table', 'view') AND name=?; ': ('42S02', "[42S02] [Microsoft][Драйвер ODBC SQL Server][SQL Server]Недопустимое имя объекта 'sqlite_master'. (208) (SQLExecDirectW); [42S02] [Microsoft][Драйвер ODBC SQL Server] [SQL Server]Не удалось подготовить операторы (8180)")
Я пытался выполнить этот код в соответствии с документацией pandas, но он все равно не работает. Размер файла паркета составляет несколько гигабайт, так может ли размер быть проблемой?

Подробнее здесь: https://stackoverflow.com/questions/786 ... -sql-table

Вернуться в «Python»