我正在尝试使用Apache Nifi构建一个新的数据摄取流。我们还必须读取一个配置JSON文件，然后继续处理。我在这里尝试
浏览 13提问于2019-08-20得票数 1
我想使用CURL.Please将.csv文件或mysql表从本地计算机(GetFile)发送到Apache Nifi中的Hive(PutHiveql)，让我知道是否有使用Curl执行此操作的命令。
浏览 0提问于2017-06-28得票数 0
我有3个节点的Nifi集群在运行(1.5版)。我已经使用handlehttprequest和中间处理器集构建了管道，用于转换/清理传入的数据，然后是handlehttpresponse。有各种客户端应用程序将通过nifi提供的rest端点发布数据。我在将Handlehttprequest作为所有节点以执行模式运行时遇到了问题。Nifi UI在一段时间后变得没有响应，我可以在nifi-app
浏览 75提问于2018-08-03得票数 0
回答已采纳
1回答
我想使用HandleHTTP处理器在Nifi中托管一个应用程序接口。我想获得一些关于如何做到这一点的信息/资源。我是Nifi的新手。提前谢谢。
浏览 27提问于2020-08-27得票数 0
回答已采纳
2回答
为了分离逻辑，简化主流程并重用处理器组，我正在寻找在Apache NiFi中实现进程间通信逻辑的方法。到目前为止，我唯一能找到的就是在主流中使用InvokeHTTP，在组中使用HandleHTTPRequest/Response对。但是，开放的HTTP端口过多可能会导致安全问题。有没有更好的方法来做同样的事情，例如，将流文件和属性路由到所需的处理器，然后将其返回？如果没有，我认为在
浏览 2提问于2020-01-28得票数 1
我是Apache的新手，我开发了一个通过HTTP请求将NiFi数据发送到NiFi端点的应用程序。在Apache NiFi中，我有一个HandleHTTPRequest处理器连接到PutFile处理器，然后连接到HandleHTTPResponse处理器。我也尝试过使用LogAttribute处理器。来自JSON服务的响应代码和HTTP运行正常，但我正在努力确保正确发送NiFi有效负载。在</
浏览 9提问于2016-07-06得票数 3
我的最终目标是屏蔽特定文件中的数据。我想要将文件从一个位置移动到另一个位置。在此传输过程中，我必须使用Python脚本屏蔽数据。因此，我设计了以下流程：我使用pandas设计了一个Python脚本。我在Google Cloud Platform上创建的虚拟机上运行此NiFi，其中我安装了Python-2.7和NiFi-1
浏览 1提问于2019-04-25得票数 0
我使用ListenHTTP作为Nifi进程的输入点。df.iloc[i].to_json() time.sleep(0.1)
问题是，Nifi在处理了大约3000条条目后就崩溃了。然后我应该重新启动它(在重新启动之前，我还会手动清空日志和flowfile_repository文件夹)。Nifi处理器ListenHTTP或Nifi</em
浏览 8提问于2017-10-19得票数 1
回答已采纳
几天前，我陷入了问题(这涉及自定义nifi处理器的错误行为)。调试对我没有帮助。因此，我决定探索nifi模拟框架(我应该已经这样做了，但没有这么做:)，正如关于这个问题的评论中所建议的那样。为此，我按照建议使用MergeContent (带有FlowFile v3版本)和PutFile处理器保存/序列化了实际的流文件。现在，我正尝试使用GetFile处理器通过测试中的代码重新读取这个文件，如下所示：
import static org.junit.Assert
浏览 2提问于2019-05-03得票数 0
回答已采纳
我正在尝试设置一个简单的过程来修改我的CSV文件，并使用Apache Nifi将其摄取到elasticsearch DB。我不想在将文件从一个处理器传递到另一个处理器时，在Stdout上流式传输我的CSV文件。
我已经做了两个流程。我的第一个流程是使用python处理器获取我的CSV文件，使用ExecuteStreamCommand对其进行定制，我在其中运行我的GetFile脚本来读取、修改和保存我的CSV文件。我的
浏览 2提问于2019-08-06得票数 0
1回答
目标
Nifi ListenHTTP/HandleHTTPRequest处理器不支持Basic，因此正如建议的那样--您可以使用ListenHTTP/HandleHTTPRequest处理器和RouteOnAttribute来验证用户名和密码。在我的例子中，Nifi接受普通的HTTP请求，因为Nifi隐藏在Api网关SSL终端下。如果准确地说，Nifi会获得，这是因为等于base
浏览 5提问于2020-07-03得票数 0
我计划使用Apache作为数据摄取用例。源可以是平面文件和Teradata数据库，输出接收器可以是Oracle数据库。我创建了几个流，使用GetFile和Teradata使用ExecuteSQL从平面文件中读取数据，并使用PutSQL将数据加载到Oracle数据库。一切似乎都很顺利。我们预测源系统将来可能会发生变化，我注意到Nifi中的处理器可以用来支持这些源。
现在，我的问题是，是否可以在
浏览 4提问于2017-03-02得票数 2
回答已采纳
我编写了下面的POST命令，并使用"HandleHttpRequest“处理器在Apache NiFi中接收POST请求
curl -v -H "Accept: application/json" -Hjson" -X POST -d '{"employeeDetails":{"empid":"124","empname": "pravee
浏览 0提问于2019-11-08得票数 0
本文要求使用MergeContent和FlowFileV3选项，然后使用PutFile。我能够以.pkg格式持久化这些文件。我正在使用GetFile、IndetifyMimeType和UnpackContent处理器在同一篇文章中建议的单元测试代码中阅读它们。但是，我在代码中这样做，如下所示：TestRunner getFileRunne
浏览 1提问于2019-05-07得票数 1
回答已采纳
我正在尝试使用Apache nifi中的Putmongo处理器将json数组插入到mongodb中。以下是我的完整Apache流程： GetFile CSV -> ConvertRecord to Json -> QueryRecord -> MergeContent -> PutMongo
浏览 55提问于2020-12-22得票数 0
我启动了一个apache/nifi容器，构建并配置了一个流。我不清楚是什么文件(nar、xml等)需要对用户要运行的映像可用。
浏览 5提问于2020-09-22得票数 1
我使用的是nifi 1.11.4，我使用HandleHttpRequest、ReplaceText和HandleHttpResponse来模拟API请求和响应。但是，在v1.9.2和1.11.4之间，它们已经从HandleHttpResponse中删除了HandleHttpResponse属性，因此响应在media type=application/octet-stream中。将其转换为JSON的最简单方法是什么，因为我希望
浏览 5提问于2020-06-12得票数 1
回答已采纳
我有一个nifi流，它保持了ListS3处理器的一些状态。我有一个dev实例和一个prod实例。我想要一些从dev部署到prod的选项，其中保存了状态，并且我不必手动进入并更改所有处理器和进程组。基于以下堆栈溢出问题： how does NIFI listfile maintains its timestamp? 编辑:为了避免误解，我希望在部署时保持prod状态。
浏览 14提问于2021-03-19得票数 0
回答已采纳
getDescription()); System.out.println("");}我想问的是:是否可以一个一个地将输出发送到apache是否有任何解决方案，Nifi提取这些输出并将每个输出放在一个依赖的处理器中？
浏览 2提问于2020-03-05得票数 2
回答已采纳
这与Apache Nifi相关。 我有一个固定的模式，我需要使用它。name": "streetaddress", "type": "string"},{"name": "city", "type":"string"}]}}]} 基本上，这个chema有两个部分，即一个在元数据中我有以csv格式创建的元数据和另一个csv格式的实际数据。 我
浏览 21提问于2019-02-28得票数 0
云服务器
ICP备案
对象存储
云点播
实时音视频
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号