Datei nicht gefunden Ausnahme

Question

I, in denen bekommen Flowfile wollen, ist Komponenten xml und aktualisieren eine der TagValue i es in benutzerdefinierten nifi Prozessor Code machen, ich habe Code wie folgt:

flowFile = session.putAttribute(flowFile,"filename",file.getName() + ".xml"); 
       InputSource inputSource = new InputSource((InputStream) flowFile); 
       DocumentBuilderFactory builderFactory = DocumentBuilderFactory.newInstance(); 
       DocumentBuilder builder = builderFactory.newDocumentBuilder(); 
       Document xmlDocument = builder.parse(inputSource); 
       XPath xPath = XPathFactory.newInstance().newXPath(); 
       NodeList myNodeList = (NodeList) xPath.compile("//runAs/text()") 
         .evaluate(flowFile, XPathConstants.NODESET); 
       myNodeList.item(0).setNodeValue("false"); 

aber es trows Datei nicht Exception Exception gefunden, was sollte ich ändern, damit dieser Code funktioniert? Ps Ich kann den Pfad für Flowfile nicht verwenden

Answer 1

Die NIFI-Flow-Datei ist kein InputStream.

so dass der Code (InputStream) flowFile falsch ist

, wenn Sie Inhalt der Flow-Datei als Eingabestrom erhalten möchten Sie session.read Methode wie folgt verwenden:

InputStream ffStream = session.read(flowFile); 
...do something with stream 
ffStream.close();