Thanks, @Zaheer N. FYI, one final option I'll throw out there is to use listFile (which was my original suggestion) and do a move/rename in Groovy. Here is a working groovy script in an ExecuteScript processor:
import org.apache.nifi.controller.ControllerService
import java.nio.file.Files
import java.nio.file.Paths
import java.nio.file.StandardCopyOption
/*
WARNING!!! This will OVERWRITE any existing file in the destination directory
REQUIRED FLOWFILE PROPERTIES:
outDir - directory name where the files will go (e.g. /tmp/junk/outdir)
newFilename - what you want the file named (e.g. mynew.jpg)
changeFilenameAttr - optional boolean - default= 1, true or null sets origFilanem=${filename}
and filename=${newFilename}
value of false, 0 or n does not change the filename property.
Also requires filename and orig.filename. These come from the getFile processor.
Note - I wasn't able to getting properties defined in the ExecuteScript processor to work
with Nifi Expression Language (e.g. referencing a property X=${filename} resolved to '${filename}'
rather than the value of filename). The expressions were not evaluated for some reason.
*/
def flowFile = session.get()
if (!flowFile) return
log.info('*************** STARTING RENAME SCRIPT: ')
//*********
def origFilename = flowFile.getAttribute('filename')
def origPath = flowFile.getAttribute('absolute.path')
def sourceFilename = origPath + '/' + origFilename
def outDir = flowFile.getAttribute('outDir')
def newFilename = flowFile.getAttribute('newFilename')
def destFilename = outDir + '/' + newFilename
//*********
try {
log.info('*************** MOVING FILE: ' + sourceFilename + ' TO ' + destFilename)
def source = Paths.get(sourceFilename)
def dest = Paths.get(destFilename)
Files.move(source, dest, StandardCopyOption.REPLACE_EXISTING)
if (flowFile.getAttribute('changeFilename')?.value?.toBoolean) {
//This needs testing/verification
flowFile = session.putAttribute(flowFile, 'origFilename', origFilename)
flowFile = session.putAttribute(flowFile, 'filename', newFilename)
}
log.info('SUCCESSFULLY MOVED FILE: ' + sourceFilename + ' TO ' + destFilename)
session.transfer(flowFile, REL_SUCCESS)
} catch(e) {
log.error('FAILED moveFile.groovy: ' + sourceFilename + ' TO ' + destFilename, e)
session.transfer(flowFile, REL_FAILURE)
}
And, thanks @Shishir Saxena for testing the previous script out.
