Нифи ПутМонго пример

Question

Я изо всех сил пытаюсь найти примеры, которые показывают, как использовать функциональность upsert (или обновить в этом отношении) в процессоре putMongo NiFi.

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

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

То, что я хотел бы сделать, похоже на слияние SQL, когда вставка может следовать по одному пути, а обновление может следовать по другому, но я не думаю, что функциональность это позволяет.

Спасибо

Answer 1

извлечение одного значения из документа

Параметр update query key должен выполнить эту работу за вас.По умолчанию он использует _id, но вы можете указать другой ключ для поиска документа для обновления.Кроме того, вы можете указать запрос, используя параметр конфигурации update query.