Я несколько новичок в асинхронном и многопоточном программировании (и Python в целом), и я пытаюсь построить асинхронный конвейер данных, который использует многопоточность для обработки отдельных потоков.
По сути, я быхотелось бы построить что-то вроде этого: http://skipperkongen.dk/2016/09/09/easy-parallel-http-requests-with-python-and-asyncio/ но с открытым (вечно работающим) асинхронным потоком данных для каждого вызова API.Данные каждого вызова будут помещены в коллекцию MongoDB.
Все, что я до сих пор пробовал, похоже, не работает по разным причинам.Есть ли простой способ сделать это?Я что-то упускаю?