无法使用nipyapi执行对nifi的任何调用。

Question

我正在尝试使用nipyapi，但是我运行的任何函数都会给我一个错误。

下面是配置的代码：

import nipyapi
nipyapi.config.nifi_config.host = 'https://localhost:8443/nifi-api'
nipyapi.config.nifi_config.username = 'admin'
nipyapi.config.nifi_config.password = 'qwertyadmin1'
nipyapi.config.registry_config.host = 'https://localhost:18080/nifi-registry'

产生错误的代码：

root = nipyapi.canvas.get_root_pg_id()

我收到了一堆警告，然后是错误，下面是一个警告示例：

2022-03-24 23:28:16,876 WARNING Retrying (Retry(total=2, connect=None, read=None, redirect=None, status=None)) after connection broken by 'ProtocolError('Connection aborted.', BadStatusLine('\x15\x03\x03\x00\x02\x02P'))': /nifi-api/flow/process-groups/root/status
2022-03-24 23:28:16,876 WARNING Retrying (Retry(total=2, connect=None, read=None, redirect=None, status=None)) after connection broken by 'ProtocolError('Connection aborted.', BadStatusLine('\x15\x03\x03\x00\x02\x02P'))': /nifi-api/flow/process-groups/root/status

错误：

MaxRetryError: HTTPConnectionPool(host='localhost', port=8443): Max retries exceeded with url: /nifi-api/flow/process-groups/root/status (Caused by ProtocolError('Connection aborted.', BadStatusLine('\x15\x03\x03\x00\x02\x02P')))

我正在尝试创建一个用户友好的界面，允许不了解nifi的用户根据他们的需求构建动态管道。我也很想听听你的想法，不管是否可以用尼皮亚皮。不过我还是很乐观的。

Answer 1

我也有同样的问题。尝试使用来自https://chamila.dev/blog/2021-07-18_ci-cd-for-apache-nifi-02-automation-with-nipyapi/的连接，它对我有效。