Notification
Envoie une notification à chaque exécution du pipeline : une seule brick pour trois canaux : mail (SMTP), Slack et webhook générique. Le message est un template avec injection de variables et de statistiques du flux d'entrée.
La brick consomme l'entrée in (le DataFrame alimente les statistiques du
message) et n'a pas de port de sortie.
Paramètres
| Paramètre | Type | Requis | Description |
|---|---|---|---|
notification_type | Enum | Oui | mail (Email SMTP, défaut), slack, webhook (générique). |
connection_id | String | Oui | Connexion notification : SMTP, webhook Slack ou webhook générique. |
subject | String | Oui | Sujet du message (défaut [Fluhoms] Rapport pipeline). |
body | String | Oui | Corps du message, en Markdown. |
include_summary | Boolean | Non | Ajoute en pied de message un résumé du DataFrame (défaut true). |
Placeholders
Le sujet et le corps supportent des placeholders remplacés à l'exécution :
| Placeholder | Description |
|---|---|
{n_rows} | Nombre de lignes du flux d'entrée. |
{columns} | Liste des colonnes. |
{first_row} | Première ligne (dictionnaire clé / valeur). |
${prj.X} | Variable X du projet (valeur de l'environnement courant). |
${run.id} | Identifiant de l'exécution. |
Avec include_summary, un tableau récapitulatif est ajouté en pied de
message : nombre de lignes et de colonnes, liste des colonnes et aperçu des 5
premières lignes.
Canaux
Email (SMTP)
Utilise une connexion SMTP : hôte, port (SSL implicite sur 465, STARTTLS sinon), identifiants, adresses expéditeur et destinataire. Le corps est envoyé en texte.
Slack
Utilise une connexion webhook Slack (URL incoming webhook). Le sujet devient l'en-tête du message et le corps est rendu en mrkdwn Slack.
Webhook générique
POST JSON vers l'URL de la connexion, avec un objet contenant subject et
body. Compatible Teams, Discord, Zapier et tout récepteur HTTP.
Exemple
Corps de message type pour un rapport de fin de pipeline :
Pipeline terminé avec {n_rows} ligne(s).
Colonnes traitées : {columns}
Pour une alerte conditionnelle sans interrompre le flux (seuil de lignes, valeur anormale…), utilisez plutôt l'action Alerte, voir Actions. La brick Notification, elle, envoie à chaque exécution.