Déclencheurs pilotés par les événements
Les événements qui comptent vivent rarement dans un seul flux. Un dépassement de position survient souvent à la suite du mouvement soudain du prix d'un actif corrélé sur le marché. Une dégradation de contrepartie est souvent déclenchée lorsqu'une exposition franchit un seuil. 3forge détecte des conditions composites à travers plusieurs flux en direct et l'état au repos, et déclenche des actions automatisées, des notifications ou des étapes de pipeline en aval dès que le motif se vérifie.
Le défi
Les déclencheurs utiles sont composites, et la plupart des systèmes ne savent pas les exprimer
L'alerte mono-flux est simple et bruyante. Le signal utile provient presque toujours d'une combinaison : un événement dans un flux, plus un état dans un autre, plus une fenêtre temporelle. La plupart des outils d'orchestration soit aplatissent tout dans un ordre unique et perdent le contexte, soit forcent chaque règle dans son propre pipeline sur mesure.
La corrélation inter-flux est difficile
Joindre un flux de prix à haute fréquence à un flux de mise à jour de positions plus lent dans une fenêtre temporelle définie, et uniquement lorsque les deux conditions sont réunies, dépasse ce que la plupart des systèmes pub-sub peuvent exprimer sans code sur mesure.
Fatigue d'alertes et bruit
Les alertes à condition unique produisent des milliers de notifications non pertinentes par jour. Les opérateurs cessent de les lire, et les signaux réels se perdent dans le bruit.
Aucun état entre les événements
De nombreux motifs utiles nécessitent de mémoriser un état récent, les cinq dernières cotations, si un ordre travaille depuis plus de trente secondes, la moyenne glissante sur une fenêtre, et les processeurs d'événements sans état ne peuvent pas l'exprimer proprement.
Câblage d'action fragile
Une fois qu'un déclencheur se déclenche, l'action, un coupe-circuit, un message Slack, un événement Kafka, une mise à jour de base de données, est câblée à la main pour chaque règle. Ajouter une nouvelle action implique de redéployer la règle.
L'approche 3forge
Une détection de motifs native d'un runtime temps réel
3forge modélise chaque flux comme une table en temps réel et chaque déclencheur comme une expression AMIScript sur ces tables. Les conditions composites, les fenêtres, les jointures et les agrégations à état sont des constructions de première classe du langage. Lorsque la condition se vérifie, le runtime invoque n'importe quel gestionnaire, de la publication d'un événement sur Kafka à l'appel d'un point de terminaison REST en aval, le tout configuré de façon déclarative. Les règles sont versionnées, observables et rejouables depuis la base en colonnes.
Capacités clés
Ce que vous pouvez bâtir avec 3forge
Détection de conditions composites
Exprimez des déclencheurs qui exigent que plusieurs flux satisfassent des conditions liées dans une fenêtre temporelle définie, en une seule expression AMIScript.
Règles fenêtrées et à état
Utilisez des fenêtres glissantes et bornées, des compteurs persistants et des agrégats courants pour exprimer des motifs qui dépendent de l'historique récent.
Cibles d'action enfichables
Routez la sortie des déclencheurs vers des alertes, des topics Kafka, des points de terminaison REST, des écritures en base ou des pipelines 3forge en aval, par configuration.
Composition de règles
Construisez des déclencheurs complexes à partir de règles nommées plus simples, réutilisez-les dans les applications et versionnez-les comme du code.
Rejeu et simulation
Rejouez n'importe quelle période historique à travers les règles actuelles pour effectuer des backtests, ajuster les seuils et démontrer le comportement aux auditeurs avant activation.
Observabilité des règles en direct
Inspectez le taux de correspondance de chaque règle, son ratio de faux positifs et la latence des actions en aval dans l'atelier, avec un accès détaillé à la chaîne d'événements déclencheurs.
Commencer
Prêt à le voir en action ?
Réservez une démo de 30 minutes avec un ingénieur solutions 3forge et observez un déclencheur composite se déclencher à travers des flux en direct, en temps réel.