Не получается вывод при многопроцессорной обработке с MongoDB - PullRequest
0 голосов
/ 11 июля 2020

Я пытаюсь распечатать содержимое из MongoDB, используя многопоточность (поскольку количество документов не превышает 5000)

import concurrent.futures
from pymongo import MongoClient


client = MongoClient(host, port)
db = client.database_name
collection = db['table_name']
file_names = collection.find().distinct('file_name')



def thread_main(name_file):
    client = MongoClient(host, port)
    db = client.database_name
    collection = db['table_name']
    for cursor in collection.find({'file_name': name_file}):
            trans_list = []
            for p in cursor['paragraphs']:
                    trans_agent_list.append(p['trans'])
            conversation = " ".join(trans_list)
            print('conversation: ', conversation)


with concurrent.futures.ThreadPoolExecutor() as executor:
    executor.map(thread_main, file_names)

Не могу понять, что здесь не так, почему бы не получить распечатку в консоли.

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...