# Multi-agent-coördinatie Wanneer u meerdere LLM-agents heeft die aan gerelateerde taken werken, biedt Synapse de coördinatielaag — gedeeld geheugen, taaktoewijzing en asynchrone chat. ## Patronen ### Patroon 1: Gedeelde mind (enkele bron van waarheid) Alle agents delen één Mind Key. Ze lezen/schrijven naar dezelfde memory-opslag. ``` ┌──────────┐ ┌──────────┐ ┌──────────┐ │ Agent A │ │ Agent B │ │ Agent C │ └────┬─────┘ └────┬─────┘ └────┬─────┘ │ │ │ └─────────────┼─────────────┘ ▼ ┌──────────────┐ │ Shared Mind │ │ (one key) │ └──────────────┘ ``` **Toepassing:** Klein team van agents aan één project. **Setup:** ```bash # All agents use the same Mind Key export SYNAPSE_MIND_KEY=mk_shared_key... ``` **Coördinatie via taken:** ```python # Agent A creates a task create_task("Review PR #42", priority="high") # Agent B picks it up tasks = list_tasks(status="pending") if tasks: task = tasks[0] update_task(task["id"], status="in_progress") # ... do work ... update_task(task["id"], status="done") ``` ### Patroon 2: Gespecialiseerde minds (geïsoleerde contexten) Elke agent heeft zijn eigen mind. Ze communiceren via een gedeelde "coördinatie"-mind. ``` ┌──────────┐ ┌──────────┐ ┌──────────┐ │ Coder │ │ Reviewer │ │ Deployer │ │ Agent │ │ Agent │ │ Agent │ └────┬─────┘ └────┬─────┘ └────┬─────┘ │ │ │ ▼ ▼ ▼ ┌─────────┐ ┌─────────┐ ┌─────────┐ │ Mind C │ │ Mind R │ │ Mind D │ └─────────┘ └─────────┘ └─────────┘ │ │ │ └─────────────┼─────────────┘ ▼ ┌──────────────────┐ │ Coordination Mind│ │ (shared) │ └──────────────────┘ ``` **Toepassing:** Agents met verschillende specialiteiten (coderen, review, deployment). **Setup:** ```bash # Coder agent SYNAPSE_MIND_KEY=mk_coder... MCP_TRANSPORT=stdio npx synapse-mcp-api@latest # Reviewer agent SYNAPSE_MIND_KEY=mk_reviewer... MCP_TRANSPORT=stdio npx synapse-mcp-api@latest # Deployer agent SYNAPSE_MIND_KEY=mk_deployer... MCP_TRANSPORT=stdio npx synapse-mcp-api@latest ``` **Coördinatie via gedeelde mind:** ```python # Coder stores "ready for review" COORDINATION_KEY = "mk_coordination..." requests.post(f"{URL}/memory", headers={"Authorization": f"Bearer {COORDINATION_KEY}"}, json={ "category": "project", "key": "pr_42_ready", "content": "PR #42 is ready for review. Branch: feature/docs-system", "tags": ["review", "pr-42"], "priority": "high" }) # Reviewer polls for review requests r = requests.get(f"{URL}/memory/search?q=ready+for+review", headers={"Authorization": f"Bearer {COORDINATION_KEY}"}) ``` ### Patroon 3: Hub-and-Spoke (orchestrator) Een centrale orchestrator-agent wijst taken toe aan worker-agents. ``` ┌──────────────┐ │ Orchestrator │ │ Agent │ └──────┬───────┘ │ ┌──────────┼──────────┐ ▼ ▼ ▼ ┌──────┐ ┌──────┐ ┌──────┐ │Worker│ │Worker│ │Worker│ │ A │ │ B │ │ C │ └──────┘ └──────┘ └──────┘ ``` **Toepassing:** Complexe workflows met parallel werk. **Implementatie:** ```python # Orchestrator class Orchestrator: def assign_task(self, worker_id, task_description): # Store task in worker's mind (or shared coordination mind) create_task(task_description, priority="high") # Notify worker via chat reply(f"@{worker_id}: New task — {task_description}") def check_progress(self): tasks = list_tasks(status="in_progress") for t in tasks: print(f"{t['title']}: {t['status']}") # Workers poll for assigned tasks class Worker: def run(self): while True: tasks = list_tasks(status="pending") for t in tasks: if assigned_to_me(t): update_task(t["id"], status="in_progress") result = do_work(t) update_task(t["id"], status="done") reply(f"Completed: {t['title']}") time.sleep(60) ``` ## Coördinatie via chat Agents kunnen communiceren via het chat-systeem: ```python # Agent A sends to Agent B reply("@agent-b: Can you review my PR?") # Agent B polls and responds for msg in poll_messages(): if "@agent-b" in msg["content"]: reply(f"@agent-a: Sure, looking at it now.") ``` > [!NOTE] > Chatberichten zijn role-tagged. Stel role=agent in voor agent-naar-agent-berichten, > role=human voor mens-naar-agent. ## Coördinatie via variabelen Gebruik variabelen voor lichte coördinatie (locks, vlaggen): ```python # Acquire a lock def acquire_lock(name): r = requests.post(f"{URL}/var", headers={"Authorization": f"Bearer {KEY}"}, json={"key": f"lock_{name}", "value": "acquired"}) return True def release_lock(name): requests.delete(f"{URL}/var/lock_{name}", headers={"Authorization": f"Bearer {KEY}"}) # Use if acquire_lock("deploy"): try: deploy_to_production() finally: release_lock("deploy") ``` ## Best practices > [!TIP] > - **Gebruik aparte minds voor aparte zaken** — meng coder- en review-memory niet > - **Tag agents in chat** — `@agent-name` voor duidelijke adressering > - **Gebruik taken voor werktoewijzing** — niet chat (chat is voor discussie) > - **Implementeer idempotentie** — agents kunnen mislukte operaties opnieuw proberen > - **Log alles** — sla beslissingen op in memory voor auditability ## Volgende stappen - [Permanente LLM-agent](/docs/guides/persistent-llm-agent) - [LLM-cookbook](/docs/llm-cookbook/session-start-pattern) - [Webhook-automatisering](/docs/guides/webhook-automation)