回答情况：
提问时间：
问题标签：
基本上，我想编写自定义处理器，它可以在处理器停止时在flowFile中发送属性。 if (flowFile == null) { }flowFile = session.putAttribute(flowFile, "ATTRIBUTE_SIGNAL", "start");
sessio
浏览 0修改于2019-08-27得票数 1
回答已采纳
... outputStream.write(bytearray(json.dumps(newObj, indent=4).encode('utf-8')))
flowFile2 = session.get() # WHAT SHOULD I PUT HERE??flowFile = session
浏览 9修改于2017-09-01得票数 1
回答已采纳
我正在尝试找出一个人可以做些什么来查看在http上的nifi流中流文件的位置。例如，假设我有一个用户可以上传文件的网页。我想向用户指出该文件当前正在被摄取/处理，以及它可能处于哪个阶段。nifi提供了什么，我可以利用它来获取这些信息？比如，有没有一种方法可以查看流文件经过了哪些处理器，或者它当前所在的处理器/队列？
浏览 0提问于2018-07-21得票数 0
我想从一个Flowfile文本开始，然后在我的过程中完全替换它。如何用一些新的静态内容替换整个Flowfile内容？
詹姆斯
浏览 0修改于2021-09-25得票数 4
回答已采纳
我已经用数据填充了FlowFiles的属性，我想将这些数据放入每个FlowFile内容中包含的Avro元数据中。
我该怎么做？我尝试使用配置了UpdateRecord处理器的AvroReader和AvroRecordSetWriter，以及一个带有/canary键的属性，该属性应该在Avro文档中的某个地方为该键写入FlowFile
浏览 1提问于2018-01-29得票数 1
回答已采纳
我尝试将Avro文件转换为SQL请求。我的文件是这样的： "type" : "record", "doc" : "Schema generated by Kite", "name" : "id", "doc" : "Type inferred fro
浏览 6修改于2018-03-06得票数 0
我需要从NiFi中执行HTTP，但我不希望/不需要请求来携带所有的FlowFile内容。
是否有办法传递FlowFile的属性，但不传递完整的内容？
浏览 3修改于2017-06-17得票数 3
回答已采纳
.*if (flowFile == null) {}
def attrs = [:] as Map<String,String>
{ inputStream ->
def text= IOUtils.toString(inputStream, StandardCharsets.
浏览 2修改于2017-08-17得票数 2
flowFile = session.get(); flowFile,现在有一种方法它创建了一个新的FlowFile。
这让我思考，无论我是否做错了，写在原来的FlowFile。做这件事很简单，所以感觉很好。这是一些代码，它创建了一个新的FlowFile，编写了原始FlowFile</
浏览 2提问于2020-05-25得票数 1
回答已采纳
我想为卡夫卡主题创建一个属性值作为partitionID。例如，我的flow文件属性列表有：account_number作为属性之一。和account_number can have different values eg, 111,222,121 etc。然后，111, 222, 121 etc将成为我的卡夫卡主题的PartitionID，因为我希望得到按时间戳排序的消息。我在nifi的PublishKafka__10处理器中找不到任何选择。提前感谢
浏览 0提问于2018-06-11得票数 0
回答已采纳
FlowFile规模的考虑因素是什么？它会影响I/O吗?如果提供足够的内存，它是否越大越好？因为每个FlowFile的NIFI都会从磁盘持续到内存？有了设置，一个FlowFile可以包含多个事件，如果没有它，一个FlowFile只包含一个事件。比方说，如果FlowFile包含1000个json对象，性能会比1个json对象更高吗？community.hortonworks.com/questions/21011/how-i-extract-attribute-fro
浏览 14提问于2019-01-18得票数 0
回答已采纳
我正在尝试理解NiFi数据流机制。我读到Nifi有包含内容和元数据的flow文件(flow file属性)。
浏览 6提问于2016-09-10得票数 1
回答已采纳
找到了一种处理传入的xml并使用XmlSlurper解析它的方便方法，但是对于传入的流文件，得到以下GroovyScript的警告-处理器详细信息：
脚本正文：InputStream i = flowFile.read()i.close()
REL_SUCCESS << flowFile
浏览 1修改于2018-07-25得票数 1
回答已采纳
我有ExecuteScript的输出FlowFile #1和另一个ExecuteScript的输出FlowFile #2。FlowFile #1 "field1": "val",}{}
我应该使用哪个处理器来将field1在FlowFile #1中的值替换为FlowFile<
浏览 2修改于2017-09-07得票数 2
我试图做一些相当简单的事情，从传入的i9中读取FlowFile PDF表单，将其中的名字和姓氏解析为JSON，然后将JSON输出到传出的FlowFile。org.apache.pdfbox.pdmodel.PDPageimport java.nio.charset.StandardCharsetsflowFile = session.write(flowFile, { inputStream
浏览 1修改于2018-08-09得票数 1
回答已采纳
在我的Nifi1.3.0数据流中，FetchElasticsearchHttp处理器将filename属性更改为其在数据库中的对应ID。我想知道有没有办法用一些Nifi的内部处理器把它改回来。
浏览 2提问于2017-07-09得票数 0
回答已采纳
是否有一种简单的方法可以将Flowfile的所有属性转储出去，或者只浏览一个Flowfile？
浏览 0修改于2021-09-25得票数 12
回答已采纳
错误总是相同的：在日志中搜索时，我总是看到以下错误：org.apache.nifi.processor.exception.ProcessException: <
浏览 0提问于2018-07-12得票数 6
回答已采纳
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号