Как направить поток в nifi на основе его URL-заголовка?

Question

Как направить поток на основе URL-адреса (если у него есть путь к файлу на один процессор и если он содержит имя пользователя и пароль, он направляет на другой процессор).Пожалуйста, укажите поток процессора, который будет использоваться.Спасибо.

Answer 1

С помощью языка выражений NiFi и RouteOnAttribute вы можете направлять входящие FlowFiles на разные процессоры.

Например,Предположим, что FlowFiles, сгенерированный исходным процессором, имеет присвоенный ему атрибут с именем url, и этот атрибут может иметь любой из следующих форматов значений:

• file: /// path / to / some/ file
• http://somesite.xyz/path/to/some/resource

Для приведенного выше случая вы можете добавить два динамических свойства к RouteOnAttribute следующим образом:

• file : ${url:startsWith("file:///")}
• websource : ${url:startsWith("http://")}

Затем подключите отношения file и websource к различным процессорам.Следующие ссылки указывают на подробные руководства и примеры использования:

• https://community.hortonworks.com/questions/54811/redirecting-flow-based-on-certain-condition-nifi.html
• https://docs.hortonworks.com/HDPDocuments/HDF3/HDF-3.1.1/bk_getting-started-with-apache-nifi/content/routing-on-attributes.html