можно ли получать подробную информацию от веб-сервиса каждые 5 минут в nifi - PullRequest
1 голос
/ 27 мая 2020

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

заранее СПАСИБО full data flow for your reference

detectDuplicate processor config RedisConnectionPoolService config (this will open when i click on arrow sign in side of RedisDistributedMapCacheClientService) i have mention my web app site address with port number in connection string is it write??

1 Ответ

1 голос
/ 28 мая 2020

Вы можете использовать DetectDuplicate, чтобы определить, является ли входящий потоковый файл точной копией недавно просмотренного потокового файла (как определено значением, вычисленным из атрибутов потокового файла), который использует кэш распределенного состояния. Этот кеш является подключаемым и может быть предоставлен собственной реализацией, HBase или Redis.

...