Apache NiFi：如何使用来自 API 的 Http 响应更新流文件的属性？

Question

我想向 API 报告一些带有每个流文件属性的信息。有时 API 会以 JSON 格式返回一些重要信息。我的目标是使用返回 API 的新数据更新原始流文件的属性。

我更新FlowFile的草图策略-> AttributeToJSON（但是FlowFile的整个内容都被JSON替换了，1°问题）-> HttpInvoke 将信息发送到 API -> API 返回带有一些数据的 JSON -> 使用一些 Process 从 JSON 中提取一些数据并更新 Flowfile 的属性

1° 问题：我可以将流文件、原始文件和另一个文件分开（用 AttributeToJSON 对其进行修改）。但是我以后如何合并它们呢？我需要哪个流程将原始流文件和我构建的“新”属性与 API 的响应结合起来？

也许我可以用 PutFile 将原始文件保存在一个目录中，然后通过另一种方式处理信息，并在某些时候使用 FetchFile（属性知道在哪里保存文件），然后将数据和属性放在一起。

extra我可以使用 HttpInvoke POST 请求仅发送属性（其中一个用 JSON 编写）吗？。

Answer 1

您可能想看看 lookup 处理器 -- LookupAttribute 和 LookupRecord。这些处理器允许您使用其他信息来丰富现有的流文件。

现在看来，RestLookupService 可用于记录扩充，但不能用于属性扩充。您可能需要提交 Jira 请求，同时您可以使用 SimpleScriptedLookupService 从该处理器进行 HTTP 调用。