Notify

Описание

Кэширует идентификатор сигнала выпуска в распределенном кэше, возможно, вместе с атрибутами FlowFile. Любые файлы потока, удерживаемые в соответствующем процессе Wait, будут выпущены после обнаружения этого сигнала в кэше.

Теги

map, cache, notify, distributed, signal, release

Свойства

Название	Описание
Release Signal Identifier	значение или результат выполнения оператора языка выражений атрибутов, который будет сопоставлен с файлом FlowFile для определения ключа кэша сигнала выпуска. Поддерживает язык выражений: true (будет оцениваться с использованием атрибутов файла потока и переменных среды)
Signal Counter Name	значение или результат выполнения оператора языка выражений атрибутов, который будет сопоставлен с файлом FlowFile для определения имени счетчика сигнала. Имя счётчика сигналов полезно, когда соответствующему процессору ожидания необходимо знать количество событий разных типов, таких как успешное выполнение или сбой, или имена источников данных назначения и т. д. Поддерживает язык выражений: true (будет оцениваться с использованием атрибутов файла потока и переменных среды)
Signal Counter Delta	Значение или результаты выражения на языке атрибутов, которые будут сопоставлены с файлом потока для определения дельты счётчика сигналов. Укажите, насколько должен увеличиться счётчик. Например, если несколько сигнальных событий обрабатываются в восходящем потоке пакетно-ориентированным способом, с помощью этого свойства можно одновременно уведомлять о количестве обработанных событий. Ноль (0) имеет особое значение, он возвращает значение целевого значения обратно к 0, что особенно полезно при использовании в режиме ожидания RELEASABLE_FLOWFILE_COUNT = Ноль (0), чтобы обеспечить управление потоком типа "открытие-закрытие шлюза". Единица (1) может открыть соответствующий ожидающий процессор, а ноль (0) может отменить его, как если бы он закрывал ворота. Поддерживает язык выражений: true (будет оцениваться с использованием атрибутов файла потока и переменных среды)
Signal Buffer Count	Укажите максимальное количество входящих файлов потока, которые могут быть буферизованы до тех пор, пока сигналы не будут отправлены в службу кэширования. Чем больше буфер, тем выше производительность, так как это сокращает количество взаимодействий со службой кэширования за счет группировки сигналов по идентификатору сигнала, когда несколько входящих файлов потока имеют один и тот же идентификатор сигнала.
Distributed Cache Service	Служба контроллера, которая используется для кэширования сигналов освобождения с целью освобождения файлов, находящихся в очереди на соответствующем процессоре ожидания
Attribute Cache Regex	Любые атрибуты, имена которых соответствуют этому регулярному выражению, будут сохранены в распределенном кэше и скопированы в любые файлы потока, выпущенные соответствующим процессором ожидания. Обратите внимание, что атрибут uuid не будет кэшироваться независимо от этого значения. Если значение отсутствует, атрибуты не будут кэшироваться.

Взаимосвязи

• success: Все FlowFiles, в которых сигнал выпуска был успешно сохранен в кэше, будут направлены в эту связь
• failure: Если кэш недоступен или если идентификатор сигнала выпуска равен нулю или пуст, файлы Flow будут перенаправлены в это отношение