我正在使用 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')
我真的很困惑,为这个问题绞尽脑汁了好一阵子,但似乎没有任何效果。希望有人能发现我哪里搞错了。