微信公众号搜"智元新知"关注
微信扫一扫可直接关注哦!

如何在nipyapi中编写控制器服务?

如何解决如何在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 举报,一经查实,本站将立刻删除。