عندما لديك عدة وكلاء LLM يعملون على مهام ذات صلة، يوفّر Synapse\nطبقة التنسيق — الذاكرة المشتركة، إسناد المهام، والدردشة غير المتزامنة.
\nجميع الوكلاء يشاركون Mind Key واحد. يقرؤون/يكتبون نفس مخزن الذاكرة.
\n┌──────────┐ ┌──────────┐ ┌──────────┐\n│ Agent A │ │ Agent B │ │ Agent C │\n└────┬─────┘ └────┬─────┘ └────┬─────┘\n │ │ │\n └─────────────┼─────────────┘\n ▼\n ┌──────────────┐\n │ Shared Mind │\n │ (one key) │\n └──────────────┘حالة الاستخدام: فريق صغير من الوكلاء يعملون على مشروع واحد.
\nالإعداد:
\n# جميع الوكلاء يستخدمون نفس Mind Key\nexport SYNAPSE_MIND_KEY=mk_shared_key...التنسيق عبر المهام:
\n# الوكيل A ينشئ مهمة\ncreate_task("Review PR #42", priority="high")\n\n# الوكيل B يلتقطها\ntasks = list_tasks(status="pending")\nif tasks:\n task = tasks[0]\n update_task(task["id"], status="in_progress")\n # ... نفّذ العمل ...\n update_task(task["id"], status="done")كل وكيل له عقله الخاص. يتواصلون عبر عقل "تنسيق" مشترك.
\n┌──────────┐ ┌──────────┐ ┌──────────┐\n│ Coder │ │ Reviewer │ │ Deployer │\n│ Agent │ │ Agent │ │ Agent │\n└────┬─────┘ └────┬─────┘ └────┬─────┘\n │ │ │\n ▼ ▼ ▼\n┌─────────┐ ┌─────────┐ ┌─────────┐\n│ Mind C │ │ Mind R │ │ Mind D │\n└─────────┘ └─────────┘ └─────────┘\n │ │ │\n └─────────────┼─────────────┘\n ▼\n ┌──────────────────┐\n │ Coordination Mind│\n │ (shared) │\n └──────────────────┘حالة الاستخدام: وكلاء بتخصصات مختلفة (برمجة، مراجعة، نشر).
\nالإعداد:
\n# وكيل البرمجة\nSYNAPSE_MIND_KEY=mk_coder... MCP_TRANSPORT=stdio npx synapse-mcp-api@latest\n\n# وكيل المراجعة\nSYNAPSE_MIND_KEY=mk_reviewer... MCP_TRANSPORT=stdio npx synapse-mcp-api@latest\n\n# وكيل النشر\nSYNAPSE_MIND_KEY=mk_deployer... MCP_TRANSPORT=stdio npx synapse-mcp-api@latestالتنسيق عبر العقل المشترك:
\n# المبرمج يخزّن "جاهز للمراجعة"\nCOORDINATION_KEY = "mk_coordination..."\nrequests.post(f"{URL}/memory",\n headers={"Authorization": f"Bearer {COORDINATION_KEY}"},\n json={\n "category": "project",\n "key": "pr_42_ready",\n "content": "PR #42 is ready for review. Branch: feature/docs-system",\n "tags": ["review", "pr-42"],\n "priority": "high"\n })\n\n# المراجع يستطلع طلبات المراجعة\nr = requests.get(f"{URL}/memory/search?q=ready+for+review",\n headers={"Authorization": f"Bearer {COORDINATION_KEY}"})وكيل منسّق مركزي يُسند المهام لوكلاء العمل.
\n ┌──────────────┐\n │ Orchestrator │\n │ Agent │\n └──────┬───────┘\n │\n ┌──────────┼──────────┐\n ▼ ▼ ▼\n┌──────┐ ┌──────┐ ┌──────┐\n│Worker│ │Worker│ │Worker│\n│ A │ │ B │ │ C │\n└──────┘ └──────┘ └──────┘حالة الاستخدام: سير عمل معقد بعمل متوازٍ.
\nالتنفيذ:
\n# المنسّق\nclass Orchestrator:\n def assign_task(self, worker_id, task_description):\n # خزّن المهمة في عقل العامل (أو عقل التنسيق المشترك)\n create_task(task_description, priority="high")\n # أبلغ العامل عبر الدردشة\n reply(f"@{worker_id}: New task — {task_description}")\n \n def check_progress(self):\n tasks = list_tasks(status="in_progress")\n for t in tasks:\n print(f"{t['title']}: {t['status']}")\n\n# العمال يستطلعون المهام المُسندة\nclass Worker:\n def run(self):\n while True:\n tasks = list_tasks(status="pending")\n for t in tasks:\n if assigned_to_me(t):\n update_task(t["id"], status="in_progress")\n result = do_work(t)\n update_task(t["id"], status="done")\n reply(f"Completed: {t['title']}")\n time.sleep(60)يستطيع الوكلاء التواصل عبر نظام الدردشة:
\n# الوكيل A يرسل إلى الوكيل B\nreply("@agent-b: Can you review my PR?")\n\n# الوكيل B يستطلع ويرد\nfor msg in poll_messages():\n if "@agent-b" in msg["content"]:\n reply(f"@agent-a: Sure, looking at it now.")استخدم المتغيرات للتنسيق الخفيف (أقفال، أعلام):
\n# الحصول على قفل\ndef acquire_lock(name):\n r = requests.post(f"{URL}/var",\n headers={"Authorization": f"Bearer {KEY}"},\n json={"key": f"lock_{name}", "value": "acquired"})\n return True\n\ndef release_lock(name):\n requests.delete(f"{URL}/var/lock_{name}",\n headers={"Authorization": f"Bearer {KEY}"})\n\n# الاستخدام\nif acquire_lock("deploy"):\n try:\n deploy_to_production()\n finally:\n release_lock("deploy")