Our Community is getting an upgrade! To get everything ready for the relaunch, we’ll be placing the site in read-only mode starting September 21st.
We really appreciate your understanding while we get things set up behind the scenes. Catch up on all the exciting details about the move here.
Need help or have questions? Drop us a line at [email protected]
Created 04-09-2021 08:18 AM
I have this flow that take files from Azure Blob Storage (with ListAzureBlobStorage processor).
Now.. is there some trigger or notification mechanism that indicates that new files to be processed have been uploaded to the Azure blob??
Thank you so much
Created 04-09-2021 06:34 PM
Hello
According to NiFi documentation, everytime the processor performing a listing of blobs, it auto picks up the new data since last run
Scope Description
| CLUSTER | After performing a listing of blobs, the timestamp of the newest blob is stored. This allows the Processor to list only blobs that have been added or modified after this date the next time that the Processor is run. State is stored across the cluster so that this Processor can be run on Primary Node only and if a new Primary Node is selected, the new node can pick up where the previous node left off, without duplicating the data. |
Created 04-09-2021 06:34 PM
Hello
According to NiFi documentation, everytime the processor performing a listing of blobs, it auto picks up the new data since last run
Scope Description
| CLUSTER | After performing a listing of blobs, the timestamp of the newest blob is stored. This allows the Processor to list only blobs that have been added or modified after this date the next time that the Processor is run. State is stored across the cluster so that this Processor can be run on Primary Node only and if a new Primary Node is selected, the new node can pick up where the previous node left off, without duplicating the data. |
Created 04-12-2021 12:15 AM
Hi, thank you.
However, this is the mechanism of every List processor: it keeps track of the files already processed.
Instead, I was wondering if there was a way to start a trigger or a notification to the flow when new ones arrive in the blob.
Thanks