当前位置: 首页 > 知识库问答 >
问题:

开发和测试新Nifi处理器的快速方法

陈斌蔚
2023-03-14

我正在为我的数据流开发新的Nifi处理器。我在eclipse中修改代码,创建新的。nar文件,并将其复制到Nifi lib中进行测试。

有没有更好的方法来测试你的新。NAR在Nifi?因为每一个小的变化都重启Nifi会降低你的开发速度。

共有1个答案

徐承载
2023-03-14

有几个快速原型和测试选项使Apache NiFi处理器的开发变得更容易。

  1. executescript中建模代码--使用executescript处理器意味着您可以对域相关代码(无论您键入处理器script body属性或由script file引用的文件)进行代码更改,而无需生成任何内容或重新启动应用程序。您可以使用出处重播功能通过更新后的代码重播相同的流文件。您还可以直接使用Matt Burgess的NiFi脚本测试器工具测试脚本。一旦有了可接受的行为,就把脚本主体迁移到可以部署的自定义处理器上。
  2. 使用NiFi的单元测试和集成测试特性--核心框架提供的测试工具和“运行器”将允许您在部署整个应用程序之前模拟自动化测试中的流场景。构建第一个流需要一点时间,但是一旦您这样做了,这是一个可重复和可理解的过程,您可以使用它来覆盖边缘情况并确保所需的行为。
 类似资料:
  • 我想做一个新的处理器,它将是GetFile和EvaluateXpath的重聚。有几个主题我感兴趣: > 现在我的nar文件超过20KB,而我的nifi无法运行它,我该如何缩小它? 我想从文件夹中获取文件,读取它的数据并将其作为一个atribute放入新的flowfile中,然后将配置xml回滚到它的原始文件夹,如何将配置文件回滚到文件夹b代码? 下面是我用来从xml配置文件中获取属性的简单代码:

  • debug populate 测试利器,快速产生大量的key 127.0.0.1:6379> debug populate 10000 OK 127.0.0.1:6379> dbsize (integer) 10000

  • 开发调试 首先安装 Weex 官方提供的 Playground ,这是一款安装在手机(Android & iOS)端的 页面预览和调试工具。 weex-toolkit中包含了调试工具weex devtools,它是专门为Weex定制的一款实现了 Chrome Debugging Protocol 的 inspect/debug 工具,能够帮助你快速查看 app 运行状态和调试 Weex 中的 JS

  • 我正在尝试使用ExecuteSQL处理器从oracle数据库中提取数据。我有一些查询,例如假设在我的oracle数据库中有15条记录。在这里,当我运行ExecuteSQL处理器时,它将作为一个流进程连续运行,并将整个记录作为一个文件存储在HDFS中,并且重复这样做。因此,在HDFS位置中会有许多文件,这些文件将从oracle db中提取已经提取的记录,并且这些文件包含相同的数据。我如何使该处理器以

  • 我正在使用Tailfile处理器从计划每分钟运行的集群(3个节点)中获取日志。日志文件名每小时都会发生变化,我不知道应该使用哪种跟踪模式。如果我使用单个文件,它不会获取1小时后生成的新文件。如果我使用多文件,它是在文件名更改第三分钟后获取文件,这增加了文件的大小。我的文件的滚动文件名应该是什么,我应该使用哪种模式。你能让我知道吗。谢谢。 tail:retrieve-${now():format(“

  • 我在运行FetchElasticSearch处理器时出现了奇怪的错误,下面是错误。 FetChelasticSearch[ID=F2B2FEE3-B940-4A73-8A28-0436E765C9A2]无法读取到Elasticsearch中,原因是没有配置的节点可用:[{#Transport#-1}{127.0.0.1}{localhost/127.0.0.1:9500}],这可能表示配置错误(主