как выполнить параллельный psycopg2 copy_from? - PullRequest
Новая
       8

как выполнить параллельный psycopg2 copy_from?

0 голосов
/ 28 февраля 2020

У меня есть поток, пытающийся записать в базу данных, подобный следующему: 

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?

...