Multi-Agent Orchestration Patterns with OpenClaw

ایک واحد AI ایجنٹ کسی عمل کو خودکار کر سکتا ہے۔ ایجنٹوں کا ایک اچھی طرح سے آرکیسٹریٹڈ نظام کاروباری کام کو خودکار کر سکتا ہے۔ فرق اس بات میں ہے کہ ایجنٹ کس طرح ہم آہنگی کرتے ہیں، بات چیت کرتے ہیں اور ناکامی کو حدود کے پار ہینڈل کرتے ہیں۔ ملٹی ایجنٹ آرکیسٹریشن ایک انجینئرنگ ڈسپلن ہے جو آزاد بوٹس کے مجموعے اور ایک مربوط، قابل اعتماد خود مختار نظام کے درمیان فرق پیدا کرتا ہے۔

OpenClaw ملٹی ایجنٹ آرکیسٹریشن کے لیے بنیادی چیزیں فراہم کرتا ہے: ایک ٹائپ شدہ میسج بس، ایک ایجنٹ رجسٹری، ہینڈ آف پروٹوکول، مشترکہ میموری نام کی جگہیں، اور تقسیم شدہ ٹریسنگ جو ایجنٹ کی حدود میں درخواستوں کی پیروی کرتی ہے۔ اس گائیڈ میں آرکیسٹریشن کے چار بنیادی نمونوں کا احاطہ کیا گیا ہے، ہر ایک کو کب استعمال کرنا ہے، انہیں OpenClaw میں کیسے لاگو کرنا ہے، اور اس کے خلاف ڈیزائن کرنے میں ناکامی کے طریقوں کا احاطہ کرتا ہے۔

اہم ٹیک ویز

• سپروائزر ورکر پیٹرن سب سے عام فن تعمیر ہے: ایک آرکیسٹریٹنگ ایجنٹ اہداف کو تحلیل کرتا ہے اور خصوصی کارکنوں کو ڈیلیگیٹس کرتا ہے۔
• پائپ لائن پیٹرن ترتیب وار دستاویز پروسیسنگ یا ملٹی سٹیپ ڈیٹا ٹرانسفارمیشن کے لیے بہترین ہے جہاں ہر مرحلہ اگلے کے لیے ان پٹ تیار کرتا ہے۔
• اتفاق رائے کا نمونہ متعدد آزاد ایجنٹوں کو ایک ہی سوال کا جائزہ لینے کے قابل بناتا ہے، جس سے اعلیٰ داؤ پر لگائے گئے فیصلوں میں واحد ایجنٹ کی غلطیوں کا خطرہ کم ہوتا ہے۔
• مارکیٹ میکر پیٹرن سب سے زیادہ قابل دستیاب ایجنٹ کو متحرک طور پر کام مختص کرتا ہے، جس سے بوجھ میں توازن پیدا ہوتا ہے اور خوبصورتی سے انحطاط ہوتا ہے۔
• کراس ایجنٹ کمیونیکیشن OpenClaw کی ٹائپ شدہ میسج بس کا استعمال کرتی ہے—کوئی خام تار نہیں گزرتی، ایجنٹوں کے درمیان کوئی مشترکہ تغیر پذیر حالت نہیں۔
• تقسیم شدہ ٹریسنگ ملٹی ایجنٹ ڈیبگنگ کے لیے ضروری ہے—ہر پیغام میں ایک ارتباطی ID ہوتا ہے جو ایجنٹ کی حدود کو پھیلاتا ہے۔
• ایجنٹ کی باؤنڈری پر سرکٹ بریکر جب سسٹم میں ایک ایجنٹ دستیاب نہ ہو تو جھرن کی ناکامیوں کو روکتے ہیں۔
• ECOSIRE پیچیدہ انٹرپرائز آٹومیشن ورک فلوز کے لیے ملٹی ایجنٹ آرکیٹیکچرز کو ڈیزائن اور لاگو کرتا ہے۔

