# Çok Ajan Koordinasyonu İlgili görevler üzerinde çalışan birden çok LLM ajanınız olduğunda, Synapse koordinasyon katmanı sağlar — paylaşımlı bellek, görev ataması ve asenkron sohbet. ## Desenler ### Desen 1: Paylaşımlı Mind (Tek Doğruluk Kaynağı) Tüm ajanlar bir Mind Key paylaşır. Aynı bellek deposunu okur/yazar. ``` ┌──────────┐ ┌──────────┐ ┌──────────┐ │ Agent A │ │ Agent B │ │ Agent C │ └────┬─────┘ └────┬─────┘ └────┬─────┘ │ │ │ └─────────────┼─────────────┘ ▼ ┌──────────────┐ │ Shared Mind │ │ (one key) │ └──────────────┘ ``` **Kullanım senaryosu:** Bir proje üzerinde çalışan küçük bir ajan ekibi. **Kurulum:** ```bash # All agents use the same Mind Key export SYNAPSE_MIND_KEY=mk_shared_key... ``` **Görevlerle koordinasyon:** ```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") ``` ### Desen 2: Uzmanlaşmış Mind'ler (İzole Bağlamlar) Her ajanın kendi mind'i vardır. Paylaşımlı bir "koordinasyon" mind'i üzerinden iletişim kurarlar. ``` ┌──────────┐ ┌──────────┐ ┌──────────┐ │ Coder │ │ Reviewer │ │ Deployer │ │ Agent │ │ Agent │ │ Agent │ └────┬─────┘ └────┬─────┘ └────┬─────┘ │ │ │ ▼ ▼ ▼ ┌─────────┐ ┌─────────┐ ┌─────────┐ │ Mind C │ │ Mind R │ │ Mind D │ └─────────┘ └─────────┘ └─────────┘ │ │ │ └─────────────┼─────────────┘ ▼ ┌──────────────────┐ │ Coordination Mind│ │ (shared) │ └──────────────────┘ ``` **Kullanım senaryosu:** Farklı uzmanlıklara sahip ajanlar (kodlama, inceleme, dağıtım). **Kurulum:** ```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 ``` **Paylaşımlı mind ile koordinasyon:** ```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}"}) ``` ### Desen 3: Hub-and-Spoke (Orkestratör) Merkezi bir orkestratör ajan, işçi ajanlara görevler atar. ``` ┌──────────────┐ │ Orchestrator │ │ Agent │ └──────┬───────┘ │ ┌──────────┼──────────┐ ▼ ▼ ▼ ┌──────┐ ┌──────┐ ┌──────┐ │Worker│ │Worker│ │Worker│ │ A │ │ B │ │ C │ └──────┘ └──────┘ └──────┘ ``` **Kullanım senaryosu:** Paralel çalışmalı karmaşık iş akışları. **Uygulama:** ```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) ``` ## Sohbet Üzerinden Koordinasyon Ajanlar sohbet sistemi üzerinden iletişim kurabilir: ```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] > Sohbet mesajları rol etiketlidir. Ajan-ajan mesajları için role=agent, insan-ajan için role=human ayarlayın. ## Değişkenler Üzerinden Koordinasyon Hafif koordinasyon (kilitler, bayraklar) için değişkenler kullanın: ```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") ``` ## En İyi Uygulamalar > [!TIP] > - **Ayrı konular için ayrı mind'ler kullanın** — kodlayıcı ve inceleyici belleğini karıştırmayın > - **Sohbette ajanları etiketleyin** — net adresleme için `@agent-name` > - **İş ataması için görevleri kullanın** — sohbet değil (sohbet tartışma içindir) > - **İdempotensi uygulayın** — ajanlar başarısız işlemleri yeniden deneyebilir > - **Her şeyi loglayın** — denetlenebilirlik için kararları bellekte saklayın ## Sonraki Adımlar - [Kalıcı LLM Ajanı](/docs/guides/persistent-llm-agent) - [LLM Cookbook](/docs/llm-cookbook/session-start-pattern) - [Webhook Otomasyonu](/docs/guides/webhook-automation)