如何用nipyapi编写控制器服务？

Question

# -*- 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)

我写这篇文章是为了使过程自动化，但我不知道为什么控制器服务不能工作

Answer 1

您不能用Python编写NiFi组件。所有组件都必须用JVM语言(Java、Kotlin、Groovy、Scala等)开发。另外，Nipyapi是用来帮助您编写自己的管理函数和类似于NiFi的东西的客户端API。