Flow Engine & In-Memory Queue
Un moteur de workflows JSON et une file d’attente en mémoire pour orchestrer des tâches synchrones et asynchrones avec gestion des dépendances.
- Exécution parallèle et séquentielle de tâches
- Gestion des dépendances entre tâches (inputs/outputs)
- Flows JSON paramétrables et réutilisables
- Résolveurs intégrés (Echo, Noop, ThrowError, Conditional, Wait, etc.)
- Ajout de tâches dynamiquement
- Système de plugins et d’actions personnalisées
- File d’attente en mémoire (MQ) pour la gestion des jobs, résultats, événements et callbacks
- API simple pour l’intégration et les tests
npm install @odyssee-software/imqfePour une introduction détaillée à la création et l’utilisation des flows, consultez le guide des flows.
import { FlowProducer } from '@odyssee-software/imqfe';
const flow = new FlowProducer();
flow.add('echoTask', {
provides: ['output1'],
requires: [],
resolver: {
name: 'flowher::Echo',
params: { in: 'Hello World!' },
results: { out: 'output1' }
}
});
const result = await flow.run(
{}, // paramètres d’entrée
['output1'], // outputs attendus
{}, // actions personnalisées (optionnel)
{} // contexte (optionnel)
);
console.log(result); // [{ output1: 'Hello World!' }]flowher::Echo: Retourne la valeur passée en entréeflowher::Noop: Ne fait rien, retourne un objet videflowher::ThrowError: Lève une erreur personnaliséeflowher::Conditional: Retourne un résultat selon une conditionflowher::Wait: Attend un délai avant de retourner un résultat
Voir src/resolver-registry.ts pour la liste complète.
Le module MQ permet de gérer des files de jobs, leur exécution, le suivi d’état, les événements et les résultats, le tout en mémoire.
Pour une explication complète et des exemples avancés, consultez le guide MQ.
import { MQ, WorkerController } from '@odyssee-software/imqfe';
const queue = new MQ({ name: 'ma-queue' });
const workerFactory = WorkerController(async ({ value }) => {
// Traitement asynchrone ici
return value * 2;
}, { value: 21 });
queue.enqueue(workerFactory);
queue.start(() => {
// Callback à la fin de la queue
console.log('Tous les jobs sont terminés');
});const [worker] = queue.enqueue(workerFactory);
worker.on('success', (job) => {
console.log('Job terminé avec succès:', job.data);
});
worker.on('error', (job) => {
console.error('Erreur dans le job:', job.error);
});
worker.follow((step, error, result) => {
console.log('Étape:', step, 'Résultat:', result, 'Erreur:', error);
});Pour plus de détails, voir src/mq.ts.
FlowProducer (src/mq-flow.ts)
constructor(specs?): Initialise un flow avec des tâches optionnellesadd(taskName, taskSpec): Ajoute une tâche au flowrun(params, expectedOutputs, actions?, context?): Exécute le flow et retourne les résultats attendus
Pour plus d’informations et d’exemples, consultez le guide des flows.
MQ (src/mq.ts)
enqueue(...workers): Ajoute un ou plusieurs jobs à la filedequeue(jobId): Retire un job de la file par son identifiantjob(jobId): Récupère un job par son identifiantstart(callback?): Démarre l’exécution de la file- Gestion des événements :
on('success'|'error'|'start'|'end', callback) - Suivi d’un job :
worker.follow(callback)
Pour des cas d’usage avancés, voir le guide MQ.
WorkerController (src/mq.ts)
- Permet de créer des workers personnalisés avec gestion des propriétés, du suivi, des événements et des dépendances.
Lance tous les tests unitaires :
npm testUn rapport Markdown est généré dans test-reports/test-report.md.
- guide/flow.md : Introduction aux flows
- guide/mq.md : Introduction à la file d’attente
Distribué sous licence GNU GPL v3. Voir le fichier LICENSE.