如何解决如何在nipyapi中编写控制器服务?
# -*- coding: utf-8 -*-
"""
Created on Mon Oct 12 16:42:29 2020
@author: nitin.jaiswal
"""
import nipyapi
import requests
import json
nipyapi.config.nifi_config.host = 'http://localhost:8080/nifi/'
nipyapi.canvas.get_controller('distributedMapCacheClientService',identifier_type='name',bool_response=False)
#Enable Controler
headers = {'Content-Type': 'application/json'}
url = 'http://localhost:8080/nifi-api/flow/process-groups/'+nipyapi.canvas.get_root_pg_id()+'/controller-services'
r = requests.get(url)
reponse = json.loads(r.text)
controllerId = reponse['controllerServices'][0]['id']
nipyapi.canvas.schedule_controller(controllerId,'True',refresh=False)
我为实现过程自动化而写了这篇文章,但我不知道为什么控制器服务不起作用
解决方法
您不能用Python编写NiFi组件。必须使用JVM语言(Java,Kotlin,Groovy,Scala等)开发所有组件。此外,Nipyapi旨在成为客户端API,可帮助您针对NiFi编写自己的管理功能和类似功能。
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。