Я пытаюсь распечатать содержимое из 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)
Не могу понять, что здесь не так, почему бы не получить распечатку в консоли.