Python ThreadPoolExecutor и psycopg2 - процесс завершается до завершения - PullRequest
0 голосов
/ 08 мая 2020

В настоящее время я создаю приложение, которое использует ThreadPoolExecutor, например:

with ThreadPoolExecutor(max_workers = 6) as executor:
   for ns in newssource:
      executor.submit(myFunc, ns)

В myFun c я делаю три вещи:

  1. Скачать TXT
  2. Проанализируйте файл TXT и сохраните его локально.
  3. Снова откройте файл TXT и сохраните дополнительную информацию в Postgres (через psycopg2).

процесс всегда заканчивается до завершения №3 - я думаю, что ошибки подключения отсутствуют, но я не вижу сообщений об ошибках. Процесс просто заканчивается ... Даже когда я создаю соединение Postgres и курсор внутри третьей функции, на самом последнем этапе.

Кажется, я не могу найти документацию по этому поводу. Будем очень признательны за любой совет / помощь.

...