NIFI：编写新处理器

Question

我想做一个新的处理器，它将是GetFile和EvaluateXpath的重聚。有几个主题我感兴趣：

>

现在我的nar文件超过20KB，而我的nifi无法运行它，我该如何缩小它？

我想从文件夹中获取文件，读取它的数据并将其作为一个atribute放入新的flowfile中，然后将配置xml回滚到它的原始文件夹，如何将配置文件回滚到文件夹b代码？

下面是我用来从xml配置文件中获取属性的简单代码：

XPathExpression start = xpath.compile("//*[local-name()='start']");
                XPathExpression startDate = xpath.compile("//*[local-name()='startDate']");
                XPathExpression endDate = xpath.compile("//*[local-name()='endDate']");
                XPathExpression runAs = xpath.compile("//*[local-name()='run']");
                XPathExpression patch = xpath.compile("//*[local-name()='patch Information']");
Object resultStart = start.evaluate(doc, XPathConstants.STRING);
                NodeList nodes = (NodeList) resultStart;
                flowFile = session.putAttribute(flowFile, "start", String.valueOf(nodes.item(nodes.getLength()-1)));

Map attributes=getAttributesFromFile（如果(attributes.size()>0){flowFile=session.putallattributes（flowFile,attributes）；}

但它不能正常工作，我应该改变什么？

Answer 1

正如这里的回答，我不相信这个用例需要定制处理器开发。使用gethdfs和Keep source file:true设置将文件维护在原始位置，并使用executexpath和各种XPath值将数据从内容提取到flowfile属性中。您还可以使用listhdfs和fetchhdfs的组合来将XML文件保存在HDFS中，因为NiFi将维护它所看到的文件的状态。