---

فاؤنڈیشن: اوپن کلا کا ایجنٹ کمیونیکیشن ماڈل

پیٹرن کا احاطہ کرنے سے پہلے، یہ سمجھنا ضروری ہے کہ OpenClaw ایجنٹ کیسے بات چیت کرتے ہیں۔ تین میکانزم ہیں، ہر ایک مختلف تجارت کے ساتھ:

دی میسج بس ایک ہی سسٹم میں ایجنٹوں کے درمیان بنیادی مواصلاتی چینل ہے۔ ایجنٹ نامی چینلز پر ٹائپ شدہ پیغامات شائع کرتے ہیں۔ دوسرے ایجنٹ ان چینلز کو سبسکرائب کرتے ہیں۔ پیغامات بس بروکر (ریڈیس اسٹریمز یا کافکا، کنفیگر ایبل) کے ذریعے جاری رہتے ہیں، لہذا اگر وصول کرنے والا ایجنٹ عارضی طور پر دستیاب نہ ہو تو پیغامات ضائع نہیں ہوتے۔

براہ راست درخواست ایک ایجنٹ کو دوسرے ایجنٹ کی بے نقاب مہارتوں کو براہ راست کال کرنے اور جواب کا انتظار کرنے کی اجازت دیتی ہے۔ یہ کال کرنے والے کے نقطہ نظر سے ہم آہنگ ہے اور کم تاخیر والے ورک فلو کے لیے موزوں ہے جہاں کالنگ ایجنٹ اس وقت تک آگے نہیں بڑھ سکتا جب تک کہ اس کا نتیجہ نہ نکل جائے۔ تھوڑا سا استعمال کریں - یہ ایجنٹوں کے درمیان سخت جوڑے پیدا کرتا ہے۔

مشترکہ میموری نام کی جگہیں ایک ہی سسٹم میں موجود ایجنٹوں کو میموری اسٹور کے مشترکہ علاقے سے پڑھنے اور لکھنے کی اجازت دیتی ہیں۔ یہ بڑے سیاق و سباق کی اشیاء (ایک دستاویز پر کارروائی کی جا رہی ہے، ایک کسٹمر پروفائل کو تمام مراحل میں افزودہ کیا جا رہا ہے) کو پیغام کے پے لوڈز کے ذریعے سیریلائز کیے بغیر منتقل کرنے کے لیے موزوں ہے۔

// Publishing a message
await messageBus.publish("document.classified", {
  documentId: "DOC-4521",
  type: "vendor-invoice",
  confidence: 0.94,
  storageKey: "incoming/doc-4521.pdf",
});

// Subscribing to messages
messageBus.subscribe("document.classified", async (message) => {
  await extractionAgent.handle(message);
});

تمام پیغامات میں ایک ارتباطی ID، ٹائم اسٹیمپ، سورس ایجنٹ ID، اور سکیما ورژن شامل ہوتا ہے۔ اسکیما ورژن میسج بس کو اپنے اعلان کردہ معاہدے کے خلاف پیغامات کی توثیق کرنے اور وصول کنندہ ایجنٹ تک پہنچنے سے پہلے غلط پیغامات کو مسترد کرنے کی اجازت دیتا ہے۔

---

پیٹرن 1: سپروائزر- ورکر

سپروائزر ورکر پیٹرن سب سے زیادہ قابل اطلاق ملٹی ایجنٹ فن تعمیر ہے۔ ایک سپروائزر ایجنٹ اعلیٰ سطح کا ہدف حاصل کرتا ہے، اسے ذیلی کاموں میں تحلیل کرتا ہے، ہر ذیلی کام کو ایک خصوصی ورکر ایجنٹ کو تفویض کرتا ہے، پیشرفت کی نگرانی کرتا ہے، اور نتائج کی ترکیب کرتا ہے۔

User/System Goal
      ↓
