Noma flow
Ordonnancement et orchestration

L’ordonnanceur et le moteur d’orchestration conçu avec et pour Liberty Next. Il s’exécute dans le processus du framework — pas de worker séparé, pas de broker, pas de démon compagnon. Planifiez des tâches cron, exécutez des pipelines ETL, synchronisez vos annuaires LDAP, distribuez des appels HTTP, et laissez les opérateurs suivre chaque exécution en direct depuis la même interface que le reste de l’application.

Conçu avec et pour Liberty NextDans le processus — sans brokerCron · intervalle · manuelÉtapes SQL · Python · HTTP · LDAPReprise · timeout · backoffLogs en direct

Ce que Nomaflow résout

Le travail en arrière-plan dont toute application interne a besoin

Sans Nomaflow, cela revient généralement à éparpiller des entrées cron sur plusieurs hôtes et des scripts Python dans différents dépôts, sans logique de reprise commune ni point unique pour voir « ce qui vient de tourner ». Avec Nomaflow : un seul catalogue de tâches, un seul historique d’exécutions, un seul flux de logs en direct — dans la même interface que le reste de l’application.

Rafraîchissement nocturne

Rapatrier, selon une planification, les données d’une base opérationnelle vers une base de reporting.

Récupération périodique d’API

Interroger un service tiers toutes les heures, avec nouvelle tentative en cas d’échec.

Synchronisation LDAP / AD

Répliquer les utilisateurs et les groupes de l’annuaire dans l’application.

Tâche de nettoyage

Purger les anciens enregistrements, archiver les PDF, supprimer les sessions expirées.

Flux conditionnel

Ne s’exécuter que si un événement s’est produit — un fichier est arrivé, un compteur a dépassé un seuil.

Exécution manuelle ponctuelle

Un opérateur la déclenche depuis un bouton après une livraison, avec des paramètres.

Fonctionnement

Du catalogue à l’historique des exécutions

Une tâche est une entrée du catalogue ; l’ordonnanceur intégré au processus la déclenche sur cron, à intervalle régulier ou manuellement ; le moteur d’étapes exécute les étapes SQL, Python et HTTP avec reprise et timeout ; l’historique rend visible chaque exécution, avec son flux de logs en direct.

Fonctionnement de Nomaflow — catalogue, ordonnanceur, moteur d’étapes, historique des exécutions et interfaces opérateur

Schémas

Ce que vous pouvez construire

Synchronisation planifiée de base

Cron à 02 h 00 → SQL Copy d’un pool source vers un pool cible → notification de succès.

Récupération d’API externe

Cron toutes les heures → étape HTTP avec authentification bearer → Python transforme le payload → écriture SQL.

Miroir LDAP / AD

Cron toutes les 4 heures → étape LDAP Sync → upsert dans la table des utilisateurs.

Nettoyage conditionnel

Cron quotidien → comptage SQL des anciennes lignes → étape Python conditionnelle qui supprime au-delà d’un seuil.

Surveillance de fichiers → lot

Cron toutes les 5 minutes → Python liste un dossier → pour chaque nouveau fichier, SQL Copy + déplacement vers l’archive.

Test de bon fonctionnement

Cron toutes les 5 minutes → étape HTTP sur votre healthz → alerte e-mail après 3 échecs consécutifs.

Les briques sont volontairement petites — une étape fait une seule chose. Les pipelines les composent ; l’historique des exécutions rend visible ce qui s’est passé.

Le bon usage

Quand choisir Nomaflow

Choisissez Nomaflow quand…

  • Les charges restent à l’échelle d’une installation et ne traversent pas de nombreux systèmes.
  • Le pipeline complet se termine en quelques secondes à quelques minutes.
  • Cron + étapes linéaires + nouvelle tentative suffisent.
  • Vous voulez un seul outil, une seule interface, un seul flux de logs.
  • L’alternative serait d’écrire à la main un script Python + un timer systemd.

Choisissez autre chose quand…

  • Les charges couvrent une douzaine de services et nécessitent une vue DAG globale.
  • Une seule étape dure plusieurs heures et requiert de l’autoscaling.
  • Vous avez besoin d’expansion dynamique de tâches ou de DAG fan-out / fan-in.
  • Vous exploitez déjà Airflow / Dagster / Prefect pour tout le reste.
  • L’alternative serait d’écrire un CronJob Kubernetes avec sidecars.

Le point de conception, c’est « la colle opérationnelle dont la plupart des applications internes ont besoin » — pas « tous les cas d’orchestration ». Pour 80 % des besoins, Nomaflow évite une bonne partie de la plomberie.

