我有一些具有不同列名的输入文件。我能创建一个处理所有类型文件的通用Nifi流吗？每个文件将具有不同类型的列和要加载的不同类型的输出表。例如，文件1将具有要加载到表AB的列A、列<
浏览 8提问于2020-09-03得票数 0
我有一个流文件，它将通过一个模板采用几个不同的路径，并且我想合并结果。我的问题是流文件将具有相同的内容，只是基于内容的一些不同的属性。我想知道是否可以使用合并处理器之一合并两个相同的流文件，但也可以让单个生成的流文件具有每个单独输入
浏览 27提问于2019-08-30得票数 0
回答已采纳
我正在寻找一种在Apache NiFi中创建关键部分的方法。我的意思是创建一组处理器，其中一个FlowFile将被单独处理-下一个FlowFile将被从队列中提取出来，当前一个FlowFile用该组的最后一个处理器完成时。请参阅下面的图片。
我想实现对NiFi API的访问令牌管理。我希望将令牌保存在缓存中，并将请求的数量限制在</
浏览 3提问于2022-01-28得票数 0
1回答
我正在使用Apache Nifi开发一个基于云的应用程序，为此我们需要支持Multitenency。但目前的Nifi实现只支持单个流的用户基于角色的访问。我可以理解，流状态保存为Nifi实例的单个压缩XML文件。以便登录到该实例任何人都可以查看相同的流。我们的要求是为每个用户登录创建唯一的<e
浏览 17提问于2016-08-17得票数 3
我计划使用nifi从10,000多个传感器中摄取数据。有50-100种传感器，它们将向nifi发送一个特定的指标.我正在思考是否应该分配一个端口号来听所有的传感器，还是应该为每种类型的传感器分配一个端口，以方便我的数据管道。哪个是更好的选择？
是否有我可以用nifi“听”的端口号的上限？
浏览 2提问于2020-05-31得票数 2
回答已采纳
我有四个运行在Ubuntu14系统上的云中的NiFi v1.1.2实例。其中三个实例充当远程进程组(R1、R2和R3)，其余的实例(M1)用于管理RPG之间的流。M1生成一个FlowFile，通过由三个RPG组成的管道传递FlowFile，并在最后记录FlowFile。每个RPG简单地将R{id}附加到FlowFile中的一个ProcessedBy属性，这样就可以很容易地看到处理数据的顺序。
我遇到的</em
浏览 3提问于2017-05-08得票数 2
回答已采纳
平面文件具有以下不带标题的数据，需要将这些数据加载到MySQL表中。102,BBB,5000,20102,BB
浏览 2提问于2021-01-13得票数 2
1回答
我正在使用Apache处理来自不同资源的数据，并且为每个数据流创建了独立的管道。我想结合这些数据来进一步处理。有没有方法可以聚合数据并将其写入单个文件。数据以流文件属性的形式显示在Nifi中。
浏览 2提问于2016-11-17得票数 1
回答已采纳
使用ExecuteSQL/ExecuteSQLRecord处理器，您可以指定“输出批大小”，这将导致多个流文件。每个流文件都包含executesql.row.count。现在，计算单个表的sum(executesql.row.count)最简单的方法是什么？content) => MergeContent (defragment) => QueryRecord (counting) => EvaluateJSONPath (back to a
浏览 1提问于2020-07-12得票数 0
1回答
我的桌面崩溃了，我把它修好了。 然而，我的NiFi项目消失了。当我转到http://192.168.1.36:8080/nifi/时，我只看到一个空白画布。有没有办法让它复活？NiFi安装在/opt/nifi-1.10.0/
浏览 34提问于2021-01-23得票数 0
回答已采纳
所以，我很想，基本上，能够旋转一个容器，运行Nifi，我已经有了一个模板。我对集装箱非常陌生，对Nifi也相当陌生。我想我知道如何旋转一个Nifi容器，但不知道如何使它每次都自动运行我的模板。
浏览 0提问于2018-03-23得票数 2
1回答
当下一个处理器无法接收或处理任何数据时，有人能详细解释NiFi处理器(如GetFile或QueryDatabaseTable )是如何存储行的吗？当数据的大小超过某个阈值时，数据会在内存中通过管道传输到磁盘上吗？它是否有耗尽内存或丢失数据的风险？
浏览 4提问于2017-05-15得票数 5
回答已采纳
1回答
我对Apache NiFi几乎没有什么疑问。
但是它只是启动配置，不能在启动NiFi之后完成。是否有任何REST为用户添加管理特权，而不是为
浏览 4提问于2017-07-27得票数 0
我有一个文件并计算了内容的哈希值，但在Java中或使用在线工具进行比较时，它永远不会匹配相同的计算结果。我添加了“debug”级别的处理器日志，但它没有帮助。
每
浏览 1提问于2018-12-18得票数 0
我在GitFlowPersistenceProvider注册表0.3中使用NiFi。今天，我创建了另一个NiFi注册表，我希望使用相同的提供程序加载来自上一个流的所有流。不幸的是，什么都没有发生--任何桶或流都不会被重新创建。我尝试手动创建所有桶，但即使这样，也不会导入任何流。声明：
当NiFi注册表启动时，此提供程序将读取Git提交历史并查找这些bucket.
浏览 0提问于2019-04-23得票数 2
回答已采纳
设置：，我有气流触发我的Nifi，它以几个PutSQL处理器结束-在这些完成之后，我需要在气流中执行其他的东西。Idea:，我想触发第一个Nifi处理器，然后在气流中等待，直到最后一个PutSQL处理器的last_execution_timestamp被更新。问题：I尝试访问属性statsLastRefreshed，但这不是最后一次执行时间，而是最后一次任何东西(用户/api请求)访问导致Nifi刷新处理器的处理器。s =
浏览 1提问于2021-04-12得票数 1
回答已采纳
Nifi能否用于执行以下操作：
看起来，可以用来使用另一个CSV文件来执行充实，但是对于这个用例来说，这似乎太复杂了。下面是一
浏览 15提问于2017-03-20得票数 5
回答已采纳
我使用NIfi来摄取数据。我的组件之一使用使用AMQP处理器来消耗rabit MQ队列。我想的解决办法就像这样。由于队列名称在文件<e
浏览 2提问于2018-02-05得票数 0
我需要在我的特定案例中阐明NiFi中ReplaceTextWithMapping的用法。：它与映射文件中的字段键匹配(我们需要大写字母或大写字母+数字)，但是我不确定您是如何决定要将输入值分配给哪个值(来自COL2或来自col3)的。"我想我的主要问题是:是否可以将输入文件中相同的值
浏览 3提问于2016-05-15得票数 2
2回答
我有如下结构的csv文件。Alfreds,Centro,Ernst,Island,Bacchus01,02,03,04,05Alfreds,Germay,01Ernst,Austria,03Bacchus,Canda,05
我试图映射这些列，但无法从列中提取数据。在这里，我的输入</em
浏览 1提问于2017-03-02得票数 3
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
腾讯会议
云直播
对象存储活动推荐
腾讯云开发者