[ Supervisor Agent ]
  ├─ task 1 → [ Worker Agent A ]
  ├─ task 2 → [ Worker Agent B ]
  └─ task 3 → [ Worker Agent C ]
      ↓
[ Supervisor Agent ] ← results from all workers
      ↓
Synthesized Response

کب استعمال کرنا ہے: جب ایک پیچیدہ مقصد کے لیے متفاوت مہارت کی ضرورت ہوتی ہے۔ سپروائزر کوآرڈینیشن منطق کو سنبھالتا ہے؛ کارکنان ڈومین کے ماہرین ہیں جو ایک کام اچھی طرح کرتے ہیں۔

اوپن کلا کا نفاذ:

export const SupervisorAgent = defineAgent({
  name: "due-diligence-supervisor",
  skills: ["decompose-goal", "assign-workers", "synthesize-results"],
  async run({ goal, workerRegistry, messageBus }) {
    // Decompose goal into tasks
    const tasks = await decomposeGoal(goal);

    // Assign to appropriate workers
    const assignments = tasks.map((task) => ({
      task,
      worker: workerRegistry.findBestMatch(task.type),
    }));

    // Publish tasks and wait for results
    const results = await Promise.allSettled(
      assignments.map(({ task, worker }) =>
        messageBus.requestReply(`worker.${worker.id}.tasks`, task, { timeoutMs: 60_000 })
      )
    );

    // Synthesize
    const successfulResults = results
      .filter((r) => r.status === "fulfilled")
      .map((r) => r.value);

    return synthesize(goal, successfulResults);
  },
});

اہم ڈیزائن کے فیصلے:

• سپروائزر میں ڈومین لاجک نہیں ہونا چاہیے - اسے صرف کوآرڈینیٹ ہونا چاہیے۔
• ورکرز کو بے وطن اور آزادانہ طور پر قابل توسیع ہونا چاہیے۔
• ناکام کارکن کے کاموں کی دوبارہ کوشش سپروائزر کے ذریعے کی جاتی ہے، نہ کہ کارکن اندرونی طور پر۔
• سپروائزر کی سطح پر ٹاسک ٹائم آؤٹ ایک سست کارکن کو پورے ورک فلو کو روکنے سے روکتا ہے۔

حقیقی دنیا کی مثال: ڈیو ڈیلیجنس آٹومیشن سسٹم جہاں سپروائزر کمپنی کے جائزے کو مالیاتی تجزیہ کارکن، قانونی دستاویز کا جائزہ لینے والے کارکن، مارکیٹ ریسرچ ورکر، اور حوالہ چیک ورکر کو تفویض کردہ متوازی کاموں میں تحلیل کرتا ہے۔ سپروائزر تمام نتائج کو ایک متحد واجبی مستعدی رپورٹ میں یکجا کرتا ہے۔

---

پیٹرن 2: پائپ لائن

پائپ لائن پیٹرن ایجنٹوں کو ترتیب دیتا ہے تاکہ ہر ایجنٹ کا آؤٹ پٹ اگلے ایجنٹ کا ان پٹ بن جائے۔ یہ دستاویز کی پروسیسنگ، ڈیٹا کی افزودگی، اور کسی بھی ورک فلو کے لیے مثالی ہے جہاں ہر قدم ایک متعین ترتیب میں پے لوڈ کو تبدیل یا افزودہ کرتا ہے۔

Input Document
    ↓
[ Stage 1: Ingestion Agent ]
    ↓
[ Stage 2: Classification Agent ]
    ↓
[ Stage 3: Extraction Agent ]
    ↓
[ Stage 4: Validation Agent ]
    ↓
[ Stage 5: Integration Agent ]
    ↓
Output: ERP Record

کب استعمال کرنا ہے: واضح اسٹیج کی حدود اور ہر قدم پر تبدیلی کے ساتھ ترتیب وار ورک فلو۔ ہائی تھرو پٹ دستاویز پروسیسنگ کے لیے بہترین۔

اوپن کلا کا نفاذ:

