0

我正在尝试在 Apache Nifi 中创建一个流程 - 情况就像这样 1- 使用来自 kafka 的消息（DONE） 2- 转换为有效的请求正文（DONE） 3- 保留转换后的消息 4- 生成一个 oauth2 令牌（它是一个 post api ) 5- 使用转换后的 json 作为请求正文调用一个 post api 并在 header 中发送令牌

我尝试了几种方法，例如将转换后的 json 放入缓存并在生成令牌后获取它，但问题是我无法将令牌传递给 fetchdistributedcache 处理器。我尝试将 json 文件放在我的服务器上，但 getfile 不接受任何输入，因此在获取 token 后无法触发它。

4

1 回答 1

1

如果步骤 4 (OAuth) 将令牌作为正文返回，则 InvokeHTTP 中有一个选项可将响应正文放入属性而不是 FF 内容中，从而保留原始 FF 内容。

因此，您可以完全跳过第 3 步。

使用 kafka -> 转换 -> InvokeHTTP for OAuth 令牌（将响应正文放入属性）-> UpdateAttribute（可选 - 假设您需要对响应正文进行一些格式化）-> InvokeHTTP（OAuth 令牌已经在属性中并且FF内容不变）

https://nifi.apache.org/docs/nifi-docs/components/org.apache.nifi/nifi-standard-nar/1.12.1/org.apache.nifi.processors.standard.InvokeHTTP/

于 2021-03-22T12:17:26.997 回答