Là où Nomaflow ne va pas

Une courte liste honnête, pour que les attentes correspondent à la réalité. Ce sont des arbitrages, pas des manques à combler — le point de conception, c’est le cas petit, à l’échelle d’une installation.

Pas de DAG de tâches avec branches parallèles

Les étapes d’une tâche sont linéaires ; vous pouvez chaîner des tâches via les Dépendances, mais le modèle reste « étape par étape », pas « graphe ».

Pas de pool de workers autoscalable

L’ordonnanceur s’exécute dans le processus du framework. Les gros lots parallèles (des milliers d’étapes simultanées) ne sont pas son point fort.

Pas de lignage / catalogue de données

Nomaflow sait quelles étapes se sont exécutées ; il ne trace pas quelles colonnes ont circulé de quelle source vers quelle cible.

Pas d’interface de backfill de niveau SaaS

Vous pouvez rejouer une exécution terminée ; « rejouer chaque jour des 90 derniers jours » passe par une étape Python que vous écrivez.

Pas de seconde pile

Comment Nomaflow s’intègre à Liberty Next

Nomaflow réutilise les connecteurs, le modèle de permissions, la couche de chiffrement et l’interface Paramètres du framework. Pas de « base Nomaflow » à installer, pas de « comptes utilisateurs Nomaflow » à gérer — une équipe qui dispose de Liberty Next dispose déjà de Nomaflow.

Connecteurs (SQL / HTTP / LDAP)

Accès aux sources de données et aux API via les mêmes requêtes déclarées que vos écrans.

Pools

Connexions aux bases de données, partagées avec le reste du framework.

Authentification + rôles

Permissions job:<name> par rôle ; :session_user pour l’audit des déclenchements.

Chiffrement

Identifiants des connecteurs, URL de webhooks et secrets OAuth — tous chiffrés au repos.

Interface Paramètres

Le constructeur de tâches et l’éditeur d’étapes y résident — rien de plus à installer.

Socket.IO

Mises à jour en direct de l’état des exécutions, des transitions d’étapes et du flux de logs.

FAQ

Questions sur Nomaflow

Qu’est-ce que Nomaflow ?

Nomaflow est l’ordonnanceur et le moteur d’orchestration de Nomana-IT, conçu avec et pour Liberty Next. Il exécute des tâches planifiées par cron, à intervalle ou manuelles, composées de pipelines d’étapes linéaires, avec nouvelle tentative, timeout et backoff, et conserve l’historique de chaque exécution avec un flux de logs en direct.

Nomaflow nécessite-t-il un worker ou un broker de messages séparé ?

Non. Nomaflow s’exécute dans le processus de Liberty Next — pas de worker séparé, pas de broker comme Redis ou RabbitMQ, pas de démon compagnon. Il réutilise les connecteurs, les pools, les rôles, le chiffrement et l’interface Paramètres du framework : aucune base ni aucun compte utilisateur propres à Nomaflow à gérer.

Quels types d’étapes existent, et comment crée-t-on une tâche ?

Les tâches se créent dans le constructeur de tâches de l’interface Paramètres — aucun fichier de configuration à écrire à la main. Une tâche enchaîne des étapes de cinq types : SQL Query, SQL Copy, Python, HTTP et LDAP Sync. Les étapes Python personnalisées couvrent la logique que les étapes déclaratives ne prennent pas en charge.

Comment suit-on les exécutions ?

La page Exécutions liste chaque exécution avec son statut et permet d’en consulter le détail par étape, avec un flux de logs en direct diffusé via Socket.IO. Les notifications partent vers Slack, l’e-mail ou un webhook selon le résultat, via des canaux définis une seule fois au niveau du framework et utilisés par toutes les tâches.

Quand faut-il plutôt utiliser Airflow, Dagster ou Prefect ?

Quand les charges couvrent une douzaine de services et nécessitent une vue DAG globale, quand une seule étape dure plusieurs heures et requiert de l’autoscaling, quand vous avez besoin d’expansion dynamique de tâches ou de DAG fan-out / fan-in, ou quand vous exploitez déjà l’un de ces outils pour tout le reste. Nomaflow vise le cas petit, à l’échelle d’une installation.

Un seul outil pour la colle opérationnelle

Nomaflow est conçu avec et pour Liberty Next. Installez le framework, créez une tâche dans le constructeur de tâches et suivez en direct votre première exécution planifiée.