import groovy.json.*
if(!这只是数据和日期的一个值，但会有很多： { "data" : "119050300", } ]
} 如何使用上述脚本将我的日期转换为日期时间格式
浏览 7提问于2019-06-11得票数 0
回答已采纳
我正在做一个与Apache NIFI的集成工作，我们偶然发现需要做双向TCP。在此之前，我们只使用单向TCP。(传统产品A) -TCP- NIFI (NIFI魔术)- TCP- (传统产品B)
所以..。我正在考虑采用上述支持TCP和其他域的NIFI，并将其简化为只支持TCP。创建专用TCP模块。我假设这会比从头开始写这篇文章要
浏览 33提问于2017-07-21得票数 2
1回答
我在nifi的执行脚本处理器上工作。我将lastdate声明为2020-12-21，并尝试在执行脚本(groovy)文件中使用此属性从oracle获取数据。 在oracle中，它给了我正确的结果。在nifi中走向失败。我的代码(脚本体)： def last_data = flowFile.getAttribute('last_date')
query = "select t.* from mytable
浏览 17提问于2020-12-29得票数 0
我使用远程nifi进行基于ssl的身份验证，是否可以使用nifi处理器和groovy代码来生成rest命令。我已经在简单的nifi中(在我的桌面上)停止了处理器并删除了队列中的坏流文件，但是我不能在远程nifi上执行，我不能使用ssl证书连接服务器
不管怎么说，我可以摆脱身份验证吗?我不使用curl命令，我想在nifi中通过invokehttp处理器和groovy代码来完成它。
浏览 2提问于2017-08-29得票数 0
通常，当我必须向RestAPI发布多个包含multipart/form-data的文件时，我会使用如下所述的ExecuteGroovyScript：
我没有此NiFi服务器的管理员访问权限，也无法更改NiFi配置，因此无法修复GroovyScript错误
问:是否可
浏览 0提问于2021-05-14得票数 1
1回答
我对Apache NiFi执行脚本处理器有问题。我正在向输出流写入一个Json字符串。但是，在Nifi上执行时，我会得到一个错误，如下所示：
import groovy.json.JsonBuilder
import org.apache.commons.io.IOUtilsimport java.nio.charset.Stan
浏览 4提问于2020-11-12得票数 0
回答已采纳
NiFi的生产实例是版本1.8.0。我们有一个自定义处理器，它不断地查看下游连接，以便根据连接的队列大小路由流文件。class org.apache.nifi.contoller.serviceStandardContollerServiceProvider cannot be cast to classorg.apache.nifi.reporting.EventAccess
浏览 4提问于2021-05-14得票数 0
回答已采纳
我正在使用NiFi中的一个NiFi处理器来使用我指定的with文件执行PUT命令。但是，现在当文件大于2GB时，我会得到一个OutOfMemory异常。我在NiFi上的内存设置要高得多。我还看到了更大的流文件与其他一些提供的Nifi处理器一起工作。java.arg.2=-Xms16g以下是
浏览 0提问于2019-08-22得票数 0
回答已采纳
1回答
我正在使用nifi处理csv文件，在这里，我希望使用groovy脚本或replaceText处理器在int值之前修剪空格。任何帮助都将不胜感激。
浏览 0提问于2018-08-13得票数 0
1回答
示例：{col1，col2，col3，col4} => {col1，加密(Col2)，col3，encrypted(col4)}在<em
浏览 0提问于2018-11-05得票数 1
回答已采纳
1回答
我想知道在nifi中线程是如何工作的，我的意思是一个处理器有一个线程，或者它们在一个主线程中？，也许我想从处理器获得一个文件，然后更新它。除了使用processor =false操作之外，如何防止一次由多个处理器获取文件数据？
File file = new File("C
浏览 2提问于2017-10-20得票数 2
回答已采纳
想知道如何为NIFI创建python插件。nifi有没有什么库/模块/包，就像pysow对servicenow一样？
浏览 26提问于2020-06-04得票数 0
试图找出是否可以通过apache NiFi或Streamset来实现连接。这样，我就可以定期从HBase读取数据，加入其他表，并将少量字段写入Hive表中。
浏览 3提问于2017-05-03得票数 0
回答已采纳
我用的是执行器处理器。flowFile.getAttribute('file.creationTime')返回null。知道如何获取流文件的file.creationTime属性值吗？
浏览 0提问于2018-08-22得票数 0
回答已采纳
我可以在运行时将一个新处理器加载到Apache NiFi中，而且，在运行的Apache NiFi实例中是否可以更新已经加载的处理器？我来自Erlang背景，在那里，BeamVM实际上可以促进热模块替换和状态更新。这是一个复杂的话题，但有可能。
最好至少能够将新代码加载到正在运行的NiFi实例中，而不必在应用新处理器时停止集群。我发现的一个可能的解决方法(虽然不是首选)是使用脚本处理器，它可以通过其属性在运行时设置/更新代码。
浏览 0提问于2019-01-18得票数 0
回答已采纳
我想在base64 json内容中解码动态大小数组的NiFi编码字符串值。然而，在我的NiFi版本中，它不包含NiFi记录路径的"base64Decode“函数.如何使用流数据编写groovy / python脚本。
浏览 5提问于2022-08-09得票数 1
我希望使用可用于将输入转换为输出的JoltTransformJSON规范。预期输入： "params": "sn=GH6747246T4JLR6AZ&c=QUERY_RECORD&p=test_station_name&p=station_id&p=result&p=mac_addresss"预期输出： "queryType": "scan",
"dataSource
浏览 5提问于2018-07-26得票数 0
1回答
当MFA处于活动状态时，是否可以使用NiFi处理器PutS3Object将数据写入S3桶中？
如果不是，那么考虑从hive/HDFS向S3写入数据的替代方案是什么呢？
浏览 0提问于2018-11-28得票数 1
回答已采纳
我有这个示例R scraper脚本(我不能使用实际的网站)： else ("He's dead, Jim")
我通过Apache NiFi( ExecuteProcessor处理器)在docker容器中运行这个脚本。BufferedInputStream.java:345)
at java.io.FilterInputStream.read(Filter
浏览 1提问于2019-02-22得票数 4
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
