Agents
Das Modul wippy/agent bietet ein Framework zum Erstellen von KI-Agenten mit Tool-Nutzung, Streaming, Delegation, Traits und Memory. Agenten werden deklarativ definiert und ueber ein Context/Runner-Muster ausgefuehrt.
Einrichtung
Abschnitt betitelt „Einrichtung“Fuege das Modul deinem Projekt hinzu:
wippy add wippy/agentwippy installDas Agent-Modul erfordert wippy/llm und einen Process-Host. Deklariere beide Abhaengigkeiten:
version: "1.0"namespace: app
entries: - name: os_env kind: env.storage.os
- name: processes kind: process.host lifecycle: auto_start: true
- name: dep.llm kind: ns.dependency component: wippy/llm version: "*" parameters: - name: env_storage value: app:os_env - name: process_host value: app:processes
- name: dep.agent kind: ns.dependency component: wippy/agent version: "*" parameters: - name: process_host value: app:processesAgent-Definitionen
Abschnitt betitelt „Agent-Definitionen“Agenten sind Registry-Eintraege mit meta.type: agent.gen1:
entries: - name: assistant kind: registry.entry meta: type: agent.gen1 name: assistant title: Assistant comment: A helpful chat assistant prompt: | You are a helpful assistant. Be concise and direct. Answer questions clearly. model: gpt-4o max_tokens: 1024 temperature: 0.7Agent-Felder
Abschnitt betitelt „Agent-Felder“| Feld | Typ | Beschreibung |
|---|---|---|
meta.type | string | Muss agent.gen1 sein |
meta.name | string | Agent-Identifikator |
prompt | string | System-Prompt |
model | string | Modellname oder -klasse |
max_tokens | number | Maximale Ausgabe-Tokens (Standard 512) |
temperature | number | Sampling-Temperatur (Standard 0; Bereich anbieterabhaengig) |
thinking_effort | number | Wird nur an das Modell weitergeleitet, wenn > 0 (anbieterdefinierte Skala) |
tools | array | Tool-Registry-IDs |
traits | array | Trait-Referenzen |
delegates | array | Delegate-Agent-Referenzen |
memory | array | Statische Memory-Eintraege (Strings) |
memory_contract | table | Konfiguration fuer dynamisches Memory |
Agent-Context
Abschnitt betitelt „Agent-Context“Der Agent-Context ist der zentrale Einstiegspunkt. Erstelle einen Context, konfiguriere ihn optional und lade dann einen Agenten:
imports: agent_context: wippy.agent:contextlocal agent_context = require("agent_context")
local ctx = agent_context.new()local runner, err = ctx:load_agent("app:assistant")if err then error("Failed to load agent: " .. tostring(err))endContext-Methoden
Abschnitt betitelt „Context-Methoden“| Methode | Beschreibung |
|---|---|
agent_context.new(options?) | Neuen Context erstellen |
:add_tools(specs) | Tools zur Laufzeit hinzufuegen |
:add_delegates(specs) | Delegate-Agenten hinzufuegen |
:configure_delegate_tools(config) | Konfigurieren, wie Delegates sich als Tools exponieren |
:set_memory_contract(config) | Dynamisches Memory konfigurieren |
:set_context_merger(fn) | Funktion zum Zusammenfuehren von Laufzeit-Context-Aktualisierungen bereitstellen |
:update_context(updates) | Laufzeit-Context aktualisieren |
:load_agent(spec_or_id, options?) | Agent laden und kompilieren, gibt Runner zurueck |
:switch_to_agent(id, options?) | Zu anderem Agent wechseln, gibt (boolean, string?) zurueck |
:switch_to_model(name) | Modell des aktuellen Agenten aendern, gibt (boolean, string?) zurueck |
:get_current_agent() | Aktuellen Runner abrufen |
:get_config() | Zusammenfassung der Context-Konfiguration zurueckgeben |
Context-Optionen
Abschnitt betitelt „Context-Optionen“local ctx = agent_context.new({ context = { session_id = "abc", user_id = "u1" }, delegate_tools = { enabled = true }, enable_cache = true,})| Option | Beschreibung |
|---|---|
context | Basis-Laufzeit-Context, der an Tools und Delegates weitergereicht wird |
delegate_tools | Standard-Delegate-Tool-Konfiguration (wird von configure_delegate_tools ueberschrieben) |
enable_cache | Prompt-Cache-Marker aktivieren (Claude-Modelle). Standardwert true. |
Laden per Inline-Spezifikation
Abschnitt betitelt „Laden per Inline-Spezifikation“Lade einen Agenten ohne Registry-Eintrag:
local runner, err = ctx:load_agent({ id = "inline-agent", name = "helper", prompt = "You are a helpful assistant.", model = "gpt-4o", max_tokens = 1024, tools = { "app.tools:search" },})Schritte ausfuehren
Abschnitt betitelt „Schritte ausfuehren“Der Runner fuehrt einen einzelnen Reasoning-Schritt aus. Uebergib einen Prompt-Builder mit der Konversation:
local prompt = require("prompt")
local conversation = prompt.new()conversation:add_user("What is the capital of France?")
local response, err = runner:step(conversation)if err then error(tostring(err))end
print(response.result)Schritt-Optionen
Abschnitt betitelt „Schritt-Optionen“local response, err = runner:step(conversation, { context = { session_id = "abc" }, stream_target = { reply_to = process.pid(), topic = "stream" }, tool_call = "auto",})| Option | Typ | Beschreibung |
|---|---|---|
context | table | Laufzeit-Context, der mit dem Agent-Context zusammengefuehrt wird |
stream_target | table | Streaming: { reply_to, topic } |
tool_call | string | "auto", "any", "none" oder ein Tool-Name |
Schritt-Antwort
Abschnitt betitelt „Schritt-Antwort“| Feld | Typ | Beschreibung |
|---|---|---|
result | string | Generierter Text |
tokens | table | Token-Nutzung |
finish_reason | string | Abschlussgrund |
tool_calls | table? | Auszufuehrende Tool-Aufrufe |
delegate_calls | table? | Delegate-Aufrufe |
Runner-Statistiken
Abschnitt betitelt „Runner-Statistiken“local stats = runner:get_stats()-- stats.id, stats.name, stats.total_tokensTool-Definitionen
Abschnitt betitelt „Tool-Definitionen“Tools sind function.lua-Eintraege mit meta.type: tool. Definiere sie in einer separaten _index.yaml:
version: "1.0"namespace: app.tools
entries: - name: calculate kind: function.lua meta: type: tool title: Calculate input_schema: | { "type": "object", "properties": { "expression": { "type": "string", "description": "Math expression to evaluate" } }, "required": ["expression"], "additionalProperties": false } llm_alias: calculate llm_description: Evaluate a mathematical expression. source: file://calculate.lua modules: [expr] method: handlerlocal expr = require("expr")
local function handler(args) local result, err = expr.eval(args.expression) if err then return { error = tostring(err) } end return { result = result }end
return { handler = handler }Tool-Metadaten
Abschnitt betitelt „Tool-Metadaten“| Feld | Typ | Beschreibung |
|---|---|---|
meta.type | string | Muss tool sein |
meta.input_schema | string/table | JSON-Schema fuer Tool-Argumente |
meta.llm_alias | string | Name, der dem LLM angezeigt wird |
meta.llm_description | string | Beschreibung, die dem LLM angezeigt wird |
meta.exclusive | boolean | Wenn true, werden gleichzeitige Tool-Aufrufe abgebrochen |
Tools in Agenten referenzieren
Abschnitt betitelt „Tools in Agenten referenzieren“Liste Tool-Registry-IDs in der Agent-Definition auf:
- name: assistant kind: registry.entry meta: type: agent.gen1 name: assistant prompt: You are a helpful assistant with tools. model: gpt-4o max_tokens: 1024 tools: - app.tools:calculate - app.tools:search - app.tools:* # wildcard: all tools in namespaceTools koennen auch mit eigenen Aliasen und Context referenziert werden:
tools: - id: app.tools:search alias: web_search context: api_key: "${SEARCH_API_KEY}"Tool-Ausfuehrung
Abschnitt betitelt „Tool-Ausfuehrung“Wenn ein Agent-Schritt tool_calls zurueckgibt, fuehre sie aus und gib die Ergebnisse zurueck:
local json = require("json")local funcs = require("funcs")
local function execute_and_continue(runner, conversation) while true do local response, err = runner:step(conversation) if err then return nil, err end
local tool_calls = response.tool_calls if not tool_calls or #tool_calls == 0 then return response.result, nil end
for _, tc in ipairs(tool_calls) do local result, call_err = funcs.call(tc.registry_id, tc.arguments) local result_str if call_err then result_str = json.encode({ error = tostring(call_err) }) else result_str = json.encode(result) end
conversation:add_function_call(tc.name, tc.arguments, tc.id) conversation:add_function_result(tc.name, result_str, tc.id) end endendTool-Aufruf-Felder
Abschnitt betitelt „Tool-Aufruf-Felder“| Feld | Typ | Beschreibung |
|---|---|---|
id | string | Eindeutiger Aufruf-Identifikator |
name | string | Tool-Name (Alias oder llm_alias) |
arguments | table | Geparste Argumente |
registry_id | string | Vollstaendige Registry-ID fuer funcs.call() |
funcs.call(tc.registry_id, tc.arguments) zur Ausfuehrung von Tools. Das Feld registry_id verweist direkt auf den Eintrag des Tools in der Registry.
Streaming
Abschnitt betitelt „Streaming“Streame Agent-Antworten in Echtzeit mit stream_target:
local TOPIC = "agent_stream"
local function stream_step(runner, conversation) local stream_ch = process.listen(TOPIC)
local done_ch = channel.new(1) coroutine.spawn(function() local response, err = runner:step(conversation, { stream_target = { reply_to = process.pid(), topic = TOPIC, }, }) done_ch:send({ response = response, err = err }) end)
local full_text = "" while true do local result = channel.select({ stream_ch:case_receive(), done_ch:case_receive(), }) if not result.ok then break end
if result.channel == done_ch then process.unlisten(stream_ch) local r = result.value return full_text, r.response, r.err end
local chunk = result.value if chunk.type == "chunk" then io.write(chunk.content or "") full_text = full_text .. (chunk.content or "") elseif chunk.type == "done" then -- wait for the step to complete local r, ok = done_ch:receive() process.unlisten(stream_ch) if ok and r then return full_text, r.response, r.err end return full_text, nil, nil end end
process.unlisten(stream_ch) return full_text, nil, nilendDer Stream verwendet die gleichen Chunk-Typen wie direktes LLM-Streaming: "chunk", "thinking", "tool_call", "error", "done".
coroutine.spawn, um runner:step() in einer separaten Coroutine auszufuehren, damit Stream-Chunks gleichzeitig empfangen werden koennen. Verwende channel.select zum Multiplexen des Stream- und Abschluss-Channels.
Delegates
Abschnitt betitelt „Delegates“Agenten koennen an andere Agenten delegieren. Delegates erscheinen als Tools fuer den uebergeordneten Agenten:
- name: coordinator kind: registry.entry meta: type: agent.gen1 name: coordinator prompt: Route questions to the right specialist. model: gpt-4o max_tokens: 1024 delegates: - id: app:code_agent name: ask_coder rule: for programming questions - id: app:math_agent name: ask_mathematician rule: for math problemsDelegate-Aufrufe erscheinen in response.delegate_calls:
local response = runner:step(conversation)
if response.delegate_calls then for _, dc in ipairs(response.delegate_calls) do -- dc.agent_id - target agent registry ID -- dc.name - delegate tool name -- dc.arguments - forwarded message endendDelegates koennen auch zur Laufzeit hinzugefuegt werden:
ctx:add_delegates({ { id = "app:specialist", name = "ask_specialist", rule = "for domain questions" },})Traits sind wiederverwendbare Faehigkeiten, die Prompts, Tools und Verhalten zu Agenten beitragen:
- name: assistant kind: registry.entry meta: type: agent.gen1 name: assistant prompt: You are a helpful assistant. model: gpt-4o traits: - time_aware - id: custom_trait context: key: valueEingebaute Traits
Abschnitt betitelt „Eingebaute Traits“| Trait | Beschreibung |
|---|---|
time_aware | Fuegt aktuelles Datum und Uhrzeit in den Prompt ein |
Der time_aware-Trait akzeptiert Context-Optionen:
traits: - id: time_aware context: timezone: America/New_York time_interval: 15Eigene Traits
Abschnitt betitelt „Eigene Traits“Traits sind Registry-Eintraege mit meta.type: agent.trait. Sie koennen folgendes beitragen:
- prompt - statischer Text, der an den System-Prompt angehaengt wird
- build_func_id - Funktion, die zur Kompilierungszeit aufgerufen wird, um Tools, Prompts und Delegates beizutragen
- prompt_func_id - Funktion, die bei jedem Schritt aufgerufen wird, um dynamische Inhalte einzufuegen
- step_func_id - Funktion, die bei jedem Schritt fuer Seiteneffekte aufgerufen wird
Statisches Memory
Abschnitt betitelt „Statisches Memory“Einfache Memory-Eintraege, die an den System-Prompt angehaengt werden:
- name: assistant kind: registry.entry meta: type: agent.gen1 name: assistant prompt: You are a helpful assistant. model: gpt-4o memory: - "User prefers concise answers" - "Always cite sources when possible"Dynamischer Memory-Contract
Abschnitt betitelt „Dynamischer Memory-Contract“Konfiguriere dynamischen Memory-Abruf aus einer externen Quelle:
memory_contract: implementation_id: app:memory_store context: user_id: "${user_id}" options: max_items: 3 max_length: 1000 recall_cooldown: 1 min_conversation_length: 2Der Memory-Contract wird waehrend runner:step() aufgerufen, um relevante Eintraege basierend auf dem Konversationskontext abzurufen. Ergebnisse werden als Developer-Nachrichten eingefuegt.
| Option | Standard | Beschreibung |
|---|---|---|
max_items | 3 | Maximale Memory-Eintraege pro Abruf |
max_length | 1000 | Maximale Gesamtzeichenlaenge |
recall_cooldown | 1 | Mindestanzahl Schritte zwischen Abrufen |
min_conversation_length | 2 | Mindestanzahl Konversationsdurchgaenge vor dem ersten Abruf |
Resolver-Contract
Abschnitt betitelt „Resolver-Contract“Wenn load_agent() einen String-Identifikator erhaelt, versucht es zuerst, ihn ueber den wippy.agent:resolver-Contract aufzuloesen. Falls kein Resolver gebunden ist oder der Resolver nil zurueckgibt, wird auf die Registry-Suche zurueckgegriffen.
Dies ermoeglicht es Anwendungen, eigene Agent-Aufloesung zu implementieren, z.B. das Laden von Agent-Definitionen aus einer Datenbank.
Einen Resolver binden
Abschnitt betitelt „Einen Resolver binden“Definiere eine Resolver-Funktion und binde sie an den Contract:
entries: - name: agent_resolver.resolve kind: function.lua source: file://agent_resolver.lua method: resolve modules: - logger imports: agent_registry: wippy.agent.discovery:registry
- name: agent_resolver_binding kind: contract.binding contracts: - contract: wippy.agent:resolver default: true methods: resolve: app:agent_resolver.resolveResolver-Implementierung
Abschnitt betitelt „Resolver-Implementierung“Der Resolver erhaelt { agent_id = "..." } und gibt eine Agent-Spezifikationstabelle oder nil zurueck:
local agent_registry = require("agent_registry")
local CUSTOM_PREFIX = "custom:"
function resolve(args) local agent_id = args.agent_id if not agent_id then return nil, "agent_id is required" end
if agent_id:sub(1, #CUSTOM_PREFIX) == CUSTOM_PREFIX then local id = agent_id:sub(#CUSTOM_PREFIX + 1)
-- load from database, config file, or any other source return { id = agent_id, name = "custom-agent", prompt = "You are a custom agent.", model = "class:balanced", max_tokens = 1024, tools = {}, } end
-- fall back to registry local spec, err = agent_registry.get_by_id(agent_id) if not spec then spec, err = agent_registry.get_by_name(agent_id) end return spec, errend
return { resolve = resolve,}Aufloesungsreihenfolge
Abschnitt betitelt „Aufloesungsreihenfolge“wippy.agent:resolver-Contract versuchen (falls gebunden)- Registry-Suche per ID
- Registry-Suche per Name
- Fehler zurueckgeben, falls nicht gefunden
Dieses Muster ermoeglicht mandantenfaehige Anwendungen, bei denen Agenten pro Benutzer oder pro Workspace konfiguriert und ausserhalb der Framework-Registry gespeichert werden.
Siehe auch
Abschnitt betitelt „Siehe auch“- LLM - Zugrundeliegendes LLM-Modul
- Einen LLM-Agenten erstellen - Schritt-fuer-Schritt-Tutorial
- Framework-Uebersicht - Nutzung der Framework-Module