OpenClaw's Pipeline Primitive اسٹیج چین کا انتظام کرتی ہے، ناکامیوں کو سنبھالتی ہے، اور پے لوڈ مواد کی بنیاد پر کسی بھی مرحلے پر برانچنگ کو سپورٹ کرتی ہے۔

import { definePipeline } from "@openclaw/orchestration";

export const InvoicePipeline = definePipeline({
  name: "invoice-processing",
  stages: [
    { agent: "document-ingester", timeout: 30_000 },
    {
      agent: "document-classifier",
      timeout: 15_000,
      branch: {
        "vendor-invoice": "invoice-extractor",
        "credit-memo": "credit-memo-extractor",
        "unknown": "human-review-queue", // Branch to exception handling
      },
    },
    { agent: "invoice-validator", timeout: 20_000 },
    { agent: "invoice-enricher", timeout: 10_000 },
    { agent: "erp-integrator", timeout: 30_000, retries: 3 },
  ],
  onFailure: {
    agent: "exception-handler",
    preservePartialState: true,
  },
});

اہم ڈیزائن کے فیصلے:

• ہر سٹیج کو کمزور ہونا چاہیے — اگر یہ ایک ہی ان پٹ کے ساتھ دو بار چلتا ہے، تو یہ ایک ہی آؤٹ پٹ پیدا کرتا ہے۔
• onFailure ہینڈلر کو پائپ لائن کی جزوی حالت موصول ہوتی ہے تاکہ یہ دوبارہ شروع کرنے کے بجائے آخری کامیاب مرحلے سے دوبارہ شروع ہو سکے۔
• برانچنگ مختلف دستاویزات کی اقسام کو درجہ بندی کے بعد مختلف ذیلی پائپ لائنوں کی پیروی کرنے کی اجازت دیتی ہے۔
• میسج بس کے ذریعے سیریلائز کرنے کے بجائے مراحل کے درمیان بڑے پے لوڈز (دستاویز بفرز) کو منتقل کرنے کے لیے مشترکہ میموری نام کی جگہ کا استعمال کریں۔

ناکامی ہینڈلنگ: جب M کے کامیاب مراحل کے بعد اسٹیج N ناکام ہوجاتا ہے، تو پائپ لائن کی حالت اسٹیج M پر چیک پوائنٹ کی جاتی ہے۔ ناکامی کے حل ہونے کے بعد (دستی اصلاح، انحصار کی بحالی کے بعد دوبارہ کوشش کریں)، پائپ لائن اسی پے لوڈ کے ساتھ اسٹیج M+1 سے دوبارہ شروع ہوتی ہے۔

---

پیٹرن 3: اتفاق رائے

Consensus پیٹرن ایک ہی ان پٹ کے خلاف متعدد آزاد ایجنٹوں کو چلاتا ہے اور سسٹم کے کام کرنے سے پہلے ان سے (ایک حد کے اندر) متفق ہونے کا تقاضا کرتا ہے۔ یہ دوسری رائے کے ملٹی ایجنٹ کے مساوی ہے اور ہائی اسٹیک فیصلوں میں سب سے زیادہ قیمتی ہے جہاں ایک ایجنٹ کی غلطی مہنگی ہوگی۔

Input
  ├─ → [ Evaluator Agent A ] → assessment A
  ├─ → [ Evaluator Agent B ] → assessment B
  └─ → [ Evaluator Agent C ] → assessment C
          ↓
  [ Consensus Resolver ]
    ├── unanimous or majority? → act
    └── no consensus? → escalate to human

کب استعمال کرنا ہے: ہائی اسٹیک فیصلے (قرض کی منظوری، دھوکہ دہی کا پتہ لگانے، میڈیکل ریکارڈ کا تجزیہ، معاہدے کی شق کا جائزہ)، مخالفانہ ان پٹ جہاں ایک ہی ایجنٹ سے ہیرا پھیری کی جاسکتی ہے، یا ایسی صورت حال جہاں مختلف ماڈلز کی تکمیلی طاقت ہوتی ہے۔

