​Подключение процессора

1. Просмотрите FlowFile в очереди.

После отдельного запуска процессора GenerateFlowFile вы можете заметить, что в соответствующей очереди соединения есть данные. Щелкните правой кнопкой мыши «Список очереди» в соединении, чтобы просмотреть информацию о FlowFile в очереди:

2. Просмотр значений настраиваемых атрибутов FlowFile.

Вы также можете просмотреть информацию о настроенном атрибуте в атрибуте FlowFile в очереди. Например, установите пользовательский атрибут «mykey» в процессоре «GenerateFlowFile» и установите соответствующее значение «myvalue»:

Запустите «GenerateFlowFile» отдельно, чтобы получить некоторые данные, и просмотрите атрибуты FlowFile в очереди следующим образом:

3. Конфигурация подключения

Для подключенных подключений вы можете настроить дополнительную информацию через «Настроить»:

Нажмите «НАСТРОЙКИ» на всплывающей странице:

Срок действия данных FlowFile истекает:

Установка времени истечения срока действия FlowFile может привести к удалению данных в очереди, которые не могут быть обработаны вовремя. Значение по умолчанию — 0. Срок действия данных никогда не истекает. Когда установлен срок действия, на соединении Connect можно увидеть небольшой значок часов.

Противодавление «Бэк Пресс»:

NiFi предоставляет два механизма настройки противодавления. Механизм противодавления позволяет определить, сколько данных находится в очереди. Когда это количество будет достигнуто, исходный процессор больше не будет планировать данные, чтобы предотвратить переполнение данных. «Порог объекта противодавления» определяет количество данных в очереди для запуска механизма противодавления. «Порог размера данных противодавления» определяет размер данных в очереди, которая запускает механизм противодавления. После настройки механизма противодавления на соединении Connection отобразится индикатор выполнения.

«Стратегии балансировки нагрузки» балансировка нагрузки:

Варианты политики балансировки нагрузки следующие:

• Не балансировать нагрузку: не балансировать данные в кластере, значение по умолчанию.
• Разделение по атрибуту: определите, на какой узел отправляются данные, на основе значения атрибута, указанного пользователем. Данные с одинаковым значением атрибута будут отправлены на один и тот же узел. Если узел, на который отправляются данные, отключен, данные не будут отправляться на другие узлы и будут отправлены автоматически при повторном подключении узла к кластеру.
• Круговой перебор: данные распределяются в режиме опроса. Когда узел отключается, он автоматически опрашивается и отправляется на другие узлы.
• Один узел: все данные отправляются на один узел.,Не Конфигурация какого узла. Когда узел отключен от кластера,Данные не будут отправляться на другие узлы,пока узел снова не станет доступен.

После настройки балансировки нагрузки вы можете увидеть значок:

«Сжатие балансировки нагрузки» — сжатие данных балансировки нагрузки:

После настройки стратегии балансировки нагрузки вы можете указать, следует ли сжимать данные, передаваемые между узлами. Доступны следующие варианты:

• Не сжимать: Не сжимать.
• Сжимать только атрибуты: сжимать только атрибуты.
• Сжатие атрибутов и содержимого. Сжатие атрибутов и содержимого.

Приоритет «Выбор приоритета»:

Вы можете указать приоритет данных в очереди, чтобы обрабатываться данные с более высоким приоритетом. Приоритеты можно использовать, перетащив их из «Доступные приоритезаторы» на вкладку «Выбранные приоритезаторы». Можно выбрать несколько приоритетов, и данные будут отсортированы в соответствии с выбранным приоритетом. Варианты приоритета следующие:

• FirstInFirstOutPrioritizer: Учитывая два FlowFile, сначала обрабатываются FlowFiles, которые первыми поступают в соединение.
• NewestFlowFileFirstPrioritizer: учитывая два FlowFile, последний FlowFile в потоке данных будет обработан первым.
• OldestFlowFileFirstPrioritizer: дано два FlowFile.,Самые старые в потоке данных будут обработаны первыми.FlowFiles。Это схема по умолчанию, используемая, если приоритет не выбран.
• PriorityAttributePrioritizer: учитывая два FlowFile, будет извлечен атрибут с именем Priority. Первым будет обработано сообщение с наименьшим значением приоритета. Рекомендуется задать числовое значение. Если это строка, она будет отсортирована по коду ascii.

4. Просмотр информации о подключениях

Посмотреть информацию о подключении можно в разделе «Подключение» главного меню «Сводка»:

5. Настройте изогнутое соединение

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