Nifi 停止 Shell 的所有处理器

Question

出于管理目的，我正在寻找 pause/stopp shell 上所有 Nifi 进程的选项或命令。有没有办法做到这一点，还是我误解了背后的概念。

Answer 1

如果你习惯使用Python，那么我的项目NiPyApi支持这个：

from nipyapi import config, canvas
_ = [canvas.schedule_processor(li, 'STOPPED') for li in canvas.list_all_processors()]
# Stops all processors anywhere in NiFi

您可以在 Github 上克隆它：https://github.com/Chaffelson/nipyapi
这些特定的调用是新的，很快就会发布到 Pypi。

Answer 2

您可以使用 curl 发送一个 api 请求，告诉它停止主 canvas PG

curl --tlsv1.2 -i -H 'Content-Type: application/json' -XPUT -d '{"id":"PG ID","state":"STOPPED"}'  http://nifi-server-ip:port/nifi-api/flow/process-groups/PG ID

这将停止主 canvas 上的所有 PG/Processors。

获取PG Id去主NiFicanvas并且是Operate dashboard下的long id

Nifi 停止 Shell 的所有处理器

Nifi Stop all Processors from Shell

apache-nifi