1回答
我正在尝试使用groovy和outputStream (这是一个bytearrayoutputstream)在Nifi中写入流文件。但是，我写入流文件的大小是零。我做错了吗？提前谢谢。
浏览 0提问于2017-07-10得票数 0
回答已采纳
1回答
我有一个要求阅读巨大的CSV文件从卡夫卡主题到卡桑德拉。我配置了以实现同样的目标。用户在Nifi安装程序上没有控件。他只指定CSV所在的URL。web应用程序将URL写入kafka主题。Nifi获取文件并插入Cassandra。任何帮助都将不胜感激。
浏览 0提问于2016-09-02得票数 1
回答已采纳
我一直试图访问NiFi流量文件属性从卡夫卡消息在星火流。我使用Java作为语言。场景是，NiFI使用GetSFTP处理器从FTP位置读取二进制文件，并使用publishKafka处理器将byte[]消息发布到Kafka。这些byte[]属性使用火花流作业转换为ASCII数据，这些解码后的ASCII被写入Kafka进行进一步处理，并使用NiFi处理器保存到HDFS。我的问题是我无法跟踪二进制文件名和解码的ASCII<e
浏览 9提问于2017-06-09得票数 1
回答已采纳
现在，我正在使用nifi和它的处理器来处理一些流内容(mqtt侦听器、json求值、文本替换、写入数据库……)。我试图持久化flowfiles，因此我做了一些卷映射(见下文)。但是它不工作；重新启动容器后，似乎流文件没有保存…… 谁能给我一个如何解决这个问题的提示？:volumes: - nifi
浏览 96提问于2019-03-25得票数 5
回答已采纳
我是NiFi新手，所以我不确定这是否可能(或正确的设计方法)：我打算使用Wait处理器，使用PostHTTP处理器(通过GUI)提示用户，然后使用Notify处理器。PostHTTP处理器)
不幸的是，PostHTTP处理
浏览 1提问于2017-06-16得票数 2
我想为nifi处理器创建日志文件，我让它们形成tailFail并逐行拆分文本，然后检查是否是错误、信息或警告日志，并路由到可执行文件处理器，但此时我有5个流文件，我想统一这个拆分的流文件并将其写入一个流文件中我还想知道nifi自定义日志是否返回了我在工作流程中添加的所有处理器的日志文件，以及是否在logback.xml中添加了附加程序。
我想知道是否有可能统一
浏览 2提问于2017-08-31得票数 0
回答已采纳
1回答
我正在为NiFi的流文件开发某种错误处理，例如数据库子系统拒绝从流文件中写入数据，因为数据并不像预期的那样，因为这些数据的源系统丢失了一些主数据。因此，这个错误处理会将数据写入MongoDB，并提供更多的信息，说明出了什么问题。
其中一个“更多的信息”是该流文件的某种堆栈跟踪，这意味着数据沿袭。，/nifi-api/provenance/lineage在正文中添加了流<
浏览 0提问于2018-11-29得票数 3
回答已采纳
我需要将一堆json文件流式传输到Nifi，然后Nifi再转到HDFS。Nifi需要查看json文件中的创建日期(UNIX格式)，然后将其路由到适当的HDFS文件夹。我的处理器设置如下： 消费Kafka -> RouteOnContent (使用正则表达式^"creationDate"：\"0-9{4}-0-9{2}-0-9{2}$) -> PutHDFS 每天都有一个HDFS文件夹据我所知，Nifi<
浏览 15提问于2019-01-29得票数 0
我创建了一个简单的NiFi管道，它从一个卡夫卡主题(使用ConsumeKafka)读取数据流，并将其写入HDFS (使用PutHDFS)。目前，我看到很多在HDFS上创建的小文件。新文件大约每秒钟创建一次，有些只有一两条记录。Max Poll Records = 10000在过去，我使用的是Flume
浏览 3提问于2017-10-16得票数 0
回答已采纳
我启动了一个apache/nifi容器，构建并配置了一个流。我不清楚是什么文件(nar、xml等)需要对用户要运行的映像可用。
浏览 5提问于2020-09-22得票数 1
1回答
当下一个处理器无法接收或处理任何数据时，有人能详细解释NiFi处理器(如GetFile或QueryDatabaseTable )是如何存储行的吗？
浏览 4提问于2017-05-15得票数 5
回答已采纳
我有一个NiFi流，它需要将数据发布到其他服务器，在发布之前，它需要从我的内部服务器或Nifi分布式缓存中获取一个值。
浏览 100提问于2020-01-22得票数 0
2回答
我想将Nifi流文件发送到Spark，并在Spark中进行一些转换，然后再次将结果发送回Nifi，以便我能够在Nifi中进一步操作。我不想写流文件写到数据库或HDFS，然后触发火花作业。我想直接发送流文件到星火和接收结果直接从火花到尼菲。我试过在Nifi中使用ExecuteSparkInteractive处理器，但我被卡住了。任何例子都会有帮助。
浏览 1提问于2018-10-31得票数 8
回答已采纳
我使用NiFi作为主要的数据摄取工具，并希望为我的容器提供来自NiFi流文件的文档。有没有人可以分享一下从NiFi向Azure Cosmos Db发布流文件内容的方法？提前感谢
更新(2019.05.26)：最后我使用了Python script，并从NiFi调用它来发布消息。我传递了一条消息作为参数。
浏览 5提问于2018-12-09得票数 1
未能处理会话，原因是无法更新日志文件/data/disk1/nifi/flowfile_repository/journals/90620570.journal，因为尚未写入任何头。处理器在管理上产生了1秒: java.lang.IllegalStateException:无法更新日志文件/data/disk1/nifi/flowfile_repository/journals/9062
浏览 2提问于2019-05-20得票数 4
使用NiFi v0.6.1是否有一种导入备份/归档的方法？所谓备份，我指的是当您使用REST或"Controller“(工具栏按钮)和”备份流“(链接)调用POST /controller/archive时生成的文件。但是，在将其与导出的模板文件进行比较之后，格式是相当不同的。但是也许有一种方法可以把它转换成模板呢？然后使用代码片段ID调用create (POST /nifi-api/contorller/templates)，因此模板
浏览 9提问于2016-06-21得票数 5
回答已采纳
1回答
我有一个场景，我的kafka消息(来自同一主题)流经单个丰富管道，并在最后写入HDFS和MongoDB。我的Kafka consumer for HDFS将每小时运行一次(用于微批处理)。因此，我需要知道根据流文件来自哪个消费者( HDFS消费者或Mongo DB消费者)，将流文件路由到putHDFS和putMongo的最佳方式。或者请建议是否有任何其他方法通过Nifi实现微批处理。
谢谢
浏览 1提问于2019-03-22得票数 0
云服务器
ICP备案
云直播
即时通信 IM
实时音视频
腾讯云开发者
