موجه webhook يوزع إجراءات ping وprocess ويرد فورًا

كيف يعمل

1. 1.عقدة Webhook تستقبل POST على المسار template/scalable-orchestrator وتنتظر الرد من عقدة استجابة لاحقة
2. 2.عقدة Parse Input تقرأ action من body وتعين ping كقيمة افتراضية، وتعين payload مع كائن افتراضي {id:123, text:"hello"}
3. 3.عقدة Switch توجه إلى مخرج ping أو process حسب قيمة action مع تجاهل غير المتطابق
4. 4.مسار ping يبني {ok:true, message:"pong"} ويمرره مباشرة إلى عقدة الرد
5. 5.مسار process يرسل payload كـ JSON إلى https://httpbin.org/post بإعادة محاولة تلقائية حتى مرتين، ثم ينسّق النتيجة في {ok, data, source:"serviceA"}
6. 6.عقدة Respond to Webhook تعيد آخر كائن JSON إلى المستدعي

حالات الاستخدام

• بوابة API خفيفة تتحقق من التشغيل عبر إجراء ping قبل الإرسال الفعلي للبيانات
• نقطة دخول موحدة تستقبل طلبات وتعيد توجيه الحمولة إلى خدمة خارجية ثم تعيد نتيجتها للمستدعي
• قالب أساسي لتوسيع التوجيه بإجراءات إضافية عبر إضافة قواعد جديدة في عقدة Switch

المتطلبات قبل التشغيل

• تفعيل سير العمل في n8n حتى يعمل رابط الـ webhook الفعلي (الحالة الحالية غير مفعّل)
• لا تتطلب أي بيانات اعتماد بالإعداد الحالي لأن الخدمة الافتراضية httpbin.org عامة، ويجب إضافة بيانات الاعتماد المناسبة عند استبدالها بواجهة API خاصة
• وصول الشبكة من خادم n8n إلى الخدمة الخارجية المستهدفة
• إرسال الطلبات بصيغة JSON مع الحقل action في body لتفعيل التوجيه الصحيح

الإعداد والاختبار في n8n

1. فعّل سير العمل وأرسل curl -X POST إلى /webhook/template/scalable-orchestrator مع {"action":"ping"} وتحقق من رد pong
2. أرسل {"action":"process","payload":{"id":1,"text":"olá"}} وتحقق من عودة البيانات مع source:"serviceA"
3. أرسل action غير معروف مثل "test" وتوقع عدم وجود رد لأن المخرج الاحتياطي معطّل
4. استبدل رابط httpbin بعنوان قابل للاختبار وأعد الإرسال للتحقق من سلوك إعادة المحاولة عند فشل الخدمة

ماذا يقدّم كخدمة؟

مناسب كخدمة أتمتة تشغيلية لربط الأنظمة، تقليل المهام اليدوية، وتسريع تسليم النتائج للعملاء أو الفرق الداخلية.