DebugFlow
Описание
Процессор DebugFlow помогает тестировать и отлаживать структуру FlowFile, позволяя явно инициировать различные ответы в ответ на получение файла потока или события таймера без файла, если используется планирование на основе таймера или cron. Он может принудительно вызывать необходимые ответы для проверки различных режимов отказа, которые могут возникнуть при работе процессора.
Теги
test, debug, processor, utility, flow, FlowFile
Свойства
| Название | Описание |
|---|---|
| FlowFile Success Iterations | Количество потоковых файлов, которые нужно перенаправить в отношение успеха. |
| FlowFile Failure Iterations | Количество потоковых файлов, которые нужно перенаправить в отношение сбоя. |
| FlowFile Rollback Iterations | Количество файлов Flow для отката (без штрафа). |
| FlowFile Rollback Yield Iterations | Количество файлов Flow для отката и приостановки. |
| FlowFile Rollback Penalty Iterations | Количество файлов Flow для отката с штрафом. |
| FlowFile Exception Iterations | Количество файлов Flow для создания исключения. |
| FlowFile Exception Class | Класс исключения, которое будет сгенерировано (должен расширять java.lang.RuntimeException). |
| No FlowFile Skip Iterations | Количество раз для пропуска onTrigger, если нет файла Flow. |
| No FlowFile Exception Iterations | Количество раз, когда генерируется исключение NPE при отсутствии FlowFile. |
| No FlowFile Yield Iterations | Количество раз, когда генерируется исключение при отсутствии FlowFile. |
| No FlowFile Exception Class | Класс исключения, который будет сгенерирован при отсутствии файла Flow (должен расширять java.lang.RuntimeException). |
| Write Iterations | Количество раз, когда выполняется запись в FlowFile |
| Content Size | Количество байт, которые записываются при каждой записи в FlowFile |
| @OnScheduled Pause Time | Указывает, как долго процессор должен находиться в спящем режиме в методе @OnScheduled, чтобы процессор мог запускаться в течение длительного времени |
| Fail When @OnScheduled called | Указывает, должен ли процессор генерировать исключение при вызове методов, аннотированных @OnScheduled |
| @OnUnscheduled Pause Time | Указывает, как долго процессор должен находиться в спящем режиме в методе @OnUnscheduled, чтобы процессор мог долго отвечать на запросы пользователя, когда тот нажимает кнопку «Стоп» |
| Fail When @OnUnscheduled called | Указывает, должен ли процессор генерировать исключение при вызове методов, помеченных @OnUnscheduled |
| @OnStopped Pause Time | Указывает, как долго процессор должен находиться в спящем режиме в методе @OnStopped, чтобы процессор мог долго завершать работу Поддерживает язык выражений: true (будет оцениваться только с использованием переменных среды) |
| Fail When @OnStopped called | Указывает, должен ли процессор генерировать исключение при вызове методов, аннотированных @OnStopped |
| OnTrigger Pause Time | Указывает, как долго процессор должен находиться в спящем режиме в методе onTrigger(), чтобы процессор мог выполнять свою задачу в течение длительного времени. |
| CustomValidate Pause Time | Указывает, как долго процессор должен находиться в спящем режиме в методе customValidate() |
| Ignore Interrupts When Paused | If the Processor's thread(s) are sleeping (due to one of the "Pause Time" properties above), and the thread is interrupted, this indicates whether the Processor should ignore the interrupt and continue sleeping or if it should allow itself to be interrupted. |
Взаимосвязи
- success: Файлы Flow успешно обработаны.
- failure: Файлы Flow не удалось обработать.