Блог

Я отправляю идентификатор клиента в MongoDB с помощью Nifi и хочу запросить MongoDB для этого клиента.

Как мне извлечь данные из другого процессора, запросить db и отправить их следующему процессору?

В процессоре GetMongo вы можете указать запрос. Если вы оставите это поле пустым, процессор будет искать запрос во входном потоковом файле, поэтому вы должны преобразовать свои сообщения Kafka в действительные запросы MongoDB в формате JSON.

Кроме того, вы можете напрямую использовать MongoDBLookupService. Он автоматически преобразует пары ключ-значение во входящей записи в действительные запросы MongoDB.