POSTGRESQL и приложение Django: не удалось получить данные от клиента: соединение сброшено одноранговым узлом

Question

Я запускаю приложение django с postgresql, nginx и gunicorn. У меня есть скрипт, в котором данные извлекаются из одной таблицы в БД, изменяются, а затем должны заменить существующие данные в этой таблице. В том же скрипте также обновляются несколько таблиц.

При запуске скрипта всегда происходит так, 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')

Я действительно запутался и уже некоторое время бьюсь головой над этой проблемой, и ничего не получается. Надеюсь, кто-нибудь сможет увидеть, где я ошибаюсь.