Работа с атрибутами

Все данные в Apache NiFi представлены абстракцией, называемой FlowFile. FlowFile состоит из двух основных частей: содержимого и атрибутов. Информация о FlowFile доступна при нажатии на иконку на странице List queue контекстного меню очереди потока.

Полный список основных атрибутов приведен в разделе FlowFile руководства разработчика NiFi.

Атрибуты FlowFile могут быть извлечены и использованы в качестве свойств процессоров при настройке потоков в интерфейсе NiFi.

Во время настройки процессоров на вкладке PROPERTIES отображаются свойства процессора. В столбце Property указано наименование параметра. В столбце Value указывается значение параметра. В зависимости от значений, разрешенных для свойства, в столбце Value пользователю предоставляется либо раскрывающийся список, из которого можно выбрать значение, либо текстовая область для ввода значения.

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

В верхней части окна для ввода значения указано, поддерживаются ли Expression Language (EL) и Parameters (PARAM) для ввода значения конкретного свойства данного процессора.

Параметры имеют следующие преимущества перед переменными:

Значения свойств в потоке, включая конфиденциальные свойства, можно параметризовать с помощью параметров. Параметры создаются в окне Parameter Contexts глобального меню интерфейса NiFi Server. Контексты параметров глобально определяются для каждого экземпляра NiFi. К контекстам параметров можно применять политики доступа, чтобы определить какие пользователи могут их создавать.

Любое свойство можно настроить для ссылки на параметр со следующими условиями:

Переменные создаются и настраиваются в пользовательском интерфейсе NiFi. Их можно использовать в любой области, поддерживающей Expression Language. Переменные нельзя использовать для конфиденциальных свойств. NiFi автоматически подбирает новые или измененные переменные. Переменные определяются на уровне группы процессов, поэтому политики доступа для просмотра и изменения переменных являются производными от политик доступа группы процессов.

При добавлении параметра, использующего язык выражений, важно понимать контекст, в котором будет оцениваться язык выражений. Выражение всегда оценивается в контексте службы процессора или контроллера, которая ссылается на параметр. Возьмем, к примеру, сценарий, в котором у параметра с именем Time значением является ${now()}. Результатом выражения является вызов для определения системного времени при его оценке. При добавлении параметра Time в качестве свойства системное время оценивается не при добавлении параметра, а при оценке выражения службой процессора или контроллера. То есть, если процессор имеет свойство, значение которого установлено на #{Time}, он будет работать точно так же, как если бы значение свойства было установлено на ${now()}. Каждый раз, когда на свойство ссылаются, оно создает другую отметку времени.

Кроме того, некоторые свойства не позволяют использовать язык выражений, в то время как другие разрешают использовать язык выражений, но не оценивают выражения по атрибутам FlowFile. Чтобы понять, как это работает, рассмотрим параметр с именем File, значение которого равно ${filename}. Затем рассмотрим три разных свойства, каждое из которых имеет свою область языка выражений и FlowFile с именем файла test.txt. Если для каждого из этих свойств задано значение #{File}, результирующее значение показано в следующей таблице.