🇮🇹 IT

🗂️ Local File Watch

Monitora una directory sul filesystem del server alla ricerca di nuovi file tramite eventi del filesystem. Avvia un'esecuzione del workflow ogni volta che viene rilevato un nuovo file. Utile per elaborare file scritti da altri servizi sulla stessa macchina.

Categoria: Trigger · Identificatore tipo: local_file_watch

Panoramica

Il trigger Local File Watch ascolta gli eventi del filesystem sul server dove Flusso e in esecuzione. Quando un nuovo file viene creato nella directory configurata, Flusso avvia immediatamente un'esecuzione del workflow con i dettagli del file come variabili di output. A differenza dei trigger file basati su cloud, questo nodo non usa il polling — reagisce alle notifiche del filesystem quasi in tempo reale.

Questo e il trigger giusto quando altri servizi sullo stesso server producono file di output: un job di esportazione legacy scrive CSV in una directory, un server FTP riceve caricamenti in arrivo, o uno script genera report secondo una pianificazione. Anziche integrare quei servizi in un nuovo connettore, semplicemente punta il Local File Watch alla directory e lascia che Flusso reagisca.

Il processo Flusso deve avere accesso in lettura alla directory configurata. Se l'opzione Move After Processing e abilitata, richiede anche accesso in scrittura per creare la sottodirectory processed/.

Configurazione

Campo	Stato	Descrizione
Directory Path	Obbligatorio	Percorso assoluto sul server, ad es. `/var/data/incoming`. Il processo Flusso deve avere accesso in lettura a questo percorso.
Pattern	Opzionale	Pattern glob da abbinare, ad es. `.csv`. Predefinito: `` (tutti i file).
Move After Processing	Opzionale	Attiva/disattiva. Quando abilitato, sposta il file in una sottodirectory `processed/` dopo l'avvio dell'esecuzione del workflow per prevenire trigger duplicati.

Dati di Output

Ogni esecuzione del workflow attivata da questo nodo riceve i seguenti campi che descrivono il file appena rilevato.

Campo	Tipo	Descrizione
`file.path`	string	Percorso assoluto del nuovo file
`file.name`	string	Nome del file con estensione
`file.size`	number	Dimensione del file in byte
`file.detected_at`	string	Timestamp ISO 8601 di quando il file e stato rilevato

{{ trigger.output.file.path }} {{ trigger.output.file.name }} {{ trigger.output.file.size }} {{ trigger.output.file.detected_at }}

Esempio di Utilizzo

Monitora /var/exports/ per nuovi file .csv depositati da un sistema legacy, poi analizza e importa i dati.

Aggiungi un trigger Local File Watch. Imposta Directory Path su /var/exports, imposta Pattern su *.csv e abilita Move After Processing per prevenire la rielaborazione.
Aggiungi un nodo HTTP Request. Usa {{ trigger.output.file.path }} nel corpo della richiesta per indicare al tuo servizio di importazione quale file leggere.
Aggiungi un nodo Email Notification per avvisare il team quando un'importazione viene completata. Includi {{ trigger.output.file.name }} nel corpo del messaggio.

Suggerimenti e Note

Rilevamento quasi in tempo reale. A differenza dei trigger basati su polling, Local File Watch reagisce agli eventi del filesystem. Il rilevamento avviene tipicamente entro un secondo dalla creazione del file.
Evita di monitorare directory ad alto volume. Se una directory riceve migliaia di file al minuto, ogni file avviera un'esecuzione del workflow. Usa un filtro pattern per restringere l'ambito.
Usa Move After Processing per prevenire duplicati. Senza di esso, un file che viene scritto lentamente (ad es. caricamenti di grandi dimensioni) potrebbe attivare piu eventi. Spostare il file una volta avviata l'esecuzione garantisce che ogni file venga elaborato esattamente una volta.
La directory deve esistere prima di attivare il workflow. Flusso non crea la directory. Se il percorso non esiste quando il workflow viene attivato, il trigger non riuscira ad avviarsi.
I file temporanei possono attivare il workflow. Alcune applicazioni scrivono su un file temporaneo e poi lo rinominano. Usa un filtro pattern (ad es. *.csv) per evitare falsi trigger su file .tmp.

Nodi Correlati

Google Drive Watch — monitora una cartella in Google Drive.
Dropbox Watch — monitora una cartella in Dropbox.
HTTP Request — chiama API esterne dopo aver rilevato un file.