df = pd.read_sql(f"SELECT * FROM {table_name}", conn)
import os
import glob
import pandas as pd
from questdb.ingress import Sender
with Sender('127.0.0.1', 9009) as sender:
sender.dataframe(df,table_name='rpt_forecast_stk')
IngressError Traceback (most recent call last)
Cell In[7], line 6
4 from questdb.ingress import Sender
5 with Sender('127.0.0.1', 9009) as sender:
----> 6 sender.dataframe(df,table_name='rpt_forecast_stk')
File src\questdb\ingress.pyx:1640, in questdb.ingress.Sender.dataframe()
File src\questdb\dataframe.pxi:2270, in questdb.ingress._dataframe()
File src\questdb\dataframe.pxi:2263, in questdb.ingress._dataframe()
File src\questdb\dataframe.pxi:2239, in questdb.ingress._dataframe()
File src\questdb\dataframe.pxi:2118, in questdb.ingress._dataframe_handle_auto_flush()
hi
I have a problem which is that I am trying to write data to local questdb database,the code is shown below
import sqlite3 import pandas as pd
连接到 SQLite 数据库
conn = sqlite3.connect('D:\wind_data\DataFromWind.db')
表名
table_name = 'rpt_forecast_stk'
使用 pd.read_sql 读取整个表
df = pd.read_sql(f"SELECT * FROM {table_name}", conn)
import os import glob import pandas as pd from questdb.ingress import Sender with Sender('127.0.0.1', 9009) as sender: sender.dataframe(df,table_name='rpt_forecast_stk')
IngressError Traceback (most recent call last) Cell In[7], line 6 4 from questdb.ingress import Sender 5 with Sender('127.0.0.1', 9009) as sender: ----> 6 sender.dataframe(df,table_name='rpt_forecast_stk')
File src\questdb\ingress.pyx:1640, in questdb.ingress.Sender.dataframe()
File src\questdb\dataframe.pxi:2270, in questdb.ingress._dataframe()
File src\questdb\dataframe.pxi:2263, in questdb.ingress._dataframe()
File src\questdb\dataframe.pxi:2239, in questdb.ingress._dataframe()
File src\questdb\dataframe.pxi:2118, in questdb.ingress._dataframe_handle_auto_flush()
IngressError: Could not flush buffer: 远程主机强迫关闭了一个现有的连接。 (os error 10054) - See https://py-questdb-client.readthedocs.io/en/v1.1.0/troubleshooting.html#inspecting-and-debugging-errors#flush-failed