Database Change

Descrizione

Innesco reattivo enterprise per change data capture su tabelle del database integrato FlowForge — il modulo "database low-code" del tenant che permette di definire schemi e tabelle dalla UI senza scrivere SQL, alimentato downstream da workflow di automation. Esegue il workflow tutte le volte che una riga corrispondente al filtro configurato viene INSERTed (nuovo record creato), UPDATEd (modifica a un record esistente, con detection del campo specifico cambiato per evitare loop infiniti), DELETEd (eliminazione, logica o fisica). Implementazione: dual-mode hot-swappable senza redeploy — modalità polling (default, safe per qualsiasi tabella, cursor su id + updated_at con frequenza configurabile 5s-1h, exactly-once semantics garantita dallo state store del trigger), oppure modalità real-time via trigger SQL nativo PostgreSQL/SQLite (LISTEN/NOTIFY pubblicato da AFTER INSERT/UPDATE/DELETE FOR EACH ROW, latency sotto i 50ms ma richiede privilegi DBA per CREATE TRIGGER — usabile quando il tenant ha schema isolato). Filtri configurabili: where clause SQL-like su uno o più campi (es. "status = 'pending' AND amount > 1000" — solo gli ordini grossi attendono pagamento triggera il flow), watch su una SPECIFICA colonna per UPDATE (es. "scatena solo se cambia il campo `delivery_status`, ignora aggiornamenti su `last_login`" — fondamentale per evitare loop quando il workflow stesso scrive in altre colonne della stessa tabella). Input al workflow downstream: { event: 'insert'|'update'|'delete', row (oggetto completo della riga corrente), oldRow? (snapshot pre-modifica per UPDATE, utile per audit log "campo X passato da Y a Z"), table (nome della tabella per multi-tabella workflow di logging), changedColumns? (lista delle colonne effettivamente cambiate nell'UPDATE), timestamp (ISO 8601 dell'evento DB) }. Use case: notifica admin via action_email_send_tracked quando insert in ordini_pending con importo > €500 (escalation EU "Codice del Consumatore" rimborsi); sync esterno verso HubSpot CRM tramite action_http post update di customers.email per allineare il marketing pipeline; audit trigger su tabella users per cambio di role/status con append automatico su audit_log immutable; workflow ETL che esporta verso data warehouse Snowflake ogni nuovo record di analytics_events; alerting su account.move Odoo quando una fattura viene cancellata da utente non autorizzato (signal anti-fraud per il controllo di gestione).

⚙️ Parametri di configurazione

Campi mostrati nell’editor quando si configura il nodo. Generati direttamente dal NodeDefconfigFields.

💡 Esempio configurazione

Snippet JSON del nodo come compare nel workflow. I valori sono derivati daidefaultValue e dai parametri required.

{
  "id": "node-trigger_db_change-1",
  "defId": "trigger_db_change",
  "label": "Database Change",
  "config": {
    "databaseId": "<databaseId>",
    "tableName": "<tableName>",
    "ops": "all",
    "pollIntervalSec": 5
  }
}

🔗 Nodi correlati nella stessa categoria