Блог

Я пытаюсь использовать реализацию кэша для NIFI, и я застрял в той части, где мне нужно хранить и извлекать кэшированные данные.

Выше я приложил поток для того, что я делаю. Итак, я отправляю JSON из generateflowfile и пытаюсь прочитать его в fetchdistributedmapcache на основе параметров, скажем, «SiteID» и «арендатор».

затем я нажимаю rest API, используя InvokeHTTP, основанный на значениях атрибутов SiteID и tenant, и извлекаю ResponseBody, у которого есть значение «Код арендатора», которое необходимо добавить в качестве значения для ключа «${SiteID}_${tenant}», который присутствует в кэше. В моем описании обновления я выбираю значение, как указано ниже.

Теперь этот атрибут tenantName должен быть сохранен в кэше с ключом «${SiteID}_${tenant}», когда он переходит в putdistributedmapcache. Я даю конфигурацию в putdistributedmapcache только с ключом, как показано ниже.

Итак, как атрибут tenantName сохраняется в кэше? И как мы можем получить его, когда мы снова отправляем те же данные Json из файла generateflow, если мы где-то кэшировали и сохранили их?

Нужны некоторые данные для решения этой проблемы.

Спасибо.