tag:blogger.com,1999:blog-42869383794183737.post4112021824574220934..comments2024-03-09T01:04:10.400-08:00Comments on Fun with Apache NiFi: Testing ExecuteScript processor scriptsMattyBhttp://www.blogger.com/profile/05049049725324531534noreply@blogger.comBlogger6125tag:blogger.com,1999:blog-42869383794183737.post-71989584391081090182022-04-07T06:29:57.492-07:002022-04-07T06:29:57.492-07:00jfrog (gag) has taken over bintray. Your link to t...jfrog (gag) has taken over bintray. Your link to the jar is dead.Derek Brouwerhttps://www.blogger.com/profile/05588662446502725544noreply@blogger.comtag:blogger.com,1999:blog-42869383794183737.post-75310174360219305982019-07-17T22:44:53.968-07:002019-07-17T22:44:53.968-07:00Any chance this will be updated for latest version...Any chance this will be updated for latest version of nifi 1.9.xCraighttps://www.blogger.com/profile/02605646007896379619noreply@blogger.comtag:blogger.com,1999:blog-42869383794183737.post-81557742886190812182019-01-18T23:35:03.550-08:002019-01-18T23:35:03.550-08:00Really a great tool, good job man, thank a lotReally a great tool, good job man, thank a lotStephttps://www.blogger.com/profile/09668419117998846522noreply@blogger.comtag:blogger.com,1999:blog-42869383794183737.post-70074351788677669962018-08-08T06:53:21.556-07:002018-08-08T06:53:21.556-07:00I don't understand why I am getting the follow...I don't understand why I am getting the following error on this script: cannot create an instance from the abstract interface org.apache.nifi.processor.io.StreamCallback <br />flowFile = session.get();<br /><br />if (flowFile != null) {<br /><br /> <br /><br /> var StreamCallback = Java.type("org.apache.nifi.processor.io.StreamCallback");<br /><br /> var IOUtils = Java.type("org.apache.commons.io.IOUtils");<br /><br /> var StandardCharsets = Java.type("java.nio.charset.StandardCharsets");<br /><br /> var transformed_message = {};<br /><br /> var error = false;<br /><br /> var line = "ops_Powertrack";<br /><br /> <br /><br /> <br /><br /> // Get attributes<br /><br /> flowFile = session.write(flowFile, new StreamCallback(function (inputStream, outputStream) {<br /><br /> // Read input FlowFile content<br /><br /> var content = IOUtils.toString(inputStream, StandardCharsets.UTF_8); // message or content<br /><br /> var message_content = {};<br /><br /> try {<br /><br /> message_content = JSON.parse(content);<br /><br /> transformed_message.postID = (((message_content || {}).postID || "null"));<br /><br /> transformed_message.contentType = (((message_content || {}).contentType || "null"));<br /><br /> <br /><br /> transformed_message.published = (((message_content || {}).published || "null"));<br /><br /> transformed_message.crawled = (((message_content || {}).crawled || "null"));<br /><br /> transformed_message.providerID = (((message_content || {}).providerID || "null"));<br /><br /> <br /><br /> line = line + " " + "postID=" + transformed_message.postID + ","<br /><br /> + "contentType=" + transformed_message.contentType + ","<br /><br /> + "published=" + transformed_message.published + ","<br /><br /> + "crawled=" + transformed_message.crawled + ","<br /><br /> + "providerID=" + transformed_message.providerID + ","<br /><br /> + " value=" + "1" + " "<br /><br /> + time * 1000000 + "\n";<br /><br /> <br /><br /> <br /><br /> // Write output content<br /><br /> if (transformed_message) {<br /><br /> outputStream.write(line.getBytes(StandardCharsets.UTF_8));<br /><br /> }<br /><br /> } catch (e) {<br /><br /> error = true;<br /><br /> outputStream.write(content.getBytes(StandardCharsets.UTF_8));<br /><br /> }<br /><br /> }));<br /><br /> <br /><br /> <br /><br /> if (error) {<br /><br /> session.transfer(flowFile, REL_FAILURE)<br /><br /> } else {<br /><br /> session.transfer(flowFile, REL_SUCCESS)<br /><br /> }<br /><br />}jdepp99https://www.blogger.com/profile/16653965043717329596noreply@blogger.comtag:blogger.com,1999:blog-42869383794183737.post-6231155883778564422017-06-16T06:58:22.557-07:002017-06-16T06:58:22.557-07:00Hello Matt,
great stuff. Just one question - is i...Hello Matt,<br /><br />great stuff. Just one question - is it possible to set up input flowfile attributes somehow?<br /><br />thx,<br />Leszekleszekhttps://www.blogger.com/profile/00124163056762259050noreply@blogger.comtag:blogger.com,1999:blog-42869383794183737.post-42449370559040535452017-03-31T13:43:35.794-07:002017-03-31T13:43:35.794-07:00This is awesome. Thank you for saving me from hour...This is awesome. Thank you for saving me from hours and hours of debugging a hugeass JS script I was writing into Nifi.Sakshamhttps://www.blogger.com/profile/09917611299090525492noreply@blogger.com