我正在寻找架构来做情感分析，在流与火花，我偶然发现了这个架构。
我想知道，在Twitter API中使用Nifi + Kafka而不是直接将Spark连接到它有什么好处，我想它会像这样更容错，但我真的不知道。
浏览 2提问于2022-01-08得票数 0
回答已采纳
Apache处理器并没有像我预期的那样运行。我不明白为什么表达式计算要插入零长度字符串到数据应该去的位置。更换策略是:永远更换。ReplaceText处理器中的替换值是： "amount&q
浏览 0提问于2018-07-02得票数 2
回答已采纳
我想知道如何使用NiFi从传入的url中提取查询字符串值。最初，我从实现UpdateAttribute开始： ? 例如，我希望从传入的url http://smth.net/hello?val=23中提取值23。 此外，我希望通过以下方式引用提取的值来使用它：(InvokeHttp处理器) http://some.net&#
浏览 27提问于2019-05-07得票数 0
回答已采纳
我在nifi中创建了一个流，用于将数据从一台linux机器传输到另一台linux机器。流动是这样的：我通过nifi管理的一切，即使用nifi创建、更新属性和启动流。
如何才能得到完成状态的数据传输，使我可以停止流
浏览 0提问于2019-01-31得票数 0
回答已采纳
我有一个文件名为'test.abcde.houses.csv‘，我想提取子字符串'abcde’，我将使用在我的下一个处理器组，以查询数据库。目前，我正在使用updateAttribute处理器组尝试提取子字符串。这是我在value部分中使用的代码。';问题：
这是从NIFI中的流</em
浏览 2提问于2022-01-12得票数 1
回答已采纳
1回答
使用NIFI提取流文件中的属性并将其转换为文本格式示例的最佳实践是：我如何使用executeScript处理器使用NIFI wihtout完成这一任务
浏览 1提问于2016-12-07得票数 2
回答已采纳
压缩格式的文本文件必须通过HTTP或HTTPS发送到apache。在那里，它必须解压缩并存储在HDFS上。到目前为止，这些努力是徒劳的。我的最佳策略是使用以下Nifi处理器：
流文件的RouteOnAttribute (filter on终结点/endpoint)内容为：-e313bde14db343d99c7
浏览 0提问于2018-07-09得票数 0
所以，我很想，基本上，能够旋转一个容器，运行Nifi，我已经有了一个模板。我对集装箱非常陌生，对Nifi也相当陌生。我想我知道如何旋转一个Nifi容器，但不知道如何使它每次都自动运行我的模板。
浏览 0提问于2018-03-23得票数 2
使用Apache，我想处理一个zip，其中包含一个category.json文件和一些数据文件，如图所示。├──datafile-n{ "rating" : 5 我想做的是解压缩文件并将category.json数据作为属性应用于每个数据文件处理这
浏览 1提问于2020-05-10得票数 1
回答已采纳
我需要从NIFI数据流中的流文件中删除unicode char NEL，直到现在我已经使用了replacetext处理器来清除数据，但是如何从replacetext处理器中搜索unicode字符串呢？
浏览 4提问于2017-06-12得票数 2
回答已采纳
我有一个文件，其中包含txt格式的数据，文件中的每一行都是1条记录。我正在使用拆分文本处理器将流文件拆分成1条记录/文件。 我想从记录中提取一个子串。我需要从开始到第n个索引获取一个子串。我在这里使用默认设置，除非我尝试添加一些在线论坛中提到<em
浏览 24提问于2020-11-18得票数 0
回答已采纳
我想编写nifi处理器，它可以从hdfs目录中读取xml文件，然后将其数据提取到流文件属性中，如果有两个nifi处理器可以获取该文件并读取数据或写入其中的情况，那么如何实现文件锁定，以便一次只有一个处理器可以使用它你能给我提供任何可以帮助我的文章、代码示例或相关资料吗？我还没
浏览 5提问于2017-09-30得票数 1
嗨，我是nifi的新手，我学习了教程，了解了出处存储库的内容，并将其移出进行审核。但我有几个问题要问。
最佳做法是始终将数据来源<em
浏览 1提问于2021-02-24得票数 0
回答已采纳
Jython对我来说不是一个选择。
摄入先前处理器的输出(准确地说，是一个带有JSON行的文本文件的Scr
浏览 0提问于2018-03-24得票数 12
回答已采纳
我有一个nifi流，它从RDBMS (SQL Server)表中提取记录，并将这些记录放在HDFS上，采用拼接格式。此流程将在一天内运行几次，以从源表中获取增量记录。现在，我需要为100+不同的源表复制相同的过程。因此，不是为每个单独的表创建sql流，而是可以创建主流(比如说模板)，并将源提取100+、目标文件名等参数传递给主流，然后对每个源表重复这些步骤。我使用
浏览 0提问于2019-02-01得票数 1
我将解释我的用例，以了解要使用哪个DB提取实用程序。
所有这些提取查询都可能需要每天以不同频率多次运行。这取决于我们从源系统或其他情况接收数据的次数。我们计划使用K
浏览 0提问于2019-02-04得票数 0
1回答
使用spark解析NiFi数据包
、、、、
我想用NiFi创建一个从HDFS读取TSV文件的工作流程，使用Spark Streaming，我可以处理这些文件并将我需要的信息存储在MySQL中。我已经在NiFi中创建了我的工作流，并且存储部分已经在工作。问题是我不能解析NiFi包，所以我可以使用它们。= packet.map(dataPacket => new String(dataPacket.get
浏览 12提问于2017-01-09得票数 3
回答已采纳
1回答
当下一个处理器无法接收或处理任何数据时，有人能详细解释NiFi处理器(如GetFile或QueryDatabaseTable )是如何存储行的吗？当数据的大小超过某个阈值时，数据会在内存中通过管道传输到磁盘上吗？它是否有耗尽内存或丢失数据的风险？
浏览 4提问于2017-05-15得票数 5
回答已采纳
Apache和Apache的用例是什么？两者似乎都是数据流引擎。如果两者都有相似的用例，哪一个更好？
浏览 2提问于2017-04-05得票数 18
回答已采纳
问题就说明了一切。我如何做下列事情之一：
有什么唯一的和短的ID节点，我运行吗？我可以使用这些ID来附加到要加载的数据库表名(请参阅下面的详细信息)，并且每个连接都有一个专用表。我有一个NIFI集群和一个自写的专用处理器，它通过JDBC将大量数据
浏览 2提问于2017-08-23得票数 2
回答已采纳
云服务器
ICP备案
腾讯会议
云直播
对象存储
腾讯云开发者
