使用git作为存储时，无法通过http调用删除Nifi注册表中的流
问题：使用git作为存储时，无法通过http调用删除Nifi注册表中的流。
回答： 当使用Git作为存储时，无法通过HTTP调用直接删除Nifi注册表中的流。这是因为Git是一个分布式版本控制系统，它主要用于代码的版本管理和协作开发，并不提供直接删除Nifi注册表中流的功能。
Nifi是一个开源的数据流处理工具，它提供了一个可视化的界面来构建、管理和监控数据流。Nifi的注册表是用来存储和管理数据流的元数据信息，包括流的配置、状态和历史记录等。
要删除Nifi注册表中的流，可以通过以下步骤进行操作：
- 打开Nifi的管理界面，登录到Nifi控制台。
- 导航到注册表页面，找到要删除的流所在的注册表。
- 在注册表页面中，找到要删除的流的条目。
- 通过点击流条目旁边的删除按钮来删除流。
需要注意的是，这种删除操作只会删除注册表中的流的元数据信息，并不会删除实际的数据流。如果需要删除实际的数据流，可以通过其他途径进行操作，例如使用Nifi的API或者其他相关工具。
推荐的腾讯云相关产品：腾讯云容器服务（Tencent Kubernetes Engine，TKE）。TKE是腾讯云提供的一种高度可扩展的容器管理服务，可帮助用户快速构建、部署和管理容器化应用。TKE提供了强大的容器编排和管理功能，可以方便地部署和管理Nifi等数据流处理工具，并提供高可用性和弹性扩展的能力。
产品介绍链接地址：https://cloud.tencent.com/product/tke
相关·内容
我在GitFlowPersistenceProvider注册表0.3中使用NiFi。今天，我创建了另一个NiFi注册表，我希望使用相同的提供程序加载来自上一个流的所有流。不幸的是，什么都没有发生--任何桶或流都不会被重新创建。我尝试手动创建所有桶，但即使这样，也不会导入任何流。
声明：
当NiFi注册表启动时，此提供程序将读取Git提交历史并查找这些bucket.yml文件，以恢复每个快照版本的存储桶和流。
如何使用NiFi将现有流加载到新的GitFlowPersistenceProvider注册表中？
浏览 0提问于2019-04-23得票数 2
回答已采纳
我正在寻找像GitHub这样的BitBucket版本控制存储库。我找到了Nifi Git存储库。但在我的组织中，我们在BitBucket中有私人帐户。我的问题是，我可以在bitbucket中使用Apache Nifi-registry创建版本控制存储库吗？在nifi注册表的providers.xml文件中有一个与Git关联的类(org.apache.nifi.registry.provider.flow.git.GitFlowPersistenceProvider)。对于bitbucket，我应该使用哪个类？任何帮助，指南都将不胜感激。谢谢!
浏览 10提问于2019-02-14得票数 0
4回答
我是nifi的新手，正在尝试理解(因为它看起来像是基于GUI的)是否有一种方法可以在Nifi上自动扩展和缩小，以及如何将xml Nifi模板部署到集群中。
本质上，我们试图做的是使用Nifi从kafka服务器收集JMX和日志文件，当它们以自动方式出现时，因此日志和JMX计数器开始流动到，比如说和Elasticsearch集群。
例如，现在我们已经使用Ansible自动化了kafka服务器的部署，所以我们希望在集群部署的同时配置和部署Nifi xml teamplates，这样就不需要手动干预来收集kafka jmx计数器和日志文件。
如何在Nifi中实现自动化？
浏览 0提问于2017-02-18得票数 5
1回答
是否可以使用REST将外部数据(而不是NiFi流)存储到NiFi注册表中？
据我所知，NiFi注册表是为NiFi流的版本化而设计的。但我想知道它是否能够将其他数据存储到NiFi注册表中，并根据版本检索它。
浏览 0提问于2018-07-03得票数 3
回答已采纳
2回答
我已经和我的Nifi 1.9.2集群一起安装了Nifi Registry 0.5.0，并且版本控制可以正常工作。然而，当涉及到注册表推送到git存储库时，我们看到了以下内容。
2020-03-02 10:19:53,183 ERROR [GitFlowMetaData Push thread] o.a.n.r.p.flow.git.GitFlowMetaData Failed to push commits to origin due to org.eclipse.jgit.api.errors.TransportException: https://svc_nifi@gitlab.intra
浏览 11提问于2020-03-02得票数 0
我正在为Apache NiFi开发一个自定义处理器。我已经创建了处理器的nar，并将它放在nifi的lib文件夹中，并启动了nifi。我已经在eclipse中设置了远程调试器，并在onTrigger()的第一行上启用了断点。在调试时，我正在我的nifi管道中一次运行一个处理器。我可以在自定义处理器的输入队列中找到单个流文件，但是我的自定义处理器没有接收到任何流文件。当我启动我的自定义处理器时，它会击中onTrigger()方法中的断点。在此方法中，当我这样做时：
public class MyCustomProc extends AbstractProcessor {
@Overri
浏览 1提问于2019-05-02得票数 2
我有两个apache服务器，它们都是托管在AWS上的开发和生产，目前开发和生产之间的迁移是手动完成的。我想知道是否有可能实现这一过程的自动化，并确保人们不会在生产中开发？
我考虑在github中上传整个nifi并让它在生产服务器上部署新的nifi，但我不知道这样做是否正确。
浏览 1提问于2022-03-03得票数 0
回答已采纳
我启动了一个apache/nifi容器，构建并配置了一个流。
我想以某种方式将这个流保存在某个地方，这样它就可以加载到运行Nifi的新docker镜像中。
这样，“用户”只需执行“docker run...”将启动nifi的一个实例，加载并启动流。
我不清楚是什么文件(nar、xml等)需要对用户要运行的映像可用。
浏览 5提问于2020-09-22得票数 1
我们想使用Nifi注册表与git作为存储引擎。在这种情况下，我修改了providers.xml，并且能够保存那里的流。
挑战：
没有双向同步。我们只能保存由Nifi用户修改的流，但是如果我们在git位置直接修改流，它将不会反映在nifi注册表中。
Nifi注册中心没有审查或批准流程。用户必须登录到nifi注册服务器，创建分支并发出拉请求。
作为解决办法，我们可以删除数据库文件( H2)并重新启动nifi resgistry。
最后，一切都应该在CI/CD中自动化，就像我们对常规maven项目所做的一样。
有什么建议吗？
浏览 0提问于2019-07-15得票数 3
我有一个nifi流，它保持了ListS3处理器的一些状态。我有一个dev实例和一个prod实例。我想要一些从dev部署到prod的选项，其中保存了状态，并且我不必手动进入并更改所有处理器和进程组。 看起来这不能用模板来完成？基于以下堆栈溢出问题： how does NIFI listfile maintains its timestamp? 编辑:为了避免误解，我希望在部署时保持prod状态。
浏览 14提问于2021-03-19得票数 0
回答已采纳
我们有一个13节点的nifi集群，拥有大约50k的处理器。flow.xml.gz的大小约为300 is。要建立13个节点的Nifi集群，通常需要8-10小时。最近，我们将集群分为两个部分，5节点集群和8节点集群，它们都具有相同的300 in flow.xml.gz。从那以后，我们无法在这两个星系团中得到Nifi。此外，我们没有看到任何与此问题有关的有效日志。有同样的flow.xml.gz可以吗？在拆分Nifi集群时，我们可能缺少哪些最佳实践。
浏览 2提问于2021-07-22得票数 0
回答已采纳
在从Nifi-1.9.2升级Nifi-1.10.0的过程中，'flow.xml.gz‘被复制到新的app.However，存储在注册表中的文件被解压。如下消息所示： $ cat 4.snapshot | grep 'version'
"version" : "1.9.2"
"version" : "1.9.2"
"version" : "1.9.2"
"
浏览 14提问于2020-01-15得票数 0
我有一个nifi流，它从RDBMS (SQL Server)表中提取记录，并将这些记录放在HDFS上，采用拼接格式。此流程将在一天内运行几次，以从源表中获取增量记录。现在，我需要为100+不同的源表复制相同的过程。因此，不是为每个单独的表创建sql流，而是可以创建主流(比如说模板)，并将源提取100+、目标文件名等参数传递给主流，然后对每个源表重复这些步骤。我使用的是Nifi Nifi 1.7。我已经非常接近对流本身进行参数化了。
示例-参数化流程中使用的组件中的参数。示例-文件名=${path}/${文件名}
不确定如何从命令行将值传递到此流？
谢谢，希德
浏览 0提问于2019-02-01得票数 1
1回答
服务器上有NiFi和NiFi注册表，这是没有连接的，我不能通过本地NiFi instance.But连接到NiFi注册表，我可以通过远程桌面访问NiFi和NiFi注册表。 在我的本地开发系统上安装了另一个版本的NiFi和NiFi注册表。有没有办法离线更新(同步)远程NiFi注册表流并将新的更新应用到远程NiFi？ ?
浏览 19提问于2020-11-07得票数 1
流文件被卡在队列中(按属性进行负载平衡)，下一个下游处理器(MergeRecord和CSVReader和CSVRecordSetWriter)不会读取。从Nifi来看，流文件似乎在队列中，但是当试图列出队列时，它会说“队列没有流文件”。尝试清空队列也会给出确切的消息。Nifi日志没有任何与处理器相关的异常。队列中大约有80个流文件。
我试过以下动作项目，但都失败了：
重新启动下游和上游(ConvertRecord)处理器。
禁用并启用CSVReader和CSVRecordSetWriter。
禁用负载平衡。
流文件过期设置为3秒。
截图: Flowfile：
Merg
浏览 0提问于2019-05-09得票数 2
我使用NIfi来摄取数据。我的组件之一使用使用AMQP处理器来消耗rabit MQ队列。
它的工作没有任何问题，但问题是队列名称。每个环境都不同，因此我无法在不更改队列名的情况下运行Nifi流。这在、QA、和PROD环境中产生了问题，因为我无法更改nifi流中的任何内容。(不允许)
我想的解决办法就像这样。
由于队列名称在文件中可用(所有env的位置都相同)
通过GetFile处理器读取文件
通过ExtractText处理器提取文本
将其作为ConsumeAMQP处理器的输入参数
问题是ConsumeAMQP处理器不接受任何输入。有人能告诉我怎么做吗？
浏览 2提问于2018-02-05得票数 0
我已经创建了一个NiFi流，它最终将json记录发布为带有Avro编码值和字符串键的记录，使用模式中的模式。这是 in NiFi。
我现在试图使用Kafka (connect-standalone)使用JdbcSinkConnector将消息移动到PostgreSQL数据库，但得到了以下错误：
我已经确认我的为1的架构。
Worker Config:
bootstrap.servers=localhost:29092
key.converter.schemas.enable=false
key.converter=org.apache.kafka.connect.storage.StringC
浏览 0提问于2018-12-11得票数 0
回答已采纳
变量注册表属性是为了促进软件开发生命周期而添加到Nifi中的功能。这意味着您可以在单独的开发环境中开发流，并利用nifi.variable.registry.properties属性中指定的自定义属性文件以及表达式语言来使用处理器配置中的变量。然后，您可以将流作为模板与自定义属性文件一起导出，并将其推送到生产环境中。但是，一旦启动了Nifi的生产实例，就不可能修改您的自定义属性文件。这意味着，如果您想要向生产中添加第二个流，则需要停止该实例，更新自定义属性文件并上传第二个流的模板，然后重新启动服务器。这使得自定义属性文件更像是实例(nifi实例)相关的，而不是流相关的。因此，我的问题是，有没有
浏览 11提问于2017-02-03得票数 4
回答已采纳
我是Apache NiFi的新手。从文档中，我可以理解到NiFi是一个具有拖放UI的框架，可以帮助构建数据管道。这个NiFi流可以被导出到一个模板中，然后保存在Git中。
我们是否应该将此模板导入到生产NiFi服务器中？导入后，我们是否应该通过UI手动启动所有处理器？请帮帮忙。
浏览 22提问于2018-12-12得票数 1
回答已采纳
我知道可以使用rest-api检索变量注册表中的值，但是有方法设置变量值吗？当我更改一个变量时，我看到发送了以下帖子：
http://localhost:8080/nifi-api/process-groups/{ID}/variable-registry/update-requests
但我不太明白VariableRegistryEntity是从哪里来的，也不明白如何操作变量。
更广泛地说，我要做的是操纵来自另一个程序的自定义Nifi处理器中的变量，所以任何关于如何这样做的指导或想法都是受欢迎的。
浏览 0提问于2018-08-24得票数 1
回答已采纳
我正在努力提升我的Nifi工作从开发到QA和我正在使用模板。我知道模板不存储敏感信息(即密码和其他信息)，我对此没有意见。
但是，即使我在XML中更改了其他值，然后上传模板，它也不起作用。
我需要重新启动nifi服务器吗？或者其他什么东西能让特帕特被反射出来？
我只想在这个模板中更改队列名和主机名。但是，如果我在XML模板中修改并上传它，它就无法工作。
<?xml version="1.0" encoding="UTF-8" standalone="yes"?>
<template encoding-version=&#
浏览 0提问于2018-02-06得票数 0
连接Minifi++实例到C2 (命令和控制)服务器有问题。
我已经设置了一个安全的Nifi实例，并且成功地设置了minifi++实例和minifi-C2实例，这两个实例都直接连接到Nifi实例。
我已经验证了手动配置的Minifi是否正确地通过S2S发送。
我还验证了C2服务器可以提供一个配置好的模板(至少在从具有正确凭据的浏览器完成请求时如此)。
现在我已经放弃了所有的连接/网络和身份验证问题，剩下的唯一的事情就是启用Minifi中的c2配置选项。
nifi.remote.input.secure=true
nifi.security.need.ClientAuth=true
nifi.s
浏览 2提问于2020-07-27得票数 0
我正在开发一个大量使用Apache1.10.0的NiFi项目。我厌倦了点击数百个进程组来应用本质上相同的小补丁。
我最近发现了远程进程组，我想知道是否有一种方法将NiFi实例连接到自身并以这种方式实现DRY？我正在考虑在根组件中实现重复组件，并在其他进程组中使用远程访问来访问它们。这个是可能的吗？
现在我只得到SSLHandshakeException / PKIX path building failed
如果有其他方式实现干法-请告诉我。
浏览 4提问于2020-06-26得票数 2
回答已采纳
如何使用JettyWebSocketClient版本1.12.0在nifi中传递授权承载者JWT令牌？无法看到添加安全websocket连接令牌的任何属性.尝试使用"+“添加自定义属性，但websocket客户端出现错误消息时无效，错误消息是不支持该属性。
尝试在密码属性中传递JWT令牌，但始终得到403禁止的错误。
浏览 7提问于2022-11-10得票数 0
1回答
在安全群集中使用Nifi
、、、
我正在尝试使用星火流来读取安全集群中的Nifi数据。我通过在SSLContext中添加SSLContext来进行身份验证，但是SSLContext是不可序列化的。
我的代码如下：
def main(args: Array[String]) {
val pKeyFile = new java.io.File("/path/to/file-cert.pfx")
val pKeyPassword = "password"
val keyStore = java.security.KeyStore.getIns
浏览 4提问于2016-10-11得票数 1
回答已采纳
我将nifi和nifi注册中心设置到不同的服务器上，它们与https和cert授权和身份验证很好地通信。
现在，对于另一个需要与相同的nifi注册中心通信的nifi，我面临着完全相同的设置问题。问题是，新的nifi是在一个限制区域，与http_proxy。我为这个问题找了很多天的答案。我在这方面的文档里找不到任何东西。在nifi中的控制器设置/注册表-客户端，有什么方法可以告诉nifi，通信将通过http_proxy而不是直接？文件上没有提到这一点。也许人们以另一种方式面对它？还是简单是不可能的？
nifi和nifi-注册表的版本为1.15.3。
浏览 10提问于2022-01-31得票数 0
我已经创建了自定义处理器，在其中从上游连接读取文件，并在读取完成时将其删除。
在这里我尝试删除文件的代码。
String input_File="C:\File\Filename.txt";
File delete_Files= new File(input_File);
delete_Files.delete();
但是我不能在Apache Nifi only.If中删除文件，我已经在java api中使用了相同的方法，它可以删除文件。
有人能建议我在Apache Nifi中阅读后删除文件吗？
浏览 15提问于2017-03-16得票数 1
回答已采纳
在apache 1.10源代码中，我可以在nifi-nar-bundles/nifi-druid-bundle/nifi-druid-processors/src/main/java/org/apache/nifi/processors/druid/PutDruidRecord.java中找到PutDruidRecord代码
但是，我在nifi 1.10 ui 中找不到这个处理器
有人能给我建议吗？
浏览 2提问于2019-12-11得票数 1
回答已采纳
我们已经开始在很多数据管道作业中使用NiFi。在Nifi中具有挑战性的事情之一是对流的变化进行回归测试。
处理NiFi流的单元测试和功能测试的常见方法是什么？有什么框架吗？
浏览 0提问于2019-07-16得票数 6
我在码头上有一个安全Nifi的实例。我可以访问它的UI，但不能通过NiFi实例访问它。在注册表客户端部分添加注册表url并尝试访问其存储桶后，我看到以下错误：
Unable to obtain listing of buckets: javax.net.ssl.SSLHandshakeException: java.security.cert.CertificateException: No subject alternative names matching IP address 172.17.0.5 found
172.17.0.5是码头网络中的Nifi-注册表ip地址.
我用这
浏览 0提问于2019-09-11得票数 2
使用Nifi，我想：
运行了一个Python脚本，该脚本导出熊猫的dataframe ，例如通过ExecuteStreamCommand将其发送给各种即插即用的Python脚本，这些脚本输入和输出熊猫的数据，但不知道它们是通过Nifi运行的，而且我无法修改它们以使用STDIN/STDOUT代替大熊猫。将输出数据传递给进一步处理。
这个是可能的吗？如果是这样的话，是怎么做的？
换句话说：
First Script: flowfile -> -> Many: with withLast：-> flowfile
浏览 1提问于2020-05-13得票数 2
我陷入了一个问题，NIFI服务就是拒绝启动。我监控了nifi-app.log，发现是OutOfMemory错误。我在bootstap.conf文件中增加了内存。但是这个错误仍然存在。
附件是nifi-app.log
2017-12-19 17:08:37,133 ERROR [ActiveMQ InactivityMonitor ReadCheckTimer] org.apache.nifi.NiFi An Unknown Error Occurred in Thread Thread[ActiveMQ InactivityMonitor ReadCheckTimer,5,main]:
浏览 57提问于2017-12-20得票数 6
回答已采纳
1回答
在windows中配置了NiFi 1.1.1版本。
我已经使用以下属性启用了客户端证书
nifi.properties
nifi.web.war.directory=./lib
nifi.web.http.host=
nifi.web.http.port=
nifi.web.https.host=hostname
nifi.web.https.port=8080
nifi.web.jetty.working.directory=./work/jetty
nifi.web.jetty.threads=200
nifi.security.keystore=./conf/ssl/server.ke
浏览 4提问于2017-03-08得票数 3
回答已采纳
理解Apache可以与NiFi集成，如所示。NiFi使用加载Spring应用程序上下文。
问: NiFi能否与Spring集成？具体来说，NiFi处理器是否可以流向调用Spring应用程序的处理器，然后再流回NiFi处理器？如果是这样的话，是否有任何样本来证明它？
注意:这种集成不是关于NiFi调用Spring的，如所示。
浏览 0提问于2018-08-29得票数 3
回答已采纳
我在Docker中有独立的安全NiFi 1.12.1，运行很好。我成功地使用了站点对站点的远程处理器，Nifi公告的点对点转发，调用NiFi API进行自我监控等等。我通过证书登录。到目前为止一切都很好。
当我尝试使用时，问题就出现了。我可以访问两个实例:安全和不安全。
无论我指定了什么确切的格式(FQDN，只是一个名称，是否带有/ NiFi -注册表)，当我尝试从NiFi访问(例如，通过导入一个进程组)或者NiFi注册中心时，它在o.a.n.w.a.config.NiFiCoreExceptionMapper org.apache.nifi.web.NiFiCoreException: Un
浏览 2提问于2021-03-24得票数 0
有没有办法使用Java API动态修改NiFi流？用例是将处理器添加到活动数据流(数据流经该数据流)。新处理器应在流程开始时添加，而不会造成应用程序中断或停机。
如果Java API不可用，请随时建议替代方案。我已经看过了。谢谢。
浏览 3提问于2018-07-25得票数 0
1回答
我需要将当前的流版本(如NiFi注册表中的版本号)放在每个流文件的属性上。
我知道我可以使用表达式语言获得系统属性。是否有包含当前版本的属性？
浏览 1提问于2020-03-23得票数 0
回答已采纳
我需要将一堆json文件流式传输到Nifi，然后Nifi再转到HDFS。Nifi需要查看json文件中的创建日期(UNIX格式)，然后将其路由到适当的HDFS文件夹。到目前为止，我的处理器设置如下： 消费Kafka -> RouteOnContent (使用正则表达式^"creationDate"：\"0-9{4}-0-9{2}-0-9{2}$) -> PutHDFS 每天都有一个HDFS文件夹，比如"2019-01-28"，"2019-01-29"，"2019-01-30“等等。然而，"PutHDFS”处理
浏览 15提问于2019-01-29得票数 0
在GitHub操作中的工作流结束时，一个“隐藏”"post“作业似乎正在运行，我似乎找不出如何忽略或覆盖它。例如，当actions/checkout@v2操作完成时，它似乎运行了以下操作：
Post job cleanup.
/usr/bin/git version
git version 2.25.1
/usr/bin/git config --local --name-only --get-regexp core\.sshCommand
/usr/bin/git submodule foreach --recursive git config --local --name-only
浏览 7提问于2021-12-26得票数 6
我使用的是nifi 1.1.0，并且在上面运行了太多的处理器，所以它有太多的负载无法运行。由于负载过大，处理器运行非常慢，我收到一些错误：
The rate of the dataflow is exceeding the provenance recording rate. slowing down flow to accommodate.
我在"nifi.properties“文件中更改了起源存储库的存储大小，但没有任何改进。我更改了以下属性：
nifi.provenance.repository.max.storage.size = 2 GB
我用谷歌搜索了一下，但没有找到合适的
浏览 2提问于2017-06-23得票数 5
1回答
当下一个处理器无法接收或处理任何数据时，有人能详细解释NiFi处理器(如GetFile或QueryDatabaseTable )是如何存储行的吗？当数据的大小超过某个阈值时，数据会在内存中通过管道传输到磁盘上吗？它是否有耗尽内存或丢失数据的风险？
浏览 4提问于2017-05-15得票数 5
回答已采纳
我对apache/nifi很陌生，运行它时：
docker run --name nifi -p 8081:8080 -d apache/nifi:latest
然后拖了一些处理器。然后，我尝试使用以下方法将它们保存为新图像：
docker commit [container ID] apache/nifi:latest
但是，当我运行新提交的映像时，它不会保存更改。如果有任何错误，请通知我。提前谢谢。
更新
一开始，我推出了nifi，包括：
docker run --name nifi -p 8081:8080 -d apache/nifi:latest
这是我在web中添加的组：
浏览 0提问于2019-08-16得票数 2
回答已采纳
我在文本文件(sftp server)中有一些(sftp server)，希望将这些值存储在memory或global variables中，以便在所有ExecuteScript处理器中使用。我有超过20 ExecuteScript基于不同类型的数据路由，我需要在这些处理器中使用这些key value pairs。我不能将这些值存储为NiFi全局变量，因为对于NiFi数据流的每次运行，文件内容并不相同。
我期待的方式是当我的NiFi流启动时，这些文件内容必须存储somewhere(memory/variables)，这样我就可以在我的所有脚本中引用它。
这能办到吗？如能就此提出任何意见或建议，
浏览 27提问于2020-01-15得票数 1
我一整天都在当地码头的集装箱里做Nifi流。完成后，我以json文件的形式下载了流，并杀死了容器。现在，我希望它能够导入我在Kubernetes上的Nifi实例。不幸的是，使用模板似乎是可行的。所以我想作为JSON文件函数的下载流程是单向的吗？或者这个功能的目的是什么？
有办法将这个JSON转换成template.xml吗？否则我得重新做我所有的工作。
浏览 3提问于2021-01-06得票数 1
使用DELETE /buckets/{bucketId}/flows/{flowId}时， 不能删除版本为0的流。 例如，不能通过上面的http调用删除类似以下流程的内容。 {
"bucketIdentifier": "6a0f624c-3163-496e-bb60-9ca4fe287654",
"bucketName": "flow_bucket",
"createdTimestamp": 1550243254914,
"description": "A
浏览 9提问于2019-02-18得票数 1
回答已采纳
我为我的文档创建了Azure CosmosDb数据库和容器。我使用NiFi作为主要的数据摄取工具，并希望为我的容器提供来自NiFi流文件的文档。有没有人可以分享一下从NiFi向Azure Cosmos Db发布流文件内容的方法？
提前感谢
更新(2019.05.26)：最后我使用了Python script，并从NiFi调用它来发布消息。我传递了一条消息作为参数。我选择python的原因是因为它在微软官方网站上有一些示例，其中包含所有必需的连接设置和库，因此很容易连接到Cosmos。我尝试了Mongo组件，但无法连接到Azure (安全配置不起作用)，并没有用得太远，因为Python脚本工作得
浏览 5提问于2018-12-09得票数 1
我想编写nifi处理器，它可以从hdfs目录中读取xml文件，然后将其数据提取到流文件属性中，如果有两个nifi处理器可以获取该文件并读取数据或写入其中的情况，那么如何实现文件锁定，以便一次只有一个处理器可以使用它？你能给我提供任何可以帮助我的文章、代码示例或相关资料吗？我还没有写任何自定义处理器。
浏览 5提问于2017-09-30得票数 1
我对NiFi…有一点挑战。准确地说是MiNiFi。我们使用MiNiFi将日志从远程系统传送到NiFi实例，从那里传送到Kafka，并传送到Elasticsearch。我们可以在没有https的情况下成功地做到这一点，但是，最近我被授权使用https安全地完成同样的任务。
使用证书，我可以连接到NiFi UI，挑战是MiNiFi无法连接到远程NiFi上的RPG，错误是“由于:接收到致命警报:handshake_failure而无法与URI 上的远程NiFi通信”。我怀疑这是因为下面的错误
2018-07-23 16:27:23,083 INFO主o.apache.nifi.controller.
浏览 2提问于2018-07-23得票数 0
回答已采纳
Nifi processor不会从没有记录的Parquet文件继承模式。我们尝试通过继承模式来使用将拼图文件转换为csv。
我们在hive上执行"create table as select“CTAS，并将结果写入HDFS中的拼图文件中。然后，我们尝试使用Nifi FetchParquet处理器读取这些文件。
这对于包含记录的文件很有效。即使模式包含在地块文件的元数据中，不包含记录的文件也将失败。为了保持一致性，应该可以将其转换为仅包含标题作为内容的csv文件。
有什么建议可以以一致的方式处理这个问题吗？
浏览 12提问于2019-07-06得票数 0
我已经下载并设置了Apache 1.16.3，但是当我尝试运行命令使用NiFi中的Git设置单个用户用户in和密码(nifi.sh set-single-user-credentials)时，我会收到以下错误：Error: Could not find or load main class org.apache.nifi.authentication.single.user.command.SetSingleUserCredentials
我还尝试通过显式调用java来运行解决方案命令，但没有成功。
更改用户名和密码的功能在Windows上无效吗？
浏览 22提问于2022-07-27得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM活动推荐
腾讯云开发者
