Ricerca e reportistica
Un planner scompone una domanda in sotto-task, diversi ricercatori lavorano in parallelo e un redattore assembla il risultato dalla memoria condivisa.
Agenti planner, ricercatore e redattore che si passano il lavoro tramite uno stream di task durevole, condividono risultati e memoria e non perdono mai un task.
Il planner suddivide il lavoro e aggiunge un task allo stream.
Una dimostrazione animata con comandi HotKV reali e risposte di esempio. Clicca su un passo qualsiasi per andarci. Comandi e risposte restano in inglese, esattamente come li digiti e li vedi in HotKV.
I team di agenti hanno bisogno di un modo per passarsi il lavoro, condividere ciò che hanno trovato e riprendersi quando uno di loro si blocca a metà di un task. Mettere insieme tutto questo con chiamate HTTP improvvisate fa perdere task, duplica le chiamate agli strumenti e non lascia traccia di chi ha fatto cosa.
Uno stream con un consumer group è la bacheca dei task. Ogni agente legge i propri task, li conferma quando ha finito, e qualsiasi cosa un agente bloccato abbia lasciato in sospeso può essere presa in carico da un altro. I risultati vanno nella memoria di lavoro condivisa, i risultati degli strumenti vengono messi in cache per ogni agente e ogni azione viene registrata.
Il planner suddivide il lavoro e aggiunge un task allo stream.
XADD tasks * type research topic "EU AI Act obligations"Il consumer group è stato creato una volta con XGROUP CREATE. Il ricercatore legge come suo membro, e il task resta in sospeso finché non viene confermato.
XREADGROUP GROUP agents researcher COUNT 1 BLOCK 5000 STREAMS tasks >Un altro agente ha già eseguito questa ricerca oggi. La cache condivisa degli strumenti la restituisce.
TOOL.CACHE.GET web "search:EU AI Act obligations"I risultati vanno nella memoria di lavoro del progetto, dove ogni agente può leggerli.
AMEM.WORK.SET project:9 findings "Providers of high-risk systems must ..."Il task è completato ed esce dalla lista dei sospesi. Se il ricercatore si fosse bloccato, XAUTOCLAIM lo avrebbe passato a un altro agente.
XACK tasks agents 1790985600123-0Il redattore legge i risultati condivisi, prepara la bozza del report e registra l'azione.
AMEM.WORK.GET project:9 findingsUn planner scompone una domanda in sotto-task, diversi ricercatori lavorano in parallelo e un redattore assembla il risultato dalla memoria condivisa.
Agenti di coding, test e revisione si passano il lavoro tramite uno stream, e ogni modifica che fanno finisce nel log episodico.
Agenti di estrazione, validazione e registrazione delle fatture si passano i documenti lungo una pipeline che sopravvive ai riavvii.
Stream con consumer group, conferme e presa in carico dei task abbandonati.
XADDXREADGROUPXACKXAUTOCLAIMStato del progetto che ogni agente può leggere e aggiornare.
AMEM.WORK.SETAMEM.WORK.GETI risultati deterministici degli strumenti vengono riutilizzati tra gli agenti.
TOOL.CACHE.GETTOOL.CACHE.SETUn log episodico per agente per audit e debug.
AMEM.EPIS.LOGIl task resta nella lista dei sospesi del consumer group. Un altro agente può prenderlo in carico con XAUTOCLAIM dopo che è rimasto inattivo abbastanza a lungo.
Sì. Hanno bisogno solo di una connessione a HotKV. Funziona qualsiasi client che parli il protocollo Redis.
Gli stream funzionano su ogni piano. La memoria degli agenti e la cache degli strumenti fanno parte dei piani Performance e Scale.
HotKV parla il protocollo Redis, quindi puoi puntarci un client esistente ed eseguire questi stessi comandi.