我有一个 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')
相关分类