Как следует из заголовка, в настоящее время мой бэкэнд социальной сети находится в NodeJ с MongoDB, и я надеюсь добавить celery + RabbitMQ с Postgres / Cassandra для канала активности / уведомлений в качестве очереди сообщений на основе разветвления. Правильно ли я подхожу к своей проблеме или мне нужно искать что-то вроде Кафки или еще чего-нибудь?
Я также сомневаюсь, где мой брокер должен выглядеть так, будто мой бэкэнд обслуживает REST API для разных клиентов.
Предположим, что приложение имеет домашнюю ленту, которая обновляется, когда кто-то публикует какую-то запись. Поскольку сообщения сохраняются в любой базе данных, как они ставятся в очередь или добавляются в брокер сообщений для использования приложением, и как они могут выполнять больше операций над этим сообщением (у сообщения есть функция «Общие акции и комментарии»).
Нужна некоторая информация о том, как решить проблему с подачей в реальном времени, например, Facebook, Instagram или Reddit и т. Д.