В будущем проекте сразу хочу заложить нужную архитектуру.
Две (пока что) ноды (воркеры) будут обрабатывать входящие сообщения и писать их в базу (монгу). Воркеры хочу поставить на разные VPS, ибо масштабирование.
Центральная (третья) нода должна брать все эти обработанные сообщения и дальше отправлять их в работу.
Нужно придумать, как центральной ноде узнавать, что сообщение обработано и записано в базу.
Вариант 1 - использовать Redis - чтобы после обработки воркеры кидали в редис айдишник сообщения в монге. А центральная нода будет подписана на канал в редисе.
Вариант 2 - Change Streams (решение подсказал ChatGPT).

Если моя механика не верная, либо есть более легкий путь - предложите.

В противном случае - нужно на (пока что) две VPS на Ubuntu поставить монгу, редис и подружить их.
На старте, конечно, центральная нода будет стоять на одном из воркеров, но в будущем уедет отдельно.