Присвоение результатов pd.read_sql_query списку фреймов данных
У меня есть список баз данных sqlite3, и я хотел бы иметь возможность читать каждую из них в отдельный фрейм данных Pandas с циклом, но пока мой метод не заполняет фреймы данных. Я предполагаю, что это связано с работой над копией, а не со ссылкой, но не могу найти хороший способ, чтобы это работало.
import sqlite3
import pandas as pd
db_1 = 'db1.db'
db_2 = 'db2.db'
df_1 = pd.DataFrame()
df_2 = pd.DataFrame()
db_df_name = [(db_1, df_1, 'df_raw'), (db_2, df_2, 'df_processed')]
for (db, df, name) in db_df_name:
with sqlite3.connect(db, detect_types=sqlite3.PARSE_DECLTYPES) as connection:
df = pd.read_sql_query("select * from messages;", connection)
print(f'Database {name} processed')
Ответы 1
Если бы вы могли лучше объяснить, что вы хотите сделать, я мог бы помочь больше.
Попробуйте это и поправьте меня, если это не сработает:
import sqlite3
import pandas as pd
# Assuming that you have two databases...
# which i don't understand cause you use the
# same query below with the same table.
dbs = ['db1.db','db2.db']
db_df_name = [(dbs[0], 'df_raw'), (dbs[1],'df_processed')]
df_1 = pd.DataFrame()
df_2 = pd.DataFrame()
df_list = []
for db, name in db_df_name:
with sqlite3.connect(db, detect_types=sqlite3.PARSE_DECLTYPES) as connection:
df = pd.read_sql_query("select * from messages;", connection)
print(f'Database {name} processed')
df_list = df_list.append(df.copy())
df_1, df_2 = df_list
print(df_1)
print(df_2)
Когда вы используете это: for db, name in db_df_name, дБ является переменной области, это не df_1 сама по себе, предполагая, что вы передаете эту структуру (по этой причине я ее удаляю):
db_df_name = [(db_1, df_1, 'df_raw'), (db_2, df_2, 'df_processed')]
Поэтому, когда вы назначаете df = ..., df_1 будет пустым.
Спасибо за вашу помощь, Лукас, основная цель здесь — прочитать каждую базу данных в отдельном фрейме данных, то есть содержимое db_1 в df_1 и содержимое db_2 в df_2.
Понял, я думал, вы хотите добавить обе базы данных в один DataFrame, тогда я отредактирую...
С текущим кодом df_1.info() возвращает <class 'pandas.core.frame.DataFrame'> Индекс: 0 записей Пустой фрейм данных