可以从java应用程序调用Apache处理器或HandleHttpRequest吗？另外，如何从java应用程序向ListenHTTP“远程URL”属性发送自定义参数？如何将参数通过URL传递给Nifi处理器组？以及如何通过该URL启动处理器组。http:/
浏览 2提问于2020-06-08得票数 1
回答已采纳
我有一个处理器，它依赖于某个jar作为依赖项。但是，对依赖jar的更改非常频繁。因此，我希望能够将jar路径指定为处理器的属性，并让nifi在每次修改属性中的路径并重新启动处理器时加载jar。正如在中所解释的那样，使用应该是可行的。然而，我无法做到这一点。下面是我使用dynamicallyModifiesClasspath属性编写的</e
浏览 0提问于2019-05-27得票数 2
回答已采纳
配置GetHTTP处理器的选项看起来很适合连接到第三方API。我需要发送用户名(可用)，密码(可用)和一个代表数据库名称的第三个字符串值。这个处理器有一个“新属性”选项，我认为它可以用于数据库字符串，但是，它似乎是在寻找一种特定类型的属性。我得到的警告消息是：“数据库”对“mydatabasename”进行验证是无效的，因为“database”不是受支持的属性。有什么建议吗？而且，一旦响应返回，我将
浏览 4提问于2017-06-10得票数 2
回答已采纳
1回答
我需要使用docker(特别是nifi-1.17.0)自动化nifi引导。我希望能够在每个新容器实例上加载一个模板，而不是运行新实例，然后登录到UI并手动更改所有设置，我希望在bash脚本中自动加载模板。我需要的是更新控制器服务的字段和一个处理器的属性。我理解我的工作流程是这样的:停止处理器禁用控制器服务更新控制器服务启用控制器服务启动处理器停止处理
浏览 25提问于2022-11-07得票数 0
我正在探索Apache NiFi，并就处理器是如何调度的提出了一些问题，nifi.bored.yield.duration=10 millis -此属性旨在通过防止使用</em
浏览 4提问于2020-10-14得票数 0
我正在使用Nifi将数据路由到Elasticsearch。我使用NiFi动态创建基于一组属性的索引。我在Elasticsearch中使用索引生命周期策略管理( Index )，它要求所有索引都必须事先手动引导，才能应用ILM设置。目前，我的流程是Nifi从Kafka -> Update属性-> PutElasticsearch记录中消费的。一个解决方案
浏览 11提问于2022-02-14得票数 0
我需要使用Nifi动态更新RouteonAttribute处理器属性的帮助。例如，如果我发送Sensor_value:50，RouteonAttribute必须自动设置如下属性你们能帮我吗？
谢谢你们
浏览 0提问于2020-01-30得票数 0
我一直试图访问NiFi流量文件属性从卡夫卡消息在星火流。我使用Java作为语言。场景是，NiFI使用GetSFTP处理器从FTP位置读取二进制文件，并使用publishKafka处理器将byte[]消息发布到Kafka。这些byte[]属性使用火花流作业转换为ASCII数据，这些解码后的ASCII被写入Kafka进行进一步处理，并使用NiFi<e
浏览 9提问于2017-06-09得票数 1
回答已采纳
我正在使用PublishKafka_2_0处理器，在连接到Kafka时需要禁用SSL端点识别算法。在中，我可以通过将以下producer属性设置为空字符串来完成此操作：PublishKafka_2_0的文档提到可以使用动态属性来设置它有人能演示如何设置这个属性吗？截图或链接到一个例子将是很好的<
浏览 0提问于2019-07-09得票数 0
回答已采纳
为什么有些NiFi处理器不允许动态属性？我在我的一个工作流中使用了FetchFile processor，我需要在整个流程中传递一些数据，以便能够在最后一步中使用它。但是，FetchFile通过不允许使用动态属性打破了这一点。我想知道有没有别的办法？为什么NiFi不允许在某些处理器上使用动态属性？我的流程是这样
浏览 3提问于2016-07-17得票数 2
回答已采纳
1回答
我正在尝试使用配置文件自定义kylo中可用的标准数据摄取模板。我在kylo/conf目录中的application.properties文件中添加了字段名nifi.getfile.business_line1=Test。当我试图在处理器${ business_line1 }中使用nifi表达式时，它将抛出为“business_line1未找到”。
或者，还有其他方法来提供自定义标准数据吗？
浏览 3提问于2017-08-16得票数 3
回答已采纳
我正在使用NiFi中的一个NiFi处理器来使用我指定的with文件执行PUT命令。但是，现在当文件大于2GB时，我会得到一个OutOfMemory异常。我在NiFi上的内存设置要高得多。我还看到了更大的流文件与其他一些提供的Nifi处理器一起工作。
我不能使用InvokeHTTP，因为我有两个不同的返回代码，它
浏览 0提问于2019-08-22得票数 0
回答已采纳
我有一个文件，其中包含txt格式的数据，文件中的每一行都是1条记录。我正在使用拆分文本处理器将流文件拆分成1条记录/文件。 我想从记录中提取一个子串。我需要从开始到第n个索引获取一个子串。我在这里使用默认设置，除非我尝试添加一些在线论坛中提到的属性(att1)。这没用的。 请帮帮我
浏览 24提问于2020-11-18得票数 0
回答已采纳
1回答
我试图在Apache中创建一个自定义处理器(用Java)来读取用户的自定义属性。是否可以创建一个处理器来提取用户密钥值对？如果是这样的话，我应该如何提取它们呢？是存储在某个nifi.processer库中的字典中的用户自定义属性。
理想情况下，我希望提取上述所有输入的属性和值的动态值。即。{“自定义属性</em
浏览 1提问于2019-04-26得票数 1
回答已采纳
我在jira上看到了这个，但它引用的是java。有没有办法用服务器上的线程映射nifi进程，这样我就可以手动关闭它了吗？
浏览 4提问于2017-09-20得票数 3
回答已采纳
从NiFi 1.7.1开始，新的支持动态选择数据库连接:在FlowFile上设置属性database.name，当使用处理器访问已配置的DBCPConnectionPoolLookup控制器服务时，该属性的内容将用于通过此查找的已配置属性获取连接，这些属性包含潜在值到控制器服务的映射。我想列出在查找中配置的每个数据库中的
浏览 8提问于2018-08-15得票数 1
回答已采纳
我对使用NiFi相当陌生。我们试图验证一个xmlfile，但我们需要使用不同的xsd，这取决于文件中传递的一些值。对名称进行提取和路由不是问题，我们将所需的文件路径存储在一个属性(xsdFile)中。XMLValidation处理器属性：
Schema File: ${
浏览 0提问于2019-09-03得票数 1
回答已采纳
我已经创建了几个自定义NiFi处理器，但是无法获得要生成的使用文档。“使用”文档指的是右键单击处理器并选择“使用”，这将显示有关该特定处理器的文档。将显示文档面板，但我的自定义处理器都不存在。我在我的自定义处理器类上使用了几个NiFi文档标记，包括几个读/写属性。代码编译和单元测试没有任何问题。构建报
浏览 1提问于2019-08-16得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
