Nifi вызвать http, как получить значение и добавить в качестве заголовка во время публикации данных - PullRequest
0 голосов
/ 22 января 2020

У меня есть поток NiFi, который должен отправить данные на какой-то другой сервер, а перед отправкой ему нужно получить значение с моего внутреннего сервера или распределенного кэша Nifi.

И добавьте это значение в заголовок Http перед публикацией данных, а также обновите, когда получите конкретный код ошибки 401.

Ниже приведен поток, который я пытаюсь, все зеленые процессоры, которые я мог сделать, но застрял при получении значения и добавлении в invoke http заголовок. Какие еще процессы я могу заставить нас добиться этого.

MyNififlow

1 Ответ

0 голосов
/ 22 января 2020

https://nifi.apache.org/docs/nifi-docs/components/org.apache.nifi/nifi-standard-nar/1.9.0/org.apache.nifi.processors.standard.InvokeHTTP/

в соответствии с документацией по коду http 401 InvikeHTTP направляет файл в отношение No Retry.

также файл потока должен содержать некоторые атрибуты ответа включая invokehttp.status.code

, поэтому вы можете использовать процессор RouteOnAttribute для перенаправления потокового файла на ваш внешний процессор токенов, только когда invokehttp.status.code=401.

...