查找 NiFi 远程进程组通过其 Rest API 启用或禁用

Vas*_*ian 1 api apache-nifi

使用NiFi REST API,

  1. 如何查找远程进程组是启用还是禁用?
  2. NiFi中传输(RemoteProcessGroupDTO)和传输状态(RemoteProcessGroupStatusDTO)之间的区别?

端点:https://nifihost:8080/nifi-api/process-groups/{id}/remote-process-groups

Tah*_*qvi 5

1.如何查看远程进程组是启用还是禁用?

\n

您需要使用不同的端点来确定 RPG 是否启用

\n
https://nifihost:8080/nifi-api/remote-process-groups/{id}\n
Run Code Online (Sandbox Code Playgroud)\n

您可以解析 json 并检查组件对象中传输的值或状态对象中的 TransmissionStatus

\n

2.NiFi中的transmission(RemoteProcessGroupDTO)和transmissionStatus(RemoteProcessGroupStatusDTO)有什么区别?

\n

两者都显示 RPG 传输的状态是布尔值,transmissionStatus 可以有字符串值

\n
{\n    "revision": {\xe2\x80\xa6},\n    "id": "value",\n    "uri": "value",\n    "position": {\xe2\x80\xa6},\n    "permissions": {\xe2\x80\xa6},\n    "bulletins": [{\xe2\x80\xa6}],\n    "disconnectedNodeAcknowledged": true,\n    "component": {\n        "id": "value",\n        "versionedComponentId": "value",\n        "parentGroupId": "value",\n        "position": {\xe2\x80\xa6},\n        "targetUri": "value",\n        "targetUris": "value",\n        "targetSecure": true,\n        "name": "value",\n        "comments": "value",\n        "communicationsTimeout": "value",\n        "yieldDuration": "value",\n        "transportProtocol": "value",\n        "localNetworkInterface": "value",\n        "proxyHost": "value",\n        "proxyPort": 0,\n        "proxyUser": "value",\n        "proxyPassword": "value",\n        "authorizationIssues": ["value"],\n        "validationErrors": ["value"],\n        "transmitting": true,\n        "inputPortCount": 0,\n        "outputPortCount": 0,\n        "activeRemoteInputPortCount": 0,\n        "inactiveRemoteInputPortCount": 0,\n        "activeRemoteOutputPortCount": 0,\n        "inactiveRemoteOutputPortCount": 0,\n        "flowRefreshed": "value",\n        "contents": {\xe2\x80\xa6}\n    },\n    "status": {\n        "groupId": "value",\n        "id": "value",\n        "name": "value",\n        "targetUri": "value",\n        "transmissionStatus": "value",\n        "statsLastRefreshed": "value",\n        "validationStatus": "value",\n        "aggregateSnapshot": {\xe2\x80\xa6},\n        "nodeSnapshots": [{\xe2\x80\xa6}]\n    },\n    "inputPortCount": 0,\n    "outputPortCount": 0,\n    "operatePermissions": {\xe2\x80\xa6}\n}\n
Run Code Online (Sandbox Code Playgroud)\n

参考:-https://nifi.apache.org/docs/nifi-docs/rest-api/index.html

\n