Я бы хотел отслеживать состояние запущенного потока MiNiFi, особенно получить список процессоров и количество потоковых файлов в очереди для каждого процессора. Я пытаюсь использовать FlowStatus Script Query , например ::
$ ./minifi.sh flowStatus systemdiagnostics:processorstats
{"controllerServiceStatusList":null,"processorStatusList":null,"connectionStatusList":null,"remoteProcessGroupStatusList":null,"instanceStatus":null,"systemDiagnosticsStatus":{"garbageCollectionStatusList":null,"heapStatus":null,"contentRepositoryUsageList":null,"flowfileRepositoryUsage":null,"processorStatus":{"loadAverage":1.99,"availableProcessors":2}},"reportingTaskStatusList":null,"errorsGeneratingReport":[]}
$ ./minifi.sh flowStatus processor:all:health,stats,bulletins
{"controllerServiceStatusList":null,"processorStatusList":[],"connectionStatusList":null,"remoteProcessGroupStatusList":null,"instanceStatus":null,"systemDiagnosticsStatus":null,"reportingTaskStatusList":null,"errorsGeneratingReport":[]}
$ /minifi.sh flowStatus processor:MyProcessorName:health,stats,bulletins
{"controllerServiceStatusList":null,"processorStatusList":[],"connectionStatusList":null,"remoteProcessGroupStatusList":null,"instanceStatus":null,"systemDiagnosticsStatus":null,"reportingTaskStatusList":null,"errorsGeneratingReport":["Unable to get status for request 'processor:MyProcessorName:health,stats,bulletins' due to:org.apache.nifi.minifi.status.StatusRequestException: No processor with key MyProcessorName to report status on"]}
но я получаю только нули. Что я должен сделать, чтобы иметь возможность получать данные, которые я хочу (включить некоторые опции в конфигурации?)? Возможно ли использовать запросы flowStatus? Мой работающий поток содержит несколько процессоров, так почему systemdiagnostics показывает только два availableProcessors и почему я не могу использовать команду flowStatus processor для получения каких-либо данных процессора?
К сожалению, документация по NiFi / MiNiFi очень скудная, поэтому я даже не уверен, смогу ли я получить данные о процессорах (количество элементов в очереди и список процессоров) таким образом. Если нет, может быть, вы знаете другой способ сделать это?