خطافات الويب

يمكن لـQueuety إرسال إشعارات POST عبر HTTP إلى عناوين URL خارجية عند وقوع أحداث محددة. استخدم خطافات الويب للتكامل مع أنظمة المراقبة أو Slack أو لوحات المعلومات المخصصة.

الأحداث المدعومة

تسجيل خطافات الويب

عبر PHP:

$id = Queuety::webhook_notifier()->register( 'job.buried', 'https://hooks.slack.com/services/...' );

عبر CLI:

wp queuety webhook add job.buried https://hooks.slack.com/services/...
wp queuety webhook add workflow.failed https://monitoring.example.com/queuety

سرد خطافات الويب

$webhooks = Queuety::webhook_notifier()->list();

wp queuety webhook list

إزالة خطافات الويب

Queuety::webhook_notifier()->remove( $webhook_id );

wp queuety webhook remove 3

تنسيق الحمولة

عند وقوع حدث، يرسل Queuety طلب POST من HTTP بجسم JSON. ويكون للحمولة دائمًا الشكل التالي:

{
    "event": "job.buried",
    "data": {
        "job_id": 42,
        "handler": "send_email",
        "queue": "emails",
        "error_message": "Connection timed out"
    },
    "timestamp": "2025-03-15T14:30:00Z"
}

عند فشل سير العمل:

{
    "event": "workflow.failed",
    "data": {
        "workflow_id": 7,
        "job_id": 42,
        "handler": "CallLlmStep",
        "error_message": "API rate limit exceeded"
    },
    "timestamp": "2025-03-15T14:30:00Z"
}

يُبذل أفضل جهد لتسليم خطاف الويب. يرسل العامل طلبًا إلى كل URL مسجل بالتتابع، مع مهلة تدفق قدرها ثانية واحدة، ويتجاهل إخفاقات التسليم. لذا قد تستهلك نقطة نهاية بطيئة ما يصل إلى ثانية تقريبًا من وقت العامل لكل URL، لكنها لا تؤدي أبدًا إلى فشل الوظيفة.

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

• تنبيهات Slack. تلقي إشعار عند عزل الوظائف أو فشل تدفقات العمل.
• تكامل PagerDuty. إطلاق حوادث عند الإخفاقات الحرجة للوظائف.
• لوحات معلومات مخصصة. بث الأحداث إلى بنية المراقبة الخاصة بك.
• سجل التدقيق. إعادة توجيه الأحداث إلى خدمة تسجيل خارجية.