Liigu sisu juurde

Veebikonksud

Queuety saab kindlate sündmuste korral saata välistele URL-idele HTTP POST-märguandeid. Kasutage veebikonksusid seirelahenduste, Slack või kohandatud juhtpaneelidega lõimimiseks.

Toetatud sündmused

Sündmus Käivitub siis, kui
job.completed Tavaline käsitleja töö või klass Contracts\Job lõpeb edukalt (ei käivitu töövoo etappide ega olekumasina toimingute puhul)
job.failed Katse viskab erindi ja ajastatakse korduskatse
job.buried Töö ammendab kõik korduskatsed
workflow.failed Töövoo etapp nurjub lõplikult

Veebikonksude registreerimine

PHP kaudu:

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

CLI kaudu:

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

Veebikonksude loetlemine

PHP
$webhooks = Queuety::webhook_notifier()->list();
Shell
wp queuety webhook list

Veebikonksude eemaldamine

PHP
Queuety::webhook_notifier()->remove( $webhook_id );
Shell
wp queuety webhook remove 3

Payload’i vorming

Sündmuse käivitumisel saadab Queuety HTTP POST-päringu koos JSON sisuga. Payload on alati järgmise kujuga:

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

Töövoo nurjumise korral:

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

Veebikonksu kohaletoimetamine toimub parimal võimalikul viisil. Töötaja saadab igale registreeritud URL-ile järjest päringu ühe sekundi pikkuse voo ajalimiidiga ja eirab kohaletoimetamise nurjumisi. Aeglane lõpp-punkt võib seega maksta töötajale iga URL kohta kuni umbes sekundi, kuid ei põhjusta kunagi töö nurjumist.

Kasutusjuhud

  • Slack hoiatused. Saate teavituse, kui tööd jäävad ootele või töövood ebaõnnestuvad.
  • PagerDuty integratsioon. Käivitage kriitiliste tööde ebaõnnestumisel intsidendid.
  • Kohandatud juhtpaneelid. Voogedastage sündmused oma seiretaristusse.
  • Auditijälg. Edastage sündmused välisesse logimisteenusesse.