PIPES
Vos donnees meurent dans un entrepot.
Votre equipe livre des tables. Vos concurrents livrent des decisions.
Pipes est l'ETL construit pour l'ere agentique. Tirez de toute source. Nettoyez. Scorez avec l'IA. Decidez. Agissez. Tout dans un seul runtime. Votre pipeline livre des decisions, pas des tables.
LE PROBLEME
Votre pipeline s'arrete. L'attente commence.
Vous extrayez. Vous nettoyez. Vous chargez. Puis vos donnees attendent. Qu'un humain ouvre un onglet, tire une conclusion, decroche le telephone. Le temps qu'on agisse, la transaction est passee, le client est parti, l'alerte est trop tardive.
Votre entrepot
ou les signaux meurent
Webhook arrive
Devient une ligne. Non lue.
Planification se declenche
Remplit une table. Oubliee.
Evenement de canal
Indexe. Oublie.
Formulaire soumis
En file. Perime.
Execution manuelle
Tableau de bord. Non lu.
Chaque signal ci dessus est un moment ou votre stack a stocke au lieu d'agir.
CE QU'EST PIPES
Un runtime. Un cerveau.
Pipes est l'ETL concu pour l'ere agentique. Un signal arrive. Pipes execute le pipeline que vous avez concu, avec une IA qui porte la memoire de chaque execution precedente. Extraire. Nettoyer. Evaluer. Decider. Agir. Auditer. Chaque etape dont votre workflow a besoin. Un runtime. Un cerveau. Vos donnees cessent de mourir dans des entrepots. Elles commencent a livrer des decisions.
Memoire, competences et outils disponibles sur chaque noeud que vous cablez. Versions de workflow immuables (les anciennes executions rejouent contre leur version). Branchement saga avec compensation. Rejouez toute execution a tout point de controle. Registre d'audit par defaut.
Workflows auto-evolutifs. Le cerveau propose des ameliorations a partir de milliers d'executions precedentes. Vous approuvez. Votre pipeline apprend de lui meme, dans vos garde fous.
Un runtime. Un cerveau. Chaque execution rejouable. Chaque etape que vous cablez.
LE CERVEAU
Quatre parties. Un seul esprit.
Chaque noeud que vous cablez s'appuie sur le meme cerveau. Memoire de chaque execution precedente. Competences en code versionne. Outils a portee. Un registre d'audit qui capte tout.
Une memoire qui survit a chaque execution.
Chaque decision, chaque score, chaque action prise par votre pipeline. Gardes. La prochaine execution part de la ou la derniere s'est arretee. Des lundi, le cerveau connait votre activite.
Des competences en code, pas en prompt.
Versionnees. Testables. Rejouables. Gouvernees. La logique dure vit la ou les ingenieurs peuvent la lire, pas enterree dans un prompt au fond d'un noeud.
Des outils cables a chaque noeud.
Connecteurs, requetes, effets de bord, appels modeles. Le cerveau les invoque a chaque etape du workflow que vous avez concu. Test avant sauvegarde pour valider les identifiants avant la mise en service.
Registre d'audit par defaut.
Entree, sortie, modele, version, moment. Captes a chaque etape. Un regulateur demande le raisonnement du trimestre dernier, vous repondez en une requete.
QUAND UN SIGNAL ARRIVE
Du signal a la decision livree. En une execution.
Le workflow que vous avez cable s'execute de bout en bout. Memoire, competences, outils et audit sont la a chaque noeud.
Le signal arrive
Un webhook, un evenement de canal, une planification, un formulaire, une execution manuelle. Le declencheur que vous avez cable.
Le cerveau s'eveille
La memoire de chaque execution precedente se charge. Les competences sont pretes a etre invoquees. Les outils sont cables. Le registre d'audit s'ouvre.
Le workflow s'execute
Chaque noeud que vous avez concu s'execute. Branchement, transformation, scoring, decision. Compensation saga si une etape echoue.
Decision actee
Entree, sortie, modele, version captures pour chaque etape. Le registre d'audit s'ecrit tout seul.
Action livree
Une transaction placee. Un client alerte. Un flux publie. La decision vit dans le monde. Rejouable pour toujours.
Cinq lignes de code. Votre premier evenement est en direct.
Authentification, chiffrement, garanties de livraison et audit sont geres pour vous. Connectez vous a un produit. Utilisez les autres quand vous etes pret.
import { NPayload } from '@npayload/sdk'
const np = await NPayload.connect({
clientId: process.env.NPAYLOAD_CLIENT_ID!,
hmacSecret: process.env.NPAYLOAD_HMAC_SECRET!,
})
// Trigger a workflow execution
const exec = await np.pipes.workflows.trigger('wf_enrich_decide', {
input: { ticker: 'AAPL', price: 178.42 },
})SDKs en Node, Python, React, Navigateur. Documentation publique du protocole. Chaque evenement envoye est inspectable.
A quoi ressemble la vie avec Pipes.
Trouvez le role qui rythme votre matin. Le changement est pour lui.
Un signal. Une reaction en chaine.
Les publishers enrichissent. Les subscribers re-enrichissent. La marketplace s'accumule.
Le publisher.
Un fournisseur de donnees tire des signaux de marche bruts. Le cerveau score avec la memoire de chaque cotation precedente. Le flux enrichi se publie dans npayload Feeds. Des acheteurs se branchent et payent pour consommer. Le pipeline devient la ligne de revenu.
Le subscriber.
Une firme quant consomme le flux du publisher. Pipes execute une competence privee dessus avec le contexte cerveau propre a la firme. Un signal derive se republie dans Feeds. Leurs abonnes se branchent sur celui la.
L'amplificateur.
Chaque publisher seme de nouveaux subscribers. Certains de ces subscribers deviennent eux memes publishers. Le cerveau grandit dans toutes les directions. Vos donnees deviennent le substrat sur lequel les entreprises des autres tournent.
La demande de rejeu.
Un regulateur demande pourquoi une transaction a tire le 12 mars a 14h07. Vous ne fouillez pas dans les logs. Vous ne reconstruisez pas l'etat. Vous ouvrez l'execution, glissez jusqu'au noeud, lisez la reponse. Cinq minutes.
COHORTE FONDATRICE
Industries ou la donnee est le produit.
Les equipes dans ces secteurs ont arrete de livrer des tables et commence a livrer des decisions.
Services financiers
Donnees de marche scorees avec la memoire de chaque cotation precedente. Transactions placees en vol.
Infrastructure IA
Sorties de modele, traces d'evaluation, signaux d'entrainement publies en flux. L'audit suit chaque decision.
Souscription en assurance
Sinistres et demandes scores en plein vol. Chaque chaine de raisonnement rejouable pour le regulateur.
Donnees de sante
Signaux patients joints, scores, routes avec consentement et audit integres.
Intelligence logistique
Evenements d'expedition enrichis avec meteo, douanes, donnees d'itineraire. Decisions en secondes.
Donnees marketplace
Flux de catalogue normalises, dedupliques, scores pour le ranking et les publicites.
Soyez le premier publisher de votre categorie.
Cablez votre premier pipe. Extraire, nettoyer, evaluer, decider, agir, auditer. Le pipeline que vous concevez livre des decisions dans la meme execution.
Questions que les equipes posent avant de cabler leur premier pipe.
Arretez de livrer des tables. Commencez a livrer des decisions.
Pipes est l'ETL avec un cerveau. Vos donnees cessent de mourir dans des entrepots. Elles commencent a livrer des decisions.
Continuez a stocker, ou commencez a livrer.