- Subscribe to RSS Feed
- Mark Question as New
- Mark Question as Read
- Float this Question for Current User
- Bookmark
- Subscribe
- Mute
- Printer Friendly Page
Apache Nifi - Trigger/notification for new data on blob storage Azure?
- Labels:
-
Apache NiFi
Created ‎04-09-2021 08:18 AM
- Mark as New
- Bookmark
- Subscribe
- Mute
- Subscribe to RSS Feed
- Permalink
- Report Inappropriate Content
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
- Mark as New
- Bookmark
- Subscribe
- Mute
- Subscribe to RSS Feed
- Permalink
- Report Inappropriate Content
Hello
According to NiFi documentation, everytime the processor performing a listing of blobs, it auto picks up the new data since last run
State management:
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
- Mark as New
- Bookmark
- Subscribe
- Mute
- Subscribe to RSS Feed
- Permalink
- Report Inappropriate Content
Hello
According to NiFi documentation, everytime the processor performing a listing of blobs, it auto picks up the new data since last run
State management:
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
- Mark as New
- Bookmark
- Subscribe
- Mute
- Subscribe to RSS Feed
- Permalink
- Report Inappropriate Content
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
