POSTGRESQL 和 Django 应用程序:无法从客户端接收数据:对等方重置连接

POSTGRESQL 和 Django 应用程序:无法从客户端接收数据:对等方重置连接

我正在使用 postgresql、nginx 和 gunicorn 运行一个 django 应用程序。我有一个脚本,其中从数据库中的一个表中提取数据,进行修改,然后需要替换该表中的现有数据。在同一个脚本中,还会更新几个表。

运行脚本时,总是会出现502 Bad Gateway服务器超时的情况,这是因为脚本中存在某些问题。由于这个主题比较新,我很难弄清楚以下错误到底是怎么回事。

我只能使用来自 postgres 的以下日志:

2020-08-22 14:57:59 UTC::@:[8228]:LOG: checkpoint starting: time
2020-08-22 14:57:59 UTC::@:[8228]:LOG: checkpoint complete: wrote 1 buffers (0.0%); 0 WAL file(s) added, 0 removed, 1 recycled; write=0.101 s, sync=0.005 s, total=0.132 s; sync files=1, longest=0.005 s, average=0.005 s; distance=65536 kB, estimate=70182 kB
2020-08-22 14:58:50 UTC:address-ip(45726):pierre@dbexostock:[25618]:LOG: could not receive data from client: Connection reset by peer
2020-08-22 14:58:50 UTC:address-ip(45724):pierre@dbexostock:[25617]:LOG: could not receive data from client: Connection reset by peer

我认为问题出在脚本中的数据库连接内部:

#connect to db
engine = create_engine('postgresql+psycopg2://user:[email protected]',
                               connect_args={'options': '-csearch_path={}'.format(dbschema)})

#access the data in the historical_data table 
conn = engine.connect()
metadata = sqlalchemy.MetaData()
histoo = sqlalchemy.Table('uploadfiles_historical_data', metadata, autoload=True, autoload_with=engine)
query = sqlalchemy.select([histoo])
resultproxy = conn.execute(query)
        
        
result_set = resultproxy.fetchall()

#update the historical table 
histo = histo2.head(0).to_sql('uploadfiles_histoo', engine, if_exists='replace')
cur = conn.cursor()
output = io.StringIO()
histo2.to_csv(output, sep='\t', header=False, encoding='utf8')
output.seek(0)
cur.copy_from(output,'uploadfiles_histoo')
conn.commit()

#update other tables (example)
itemmdb = df559.to_sql('dashboard_item', engine, if_exists='replace')

我真的很困惑,为这个问题绞尽脑汁了好一阵子,但似乎没有任何效果。希望有人能发现我哪里搞错了。

相关内容