У меня есть поток, пытающийся записать в базу данных, подобный следующему:
def thread(f, table, columns, conn):
cur = conn.cursor()
try:
cur.copy_from(f, table, columns)
except:
conn.rollback()
else:
conn.commit()
finally:
if cur is not None:
cur.close()
Я хотел бы иметь несколько потоков, которые делают это, но текущая реализация нуждается в блокировке вокруг нее, которая наносит ущерб цели иметь несколько потоков.
Есть ли способ сделать параллельное copy_from в psycopg2?