Я не эксперт по многопоточности / asyncio, но, может быть, было бы проще создать экземпляр Kafka и получить фрагмент кода, который прослушивал бы тему Kafka? К этой теме вы можете добавить изображения или пути к изображениям, если вы уже храните их локально. Более того, используя consumer-groups
, вы получите бесплатную систему балансировки нагрузки, поскольку она является частью Kafka.