Use the Funnel processor to merge the different queues into a single one and then you can specify more than one file for the get def flowFiles = session.get(10) ... View more

You're running NiFi 2.0.0.X?   ... View more

You can achieve the same with a JOLT shift and this spec: { "*": "&", "meHostName": { "*;*": { "$(0,1)": "case", "$(0,2)": "devicename" } } } ... View more

Kinda neat...didn't know RabbitMQ had introduced "stream" queues...I've always used Kafka for streaming in the past.  However, reading up on it I don't think NiFi has the native Java library/processors to use RabbitMQ streams.  However, the version of the amqp-client that ships with NiFi should be able to support connecting to a streams queue if set up correctly meaning it might be possible to create a custom Groovy processor. https://www.rabbitmq.com/docs/streams ... View more

I've done something similar where I use a custom Groovy processor to handle the file uploaded and posted to the HandleHTTPRequest does something with the data and provides a JSON response to HandleHTTPResponse   ... View more

Looks like custom might not needed since file and path allows for RegEx which means you could define multiple:   ... View more

If I get time, I might see how the current SFTP processor works. From the sounds of it you'd want a processor that can do several file patterns/paths per SFTP host to avoid having hundreds of flows. ... View more

You could implement this using Groovy script which is forward and backward compatible. I've taken code written in NiFi 1.X and works just fine in 2.X ... View more

Looks like NiFi is might be using GitHub - redis/jedis: Redis Java client under the covers so if it can run the commands you asked about, you might be able to build a custom Groovy processor to run them. ... View more