Цель: - Искать вариант использования механизма получения SNMP-ловушек в качестве настраиваемого процессора в Apache Nifi.
Посмотрел ссылки на то, как создать настраиваемый процессор в Nifi ( Apache docs и видео на YouTube ), исходный код Nifi GetSNMP (включая AbstractSNMPProcessor), ListenSysLog, GetFile и т. д.
Получили простой ( java-код ) приемник SNMPTrap, использующийБиблиотека SNMP4J и может прослушивать определенный адрес с портом на основе UDP или TCP.И тогда в случае Trap (может быть смоделирован простым Java-кодом из библиотеки SNMP4J) можно распечатать детали PDU.
Теперь, когда пытаюсь написать этот код в Nifi как пользовательский процессор, не уверен, куда поместить моймеханизм прослушивания и затем обработка фактической части PDUВид поражен здесь.
Подробнее: -
Процессор GetSNMP говорит о конкретном OID и, используя его, у нас есть варианты стратегий GET или Walk для получения информации.Здесь (для моей цели) ищем вариант, где сервер Nifi работает и хочет, чтобы ловушки SNMP выбирались из конкретной системы, где работает Nifi.И для моей цели - не получить контекст для расширения кода GetSNMP.
В ListenSyslogProcessor был механизм блокировки очереди.И из этого я не мог извлечь для прослушивания по IP-адресу для ловушек и как именно использовать ProcessContext, параметр ProcessSession метода onTrigger для пользовательского процессора Nifi.
Любые входные данные приветствуются ...