NiFi flow configuration

Примеры3B · Общие setup/версии · Фактические проверки (архив рабочего проекта)

Тип материала: учебное практическое упражнение. Выполненные и непроверенные шаги указаны отдельно.

Команды выполняются из examples/processing после общего setup; $labPython — interpreter venv. Runtime и documented expected result различаются.

Зависимости и версии

NiFi2.5.0/Java21, requests2.32.5; blueprint, REST builder. Blueprint — вход собственного builder, не нативный NiFi versioned-flow export.

Команды запуска

docker compose -f compose-runtimes.yaml --profile nifi up -d
$env:HANDBOOK_NIFI_PASSWORD = 'handbook-demo-only-password-2026'
& $labPython nifi/build_flow.py --ca path/to/trusted-local-nifi.pem

Тестовые данные

GenerateFlowFile выдаёт минимальный synthetic JSON, UpdateAttribute добавляет pipeline.stage/schema.version, LogAttribute показывает metadata. Это isolated configuration demo, не полноценный financial event schema/pipeline.

Ожидаемый результат

Builder проверяет /flow/about2.5.x, находит actual processor bundle/property descriptors, создаёт отдельный stopped group и connections с backpressure thresholds. Стартовать в UI после validation, либо --start при первичном создании. Existing same-name group не перезаписывается.

Ограничения и статус проверки

Сначала экспортировать/доверить сертификат локального NiFi и проверить hostname/SAN для URL; TLS validation не отключается. Old /docs/nifi-docs/rest-api URL оказался API1.28, поэтому2.5 endpoints сопоставлены с release-tag source и требуют runtime server validation. Создание/запуск реально NOT_RUN; только JSON/references/CLI проверены.

Полный журнал ограничений (архив рабочего проекта) хранит NOT_RUN и failed runtime attempts; их нельзя считать выполненными integration tests.