我想在插入传入文档之前清空集合。集合应该始终反映与进入处理器的文档完全相同的文档。我可能不得不使用这种方法:使用并使用GenerateFlowFile({}) -> DeleteMongo来删除集合中的所有条目。
浏览 35提问于2019-07-11得票数 1
回答已采纳
我使用NiFi作为主要的数据摄取工具，并希望为我的容器提供来自NiFi流文件的文档。有没有人可以分享一下从NiFi向Azure Cosmos Db发布流文件内容的方法？提前感谢
更新(2019.05.26)：最后我使用了Python script，并从NiFi调用它来发布消息。我传递了一条消息作为参数。
浏览 5提问于2018-12-09得票数 1
1回答
我使用的是Nifi 0.4.1版本。正在编写自定义代码以将CSV转换为avro格式。我已经创建了类文件，并能够生成nar文件。将nar文件放入lib目录并重新启动nifi服务器。当在nifi工作区拖动处理器时，无法看到为将csv转换为avro而创建的类。谢谢,
浏览 4提问于2016-02-25得票数 3
我想使用apache nifi将数据从oracle传输到MongoDB。Oracle总共有900万条记录。我已经使用QueryDatabaseTable和PutMongoRecord处理器创建了nifi flow。此流程运行良好，但存在一些性能问题。在启动nifi流之后，SplitJson -> PutMongoRecord队列中的记录不断增加。有没有办法降低SplitJson处理器放入队列中的记录的速度？或
提高PutMongoRecord<e
浏览 8提问于2020-06-29得票数 0
1回答
我在nifi lib文件夹中添加了一些jar文件，以允许我连接hive，但不幸的是，nifi应用程序没有在web上运行，然后我删除了所有新的jar文件，但是问题没有解决，我一直收到以下错误(NIFIVersion1.15.0)
由于org.apache.nifi.NiFi : org/apache/ NiFi /processor/DataU
浏览 4提问于2021-12-28得票数 0
我启动了一个apache/nifi容器，构建并配置了一个流。我不清楚是什么文件(nar、xml等)需要对用户要运行的映像可用。
浏览 5提问于2020-09-22得票数 1
我有一个基于apache/nifi:1.12.1的Dockerfile，希望像这样展开它：RUN mkdir -p /opt/nifi/nifi-current构建成功，我使用docker run -it -d --rm --name nifi nifi-test运行它，但是当我通过docker exec进入容器时，没有flow dir。我试过像USER
浏览 9提问于2022-05-04得票数 1
回答已采纳
如何在Apache NiFi中清除FetchDistributedMapCache处理器的缓存？我尝试删除持久化目录，也尝试一起给出一个新目录，但它仍然获取旧数据。谢谢你的帮助。
浏览 0提问于2017-04-24得票数 5
我有一个Apache实例，它需要将消息记录到远程Graylog服务器。我希望将nifi-app.log、nifi-bootstrap.log和nifi-user.log的输出全部发送到此服务器，以及它们的默认本地策略。我的问题：
是否有更好的方法来配置Apache来发送NiFi的日志？
浏览 5提问于2018-12-07得票数 1
回答已采纳
我需要Apache安全集群配置方面的帮助。首先，我只使用ldap-用户组提供程序，但它不能工作。Web中的错误消息是Untrusted proxy CN=nifi, OU=NIFI
然后，我将我的authorizers.xml修改为复合用户组提供者Policy Provider">file-access-policy-provider
浏览 6提问于2022-03-15得票数 0
我正在实现自定义NiFi处理器来解码一些文件。在解码过程中，我需要查找某些数据映射的外部CSV记录。注意，这个解码过程很复杂，所以它必须是一个自定义处理器。我知道可以设置外部CSVRecordLookupService，然后在CustomController中定义一个属性描述符，如下所示 <version>1.13.0&
浏览 4提问于2021-04-05得票数 2
回答已采纳
+= "org.apache.nifi" % "nifi-site-to-site-client" % "0.7.0"import org.apache.spark.SparkContext
import org.apache.spark.S
浏览 4提问于2016-07-19得票数 2
MongoDB是做什么的？在每次更新之后，保持该列排序的时间复杂度是多少？
浏览 0提问于2021-12-29得票数 -1
回答已采纳
1回答
我使用Apache Nifi、Spark和Kafka在它们之间发送消息。首先，我使用Nifi获取数据，并将其发送到Spark进行处理。然后，我再次将数据从Spark发送到Nifi，以将其插入到DB中。
我的问题是，每次我运行Spark，我都会得到同样的3.142条记录。我尝试查看Kafka-Queue-I (从Nifi到Spark)或Kafka-Queue-II (从Spark到NiFi)上是否有数
浏览 15提问于2020-02-14得票数 0
我们已经使用apache NiFi开发了ETL管道。只有当客户端从portal.After上传源数据文件时，它才会触发，该文件中存在的数据通过不同的层被转换并存储回仓库(即蜂巢)。问题:为了将数据输入到DSS工具中，首先要在蜂巢表中加载数据。这很好。但是，我们不能阻止现有的ETL流介于两者之间，然后开始敏感信息的识别过程。上面的解决方案必须需要一些手动处理，我想摆脱它并使之成为automated.that，它应该插入到NiFi pipeline.But
浏览 4提问于2020-07-01得票数 0
doc.review_start_time = datetime.datetime.now()doc.save()
在执行保存方法时
浏览 4提问于2020-08-28得票数 3
我在HDFS中有5个XML文件，我正在使用Apache this is the flow nifi获取这些文件。首先，我使用生成流文件处理器，然后我必须使用5个不同的FetchHdfs处理器。我不能使用GetHdfs，因为它会删除目录中的所有文件，并且我没有权限摄取这些文件。因此，我正在寻找一种方法，除了使用5 FetchHdfs之外，我还能做什么？所有的文件都在同一个目录中，我想保留它们，这样我就可以多次测试。我在Transform
浏览 11提问于2021-08-09得票数 1
首先在DOM中直接添加条目，然后在用户添加完条目后，将与此新条目相关的文档插入到MongoDB中。在当前用户添加新列表项时，如何防止页面自动拉入新列表项(例如，可能已由其他用户添加的列表项)？有没有办法让应用程序停止侦听添加到MongoDB的任何新文档，直到应用程序开始告诉它重新启动(请注意，应该只阻止页面的指定区域，即特定的流星模板)的自动更新？
浏览 2提问于2015-04-09得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
云直播
对象存储
实时音视频活动推荐
腾讯云开发者
