【发布时间】:2018-08-01 05:57:01
【问题描述】:
【问题讨论】:
标签: rest api apache-nifi
【问题讨论】:
标签: rest api apache-nifi
您可以向/process-groups/{id}/variable-registry 发出GET 请求,其中{id} 是您感兴趣的进程组ID。您将收到类似于以下内容的JSON 响应:
{
"processGroupRevision": {…},
"variableRegistry": {
"variables": [{
"variable": {
"name": "value",
"value": "value",
"processGroupId": "value",
"affectedComponents": [{…}]
},
"canWrite": true
}],
"processGroupId": "value"
},
"disconnectedNodeAcknowledged": true
}
所有这些都记录在进程组下的Apache NiFi REST API page 中。您还可以使用浏览器的开发人员工具面板检查 NiFi UI 在您与 UI 交互时向服务器发出的请求,以观察进行了哪些调用。
【讨论】:
您还可以使用Community NiFi Python Client: NiPyApi 轻松获取这些内容
Python 3.6.5 (v3.6.5:f59c0932b4, Mar 28 2018, 03:03:55)
[GCC 4.2.1 (Apple Inc. build 5666) (dot 3)] on darwin
>> import nipyapi
# Get your ProcessGroup object
>> pg = nipyapi.canvas.get_process_group('myProcessGroup')
# Get the VariableRegistry for that ProcessGroup
>> vars = nipyapi.canvas.get_variable_registry(pg)
>> vars.variable_registry.variables
[{'can_write': True,
'variable': {'affected_components': [],
'name': 'foo',
'process_group_id': 'fb88a5cb-0164-1000-d5ce-d89ad0e93df2',
'value': 'bar'}}]
【讨论】: