Apache NiFi是一个易于使用，功能强大且可靠的分布式系统，用于转换和分发数据。
我的用例。某些处理的某些处理将文件添加到某个目录（_use_it） - >使用REST调用我的流 - >现在我希望我的进程从所提到的目录（_use_it）中读取所有文件。我想要 ...
我正在使用NIFI，我有数据流，我使用以下过程：ExecuteScript RouteOnAttribute FetchMapDistribuedCache InvokeHTTPRequest EvaluateJSONPath和两级进程组如...
是一种从单次运行FetchHDFS处理器获取文件总数的方法？我的用例是==>从目录（hdfs）读取所有文件，连接它们然后进行进一步处理。但要停止......
我将在单个节点NiFi上工作的流移动到3节点NiFi集群，突然间使用DistributedMapCache的等待处理器无法按预期工作，这意味着它不是......
我已经更新了变量注册表以指向自定义属性文件，并且我能够使用表达式语言读取我的处理器中的那些并且没有任何问题。我怎么想在...中阅读它们
有没有办法从SplitRecord处理器Nifi获取片段索引？我将一个非常大的xls（4毫米记录）分成“每分裂记录数”= 100000.现在我想处理前两个分裂，到......
可以在单个Apache NiFi实例上配置的数据库连接控制器服务数量的限制是多少？
我正在使用DBCPConnectionPoolLookup控制器服务，该服务可能包含大量数据库（100的订单） - 使用DBCPConnectionPool控制器服务进行配置。所有这些......
我在多个小文件中有json数据（有时在文件中只有一行或空文件）。我想将所有小文件合并到单个大文件中。我正在意外地收到一个大文件......
我有json输入数组：{“id”：3，“name”：“ROOT”，“mylist”：[{“id”：10，“info”：“hello”}，{“id”：11， “信息”：“世界”} ...
我从第三方获取CSV文件。这个文件的模式是动态的，我唯一可以肯定的是，每个包含数据的列也都有标题名称。文件将始终有一个标题。 ...
我正在尝试将大量的大型CSV文件插入到数据库中。我正在使用PutDataBaseRecord处理器，这使得这个过程非常快速和简单。问题是我不......
我正在尝试解决一项任务，并会感谢任何帮助 - 文档链接，论坛链接或其他常见问题解答，除了https://cwiki.apache.org/confluence/display/NIFI/FAQs，或任何有意义的.. 。
我想通过相同的指定属性合并包含JSON对象的两个流文件... flow1：attribute：xuuid = 123456内容：{“sname”：“jack”，“id”：“00001”，“state”：“NY” } flow2：属性：...
我在NIFI中有以下流程，JSON中有（1000+）个对象。 invokeHTTP-> SPLIT JSON-> putMongo Flow工作正常，直到我在json中收到一些带有“。”的键。在名字里。例如“火花....
我正在尝试从nifi rest api创建一个DbcpController服务。我也得到了正确的响应但是当我转到UI时，控制器服务不可见。 curl -i -X POST -H'内容类型：...
我想提取kafka指标，发现这可以通过JMX使用jconsole来完成。但我需要为此创建一种程序化的方式，并认为nifi将是一个伟大的......
apache-nifi：如何将时区传递给crontab字符串
NIFI能够使用类似策略的crontab来安排任务。在某些处理器的调度选项卡中，您可以选择“CRON驱动”。这个CRON使用Quartz Scheduler模块，我发现如何设置...
我正在使用Kafka，Druid和SuperSet测试数据流。我正处于德鲁伊的一些数据（见1. picutre）。之后，我可以通过...在Superset中生成德鲁伊数据源。
我有以下JSON输入{“events”：[{“cluster_id”：“0717-035521-puny598”，“timestamp”：1535540053785，“type”：“TERMINATING”，“details”：{“reason”：{.. 。
我有一个30个处理器的nifi模板。模板中有多个条件分支。现在，我想在模板的末尾添加一些东西，以便我可以获得所有的列表......