要通过nipyapi客户端启动Apache NiFi控制器,可能需要遵循以下解决方法:
pip install nipyapi
import nipyapi
nipyapi.config.nifi_config.host = 'http://localhost:8080/nifi-api' # 设置NiFi控制器的URL
# 检查NiFi控制器是否可访问
nipyapi.utils.set_endpoint('nifi')
status = nipyapi.utils.site2status()
print(status)
如果输出为{'controller': {'status': 'RUNNING'}}
,表示NiFi控制器正在运行。
import nipyapi
nipyapi.config.nifi_config.host = 'http://localhost:8080/nifi-api' # 设置NiFi控制器的URL
# 使用nipyapi客户端启动NiFi控制器
controller = nipyapi.canvas.get_root_pg_id()
nipyapi.canvas.schedule_controller(controller, True) # 第二个参数为True表示启动控制器
# 检查NiFi控制器的状态
status = nipyapi.canvas.get_controller_status(controller)
print(status)
希望以上解决方法能够帮助您解决问题!