I have a linux command like this which works in a normal terminal.   (head -1 -; diff --unchanged-group-format= --old-line-format= --new-line-format=%L --unidirectional-new-file --speed-large-files recordsYesterday.csv -) < recordsToday.csv   I want to immitate such command in ExecuteStreamCommand. The recordsToday.csv will of course be replaced with the flowfile content.   I tried doing it like this but it does not work. Any help would be appreciated. Thank you. ... View more

I am try to connect to sftp via ssh keys. The problem is that the keys provided to me does not have passphrase and NiFi PutSFTP processor is asking for one. I have tried setting the field to an empty string but NiFi is saying that passphrase field cannot be empty.   Anyone knows a workaround? I really need to use these ssh keys provided to me. I cannot generate new keys with passphrase. ... View more

    @Grab('net.lingala.zip4j:zip4j:2.2.8') import net.lingala.zip4j.io.outputstream.ZipOutputStream; import net.lingala.zip4j.model.ZipParameters; import net.lingala.zip4j.model.enums.EncryptionMethod; import org.apache.commons.io.IOUtils flowFile = session.get() if(!flowFile) return flowFile = session.write(flowFile, {inputStream, outputStream -> byte[] inputByteArray = IOUtils.toByteArray(inputStream) ByteArrayOutputStream outputByteStream = new ByteArrayOutputStream() ZipOutputStream outputZipStream = new ZipOutputStream(outputByteStream, "password".toCharArray()) //init the zip parameters ZipParameters zipParams = new ZipParameters() zipParams.setEncryptFiles(true) zipParams.setEncryptionMethod(EncryptionMethod.AES) zipParams.setFileNameInZip("records.csv") outputZipStream.putNextEntry(zipParams) outputZipStream.write(inputByteArray) outputZipStream.closeEntry() outputZipStream.close() outputByteStream.close() outputStream.write(outputByteStream.toByteArray()) } as StreamCallback) session.transfer(flowFile, REL_SUCCESS)     I am zipping a csv file with password using ExecuteScript written in groovy. The ExecuteScript processor is able to pass the flowfile to the next processor without problem but the PutSFTP processor is complaining. I get the following error. The file is saved in SFTP nonetheless but its corrupted so I can't unzip it. ... View more

Output of attributesToJson is:   {"disconnectedNodeAcknowledged":"true","state":"STOPPED","revision":"{\"clientId\":\"f4b30e7b-016e-1000-7c5e-310be411ae67\",\"version\":9}"}   when it should be   {"disconnectedNodeAcknowledged":"true","state":"STOPPED","revision":{"clientId":"f4b30e7b-016e-1000-7c5e-310be411ae67","version":9}}   As you can see the revision property is encoded as string when it should be json. How can I resolve this? ... View more

Which processors in NiFi should help me execute this script in this scenario. scenario: code should run after a processor has has been executed successfully.   fetch('http://localhost:8080/nifi-api/processors/c32238a4-9faf-1e14-d0e8-4cd49944c119').then(data => { fetch('http://localhost:8080/nifi-api/processors/c32238a4-9faf-1e14-d0e8-4cd49944c119/run-status', { method: 'PUT', body: { "revision": { "clientId": "stopProcessor.js", "version": data.revision.version }, "state": "STOPPED", "disconnectedNodeAcknowledged": true } }) });   I thought of using invokeHTTP but I do not have access to the current version. That's why I ended up using a script. If you have ideas on how to simplify the process, please help. thank you! ... View more