Recherche et rapports
Un planificateur découpe une question en sous-tâches, plusieurs chercheurs travaillent en parallèle et un rédacteur assemble le résultat à partir de la mémoire partagée.
Des agents planificateur, chercheur et rédacteur qui se transmettent le travail via un flux de tâches durable, partagent résultats et mémoire, et ne perdent jamais une tâche.
Le planificateur découpe le travail et ajoute une tâche au stream.
Une démonstration animée avec de vraies commandes HotKV et des exemples de réponses. Cliquez sur une étape pour y accéder directement. Les commandes et les réponses restent en anglais, exactement comme vous les saisissez et les voyez dans HotKV.
Des équipes d'agents ont besoin de se passer du travail, de partager ce qu'elles ont trouvé et de se rétablir quand l'un d'eux plante en pleine tâche. Assembler tout cela avec des appels HTTP improvisés fait perdre des tâches, duplique les appels d'outils et ne laisse aucune trace de qui a fait quoi.
Un stream avec un groupe de consommateurs sert de tableau des tâches. Chaque agent lit ses propres tâches et les acquitte une fois terminées, et tout ce qu'un agent planté a laissé en attente peut être repris par un autre. Les résultats vont dans une mémoire de travail partagée, les résultats d'outils sont mis en cache pour tous les agents et chaque action est journalisée.
Le planificateur découpe le travail et ajoute une tâche au stream.
XADD tasks * type research topic "EU AI Act obligations"Le groupe de consommateurs a été créé une fois avec XGROUP CREATE. Le chercheur lit en tant que membre du groupe, et la tâche reste en attente jusqu'à son acquittement.
XREADGROUP GROUP agents researcher COUNT 1 BLOCK 5000 STREAMS tasks >Un autre agent a déjà lancé cette recherche aujourd'hui. Le cache d'outils partagé la renvoie.
TOOL.CACHE.GET web "search:EU AI Act obligations"Les résultats vont dans la mémoire de travail du projet, où chaque agent peut les lire.
AMEM.WORK.SET project:9 findings "Providers of high-risk systems must ..."La tâche est terminée et quitte la liste d'attente. Si le chercheur avait planté, XAUTOCLAIM l'aurait confiée à un autre agent.
XACK tasks agents 1790985600123-0Le rédacteur lit les résultats partagés, rédige le rapport et journalise l'action.
AMEM.WORK.GET project:9 findingsUn planificateur découpe une question en sous-tâches, plusieurs chercheurs travaillent en parallèle et un rédacteur assemble le résultat à partir de la mémoire partagée.
Les agents de code, de test et de revue se passent le travail via un stream, et chaque modification qu'ils apportent figure dans le journal épisodique.
Les agents d'extraction, de validation et de comptabilisation des factures font circuler les documents dans un pipeline qui survit aux redémarrages.
Streams avec groupes de consommateurs, acquittements et reprise des tâches abandonnées.
XADDXREADGROUPXACKXAUTOCLAIMUn état de projet que chaque agent peut lire et mettre à jour.
AMEM.WORK.SETAMEM.WORK.GETLes résultats d'outils déterministes sont réutilisés d'un agent à l'autre.
TOOL.CACHE.GETTOOL.CACHE.SETUn journal épisodique par agent pour l'audit et le débogage.
AMEM.EPIS.LOGLa tâche reste dans la liste d'attente du groupe de consommateurs. Un autre agent peut la reprendre avec XAUTOCLAIM une fois qu'elle est restée inactive assez longtemps.
Oui. Ils ont seulement besoin d'une connexion à HotKV. Tout client qui parle le protocole Redis fonctionne.
Les streams fonctionnent avec toutes les offres. La mémoire d'agent et le cache d'outils font partie des offres Performance et Scale.
HotKV parle le protocole Redis. Vous pouvez donc y connecter un client existant et exécuter ces mêmes commandes.