В настоящее время я создаю приложение, которое использует ThreadPoolExecutor, например:
with ThreadPoolExecutor(max_workers = 6) as executor:
for ns in newssource:
executor.submit(myFunc, ns)
В myFun c я делаю три вещи:
- Скачать TXT
- Проанализируйте файл TXT и сохраните его локально.
- Снова откройте файл TXT и сохраните дополнительную информацию в Postgres (через psycopg2).
процесс всегда заканчивается до завершения №3 - я думаю, что ошибки подключения отсутствуют, но я не вижу сообщений об ошибках. Процесс просто заканчивается ... Даже когда я создаю соединение Postgres и курсор внутри третьей функции, на самом последнем этапе.
Кажется, я не могу найти документацию по этому поводу. Будем очень признательны за любой совет / помощь.