NiFi:我将使用哪个处理器连接到需要3个凭证元素的第三方API？

Question

配置GetHTTP处理器的选项看起来像是用于连接第三方API.我需要发送用户名(可用),密码(可用)和表示数据库名称的第3个字符串值.当响应(json)返回时,它将包含一个会话标识符,我将在以后需要用于任何其他API(javascript)调用.这个处理器有一个"新属性"选项,我认为我可能会将其用于数据库字符串,但是,它似乎正在寻找特定类型的属性.我得到的警告消息指出:对'mydatabasename'验证的'database'无效,因为'database'不是受支持的属性.有什么建议？此外,一旦响应确实返回,我将如何保留所有后续API调用的会话ID？

Answer 1

GetHTTP接受动态属性,这些属性将作为HTTP请求标头传递给服务器.添加database在NiFi 1.2.0中调用的动态属性我没有任何问题,但我相信这是一个相对较新的添加,可能在早期版本中不可用.InvokeHTTP可能是另一种选择.

重用会话ID需要从响应中解析会话ID并进入NiFi流文件属性.根据您返回的内容类型,这通常使用ExtractText,EvaluateJsonPath或类似的处理器完成.

后续的GetHTTP或InvokeHTTP处理器应配置为具有会话ID的动态属性,其值设置为使用NiFi表达式语言来使用flowfile属性,如${sessionid}.