اوپن کلا کا نفاذ:

export const FraudConsensusCheck = defineAgent({
  name: "fraud-consensus",
  async run({ transaction, evaluators }) {
    // Run all evaluators in parallel
    const assessments = await Promise.all(
      evaluators.map((evaluator) =>
        evaluator.assess(transaction)
      )
    );

    const fraudVotes = assessments.filter((a) => a.isFraud).length;
    const totalVotes = assessments.length;
    const agreementRatio = fraudVotes / totalVotes;

    if (agreementRatio >= 0.67) { // Supermajority fraud detection
      return { decision: "block", confidence: agreementRatio, assessments };
    } else if (agreementRatio === 0) { // Unanimous clear
      return { decision: "allow", confidence: 1 - agreementRatio, assessments };
    } else {
      // Disagreement — escalate with all assessments for human review
      return { decision: "escalate", confidence: null, assessments };
    }
  },
});

اہم ڈیزائن کے فیصلے:

• تشخیص کرنے والے ایجنٹوں کو متعلقہ ناکامیوں کو کم کرنے کے لیے مختلف ماڈلز یا مختلف اشتعال انگیز حکمت عملیوں کا استعمال کرنا چاہیے۔ دو ایجنٹ جو ایک ہی ماڈل کو ایک ہی پرامپٹ کے ساتھ استعمال کرتے ہیں وہ عام طور پر متفق ہوں گے - جو مقصد کو شکست دیتا ہے۔
• اتفاق رائے کی حد قابل ترتیب ہے۔ متفقہ معاہدہ ناقابل واپسی اقدامات کے لیے موزوں ہے۔ الٹ جانے والے فیصلوں کے لیے سادہ اکثریت کافی ہے۔
• بڑھنے کے راستوں کو صلاحیت کی منصوبہ بندی کی ضرورت ہوتی ہے — اگر آپ کی ترقی کی شرح زیادہ ہے، تو تشخیص کرنے والے کے معیار کو ٹیوننگ کی ضرورت ہے۔

---

پیٹرن 4: مارکیٹ بنانے والا

مارکیٹ میکر پیٹرن ورکر ایجنٹس کے ایک پول کو برقرار رکھتا ہے اور ٹاسک پہنچنے کے وقت سب سے مناسب دستیاب کارکن کو متحرک طور پر کام مختص کرتا ہے۔ کارکنان اپنی صلاحیتوں اور موجودہ بوجھ کو رجسٹر کرتے ہیں۔ مارکیٹ میکر ہر کام کو بہترین میچ کی طرف لے جاتا ہے۔

Task Queue
    ↓
[ Market-Maker Agent ]
    ├── Worker A: [language-translation] load: 30%
    ├── Worker B: [language-translation] load: 80%
    └── Worker C: [language-translation] load: 10%  ← assigned

کب استعمال کریں: ہائی تھرو پٹ سسٹم جہاں کام کا حجم نمایاں طور پر مختلف ہوتا ہے۔ روٹنگ منطق کو تبدیل کیے بغیر ورکر ایجنٹس کی افقی اسکیلنگ کو فعال کرتا ہے۔ خوبصورت تنزلی کو بھی قابل بناتا ہے — اگر کوئی خصوصی کارکن دستیاب نہ ہو تو، مارکیٹ میکر کام کو ناکام کرنے کے بجائے کم کارکردگی والے عام کارکن کے پاس جا سکتا ہے۔

