在 NiFi 中，如何将二进制文件发送到 HTTP Rest？答案

【问题标题】：In NiFi how do you send binary files to HTTP Rest?在 NiFi 中，如何将二进制文件发送到 HTTP Rest？
【发布时间】：2019-01-11 04:11:40
【问题描述】：

我有以下业务需求。有人可以建议我应该创建的 NiFi WorkFlow 吗？谢谢 1）通过Kakfa我得到元数据作为JSON对象。此 JSON 对象具有二进制格式的图像或视频。这个二进制文件非常大。 2) 我需要提取二进制数据并将其发送到 HTTP REST (POST)。

在我看来，我有以下工作流程： ConsumeKakfa==>EvaluateJsonPath==>UpdateAttributes=>InvokeHTTP

说明： 1) ConsumeKakfa 将接收元数据作为 json 对象。 2) EvaluateJsonPath 将提取内容 json 属性，该属性具有存储为 base64 的图像或视频数据。 3) UpdateAttribute 将更新流文件以插入 POST 有效负载。 4) InvokeHTTP 将调用 POST HTTP 休息调用。

我不确定 InvokeHTTP 是否会处理大量数据。

【问题讨论】：

标签： apache-nifi

【解决方案1】：

你的流程应该是这样的：

ConsumeKafka
EvaluateJsonPath (destination=content) 将评估后的 base64 二进制存储到流文件内容中
Base64EncodeContent (decode) 将 base64 内容解码为二进制
InvokeHTTP 将内容中的所有内容作为正文发送

【讨论】：