export const TranslationMarketMaker = defineAgent({
  name: "translation-market-maker",
  tools: ["worker-registry", "task-queue"],
  async run({ tools }) {
    while (true) {
      const task = await tools.taskQueue.dequeue("translation.pending");
      if (!task) { await sleep(100); continue; }

      const workers = await tools.workerRegistry.getAvailable({
        capability: "language-translation",
        targetLanguage: task.targetLanguage,
      });

      if (workers.length === 0) {
        // No specialist available — try generalist
        const generalists = await tools.workerRegistry.getAvailable({ capability: "general-translation" });
        if (generalists.length === 0) {
          await tools.taskQueue.requeueWithDelay(task, { delayMs: 5000 });
          continue;
        }
        workers.push(...generalists);
      }

      // Select worker with lowest load
      const selected = workers.sort((a, b) => a.currentLoad - b.currentLoad)[0];
      await selected.dispatch(task);
    }
  },
});

اہم ڈیزائن کے فیصلے:

• ورکر لوڈ کی رپورٹنگ درست اور کم تاخیر والی ہونی چاہیے۔ باسی لوڈ ڈیٹا غیر مساوی تقسیم کا باعث بنتا ہے۔
• فال بیک چین (ماہر → جنرلسٹ → تاخیر کے ساتھ قطار) صلاحیت کی کمی کے دوران کام کے نقصان کو روکتا ہے۔
• ورکرز اسٹارٹ اپ پر خود رجسٹر ہوتے ہیں اور شاندار بند ہونے پر رجسٹریشن ختم کرتے ہیں۔ ہیلتھ چیک پولنگ کریش ہونے والے کارکنوں کو خود بخود ہٹا دیتی ہے۔

---

کراس پیٹرن: تقسیم شدہ ٹریسنگ

اس سے قطع نظر کہ آپ کس آرکیسٹریشن پیٹرن کا استعمال کرتے ہیں، تقسیم شدہ ٹریسنگ پروڈکشن ملٹی ایجنٹ سسٹمز کے لیے غیر گفت و شنید ہے۔ ہر پیغام میں ایک correlationId اور ایک spanId ہوتا ہے۔ جب کوئی ایجنٹ چائلڈ ٹاسک بناتا ہے (سپروائزر پیٹرن میں) یا کام کو اگلے مرحلے تک پہنچاتا ہے (پائپ لائن پیٹرن میں)، یہ موجودہ مدت کے بچے کے طور پر ایک نیا اسپین بناتا ہے۔

// Middleware that injects tracing into all agent message handlers
agent.useHook("preRun", (ctx) => {
  ctx.span = tracer.startSpan(ctx.skill, { childOf: ctx.message.parentSpan });
  ctx.span.setTag("agent.id", ctx.agentId);
  ctx.span.setTag("correlation.id", ctx.message.correlationId);
});

agent.useHook("postRun", (ctx) => {
  ctx.span.finish();
});

تقسیم شدہ ٹریسنگ کے ساتھ، آپ ایجنٹ کی تمام حدود میں کسی بھی کام کے لیے مکمل عمل درآمد کے درخت کا تصور کر سکتے ہیں — تاخیر کے مسائل اور غیر متوقع رویے کو ڈیبگ کرنے کے لیے انمول۔

---

اینٹی پیٹرن سے بچنے کے لیے

مشترکہ تغیر پذیر حالت: متعدد ایجنٹوں کا ایک ہی ڈیٹا سٹور ریکارڈ پر بغیر کوآرڈینیشن کے لکھنا اپ ڈیٹس اور دوڑ کے حالات کا باعث بنتا ہے۔ کوآرڈینیشن کے لیے میسج بس کا استعمال کریں؛ ایجنٹ اپنی ریاست کے مالک ہیں۔

تین ایجنٹوں سے زیادہ لمبی ہم وقت ساز زنجیریں: اگر ایجنٹ A کال کرتا ہے B کو جو C کو کال کرتا ہے جو D کو ہم آہنگی سے کال کرتا ہے، تو لیٹنسی کمپاؤنڈز اور ناکامی کے دھماکے کا رداس بڑا ہوتا ہے۔ چیک پوائنٹنگ کے ساتھ غیر مطابقت پذیر پائپ لائن کے مراحل میں لمبی ہم وقت ساز زنجیروں کو توڑ دیں۔

ڈومین لاجک کے ساتھ سپروائزر ایجنٹ: سپروائزرز کو آرکیسٹریٹ کرنا چاہیے، ڈومین کے کام کو انجام نہیں دینا چاہیے۔ جب ایک سپروائزر نکالنے کی منطق یا توثیق کے اصولوں پر مشتمل ہونا شروع کر دیتا ہے، تو یہ بھیس میں ایک یک سنگی بن جاتا ہے۔

ایجنٹوں کے درمیان مضمر معاہدے: پیغام کے اسکیموں کو بس کی سطح پر ورژن اور تصدیق شدہ ہونا چاہیے۔ وہ ایجنٹ جو پیغام کے ڈھانچے کو درست کرنے کے بجائے اس کی تصدیق کرتے ہیں وہ خاموشی سے ناکام ہو جاتے ہیں جب بھیجنے والا اپنا آؤٹ پٹ فارمیٹ تبدیل کرتا ہے۔

---

اکثر پوچھے گئے سوالات

آپ سپروائزر ورکر سسٹم میں جزوی ناکامیوں کو کیسے ہینڈل کرتے ہیں جہاں کچھ کارکن کامیاب ہوتے ہیں اور کچھ ناکام ہوتے ہیں؟

سپروائزر کارکن کے تمام کاموں کے نتائج کامیابیوں اور ناکامیوں کے مرکب کے طور پر حاصل کرتا ہے۔ ترکیب کی مہارت فیصلہ کرتی ہے کہ مقصد کی بنیاد پر جزوی نتائج کو کیسے ہینڈل کیا جائے: کچھ اہداف کے لیے، جزوی نتائج مفید پیداوار پیدا کرنے کے لیے کافی ہوتے ہیں۔ دوسروں کے لیے، تمام نتائج درکار ہیں۔ کم از کم کامیابی کی حد کے ساتھ سپروائزر کو ترتیب دیں — اگر کارکنان کے اس تناسب سے کم کامیاب ہوتے ہیں، تو ممکنہ طور پر گمراہ کن جزوی پیداوار پیدا کرنے کے بجائے بڑھائیں۔

کیا ایک ہی ایجنٹ ایک ساتھ متعدد آرکیسٹریشن پیٹرن میں حصہ لے سکتا ہے؟

جی ہاں ایک ایجنٹ صرف ایک خدمت ہے — یہ ایک سپروائزر-ورکر سسٹم میں ایک کارکن ہو سکتا ہے جبکہ پائپ لائن میں ایک اسٹیج ہونے کے ساتھ ساتھ اتفاق رائے کی جانچ میں بطور ایویلیویٹر حصہ لے سکتا ہے۔ ہر درخواست آزاد ہے۔ اہم ضرورت یہ ہے کہ ایجنٹ درخواستوں کے درمیان بے وطن ہیں (ریاست بھرا ڈیٹا میموری اسٹورز میں جاتا ہے، ایجنٹ مثال کے متغیرات میں نہیں) لہذا متعدد ہم آہنگی کی درخواستیں مداخلت نہیں کرتی ہیں۔

ہائی تھرو پٹ سسٹمز کے لیے میسج بس کا اوور ہیڈ کیا ہے؟

ریڈیس اسٹریمز کے ساتھ میسج بس بیک اینڈ کے طور پر، پیغام کی اشاعت/سبسکرائب کی تاخیر عام طور پر 64KB سے کم کے پیغامات کے لیے 2ms سے کم ہوتی ہے۔ ہائی تھرو پٹ پائپ لائنز کے لیے جو فی منٹ ہزاروں دستاویزات پر کارروائی کرتی ہیں، یہ ہر مرحلے میں پروسیسنگ کے کام کے مقابلے میں نہ ہونے کے برابر ہے۔ انتہائی اعلی تھرو پٹ سسٹمز (فی دن لاکھوں پیغامات) کے لیے، کافکا اعلی آپریشنل پیچیدگی کی قیمت پر زیادہ پائیدار تھرو پٹ فراہم کرتا ہے۔

جب انفرادی ایجنٹ تیار ہوتے ہیں تو آپ ملٹی ایجنٹ سسٹم کا ورژن کیسے بناتے ہیں؟

ورژن ایجنٹ آزادانہ طور پر اپنے مینی فیسٹ میں سیمنٹک ورژننگ کا استعمال کرتے ہیں۔ میسج بس پیغامات کو ان کے اعلان کردہ اسکیما ورژن کے خلاف توثیق کرتی ہے۔ جب کوئی ایجنٹ اپنا آؤٹ پٹ سکیما (بریکنگ چینج) تبدیل کرتا ہے، تو یہ بڑے ورژن کو ٹکر دیتا ہے اور بس پرانے سکیما کے پیغامات کو پچھلے ورژن تک لے جاتا ہے۔ دونوں ورژن ہجرت ونڈو کے دوران ایک ساتھ چلتے ہیں۔ سپروائزر یا پائپ لائن کنفیگریشن بتاتی ہے کہ ہر ورکر کا کون سا ورژن درکار ہے، جو آپ کو رول آؤٹ ٹائمنگ کا مکمل کنٹرول فراہم کرتا ہے۔

جب کاموں پر انحصار ہوتا ہے تو Market-Maker پیٹرن ٹاسک آرڈرنگ کو کیسے ہینڈل کرتا ہے؟

مارکیٹ میکر آزادانہ کاموں کے لیے موزوں ہے — ایسے کام جو کسی بھی ترتیب سے انجام دے سکتے ہیں۔ انحصار والے کاموں کے لیے، اس کے بجائے پائپ لائن یا سپروائزر پیٹرن کا استعمال کریں، جو واضح طور پر آرڈر کو نافذ کرتا ہے۔ اگر آپ کے پاس آزاد اور منحصر کاموں کا مرکب ہے تو، سپروائزر کا نمونہ اچھی طرح سے کام کرتا ہے: سپروائزر آزاد کاموں کو Market-Maker پول میں بھیجتا ہے اور باقی کاموں کے لیے انحصار کا انتظام کرتا ہے۔

---

اگلے اقدامات

ملٹی ایجنٹ آرکیسٹریشن آٹومیشن کی پیچیدگی کو غیر مقفل کرتا ہے جسے واحد ایجنٹ ہینڈل نہیں کرسکتے ہیں۔ اس گائیڈ میں پیٹرن — سپروائزر- ورکر، پائپ لائن، اتفاق رائے، اور مارکیٹ میکر — انٹرپرائز آٹومیشن کے استعمال کے کیسز کی اکثریت کا احاطہ کرتے ہیں۔ کلیدی مسئلہ کے مواصلاتی ڈھانچے کے لئے صحیح پیٹرن کا انتخاب کرنا ہے، ہر مسئلے کو ایک فن تعمیر میں مجبور نہیں کرنا۔

ECOSIRE کی OpenClaw ملٹی ایجنٹ آرکیسٹریشن سروس پیچیدہ ملٹی ایجنٹ سسٹمز کے لیے آرکیٹیکچر ڈیزائن، نفاذ، اور جاری اصلاح فراہم کرتی ہے۔ ہماری ٹیم نے ماہانہ لاکھوں دستاویزات کو ہینڈل کرنے والے دستاویز پراسیسنگ سسٹمز، 24/7 چلنے والی مالیاتی تجزیہ پائپ لائنز، اور درجن بھر خصوصی ایجنٹوں کے ساتھ مربوط HR آٹومیشن سسٹمز کے لیے آرکیسٹریشن آرکیٹیکچرز ڈیزائن کیے ہیں۔

اپنے ملٹی ایجنٹ فن تعمیر کی ضروریات پر بات کرنے کے لیے ECOSIRE سے رابطہ کریں۔