Pysyvät viiveet

Näytä Markdown-muodossa Muokkaa palvelussa GitHub Dokumentaatio: 2cc7b2b

Työnkulku voi keskeytyä kiinteäksi ajaksi vaiheiden välillä delay()-rakentajametodilla. Viivevaiheet ovat pysyviä: viive tallennetaan tietokantaan, joten se säilyy työntekijöiden uudelleenkäynnistysten, käyttöönottojen ja palvelimen uudelleenkäynnistysten yli.

`->delay()`-metodi

Lisää viivevaihe mihin tahansa työnkulun ketjun kohtaan:

PHP

use Queuety\Queuety;

Queuety::workflow( 'drip_campaign' )
    ->then( SendWelcomeEmailHandler::class )
    ->delay( days: 1 )
    ->then( SendFollowUpEmailHandler::class )
    ->delay( days: 3 )
    ->then( SendFinalEmailHandler::class )
    ->dispatch( [ 'user_id' => 42 ] );

Työnkulku tekee seuraavaa:

Suorita SendWelcomeEmailHandler
Odota 1 päivä
Suorita SendFollowUpEmailHandler
Odota 3 päivää
Suorita SendFinalEmailHandler

Kestoparametrit

delay()-metodi hyväksyy minkä tahansa yhdistelmän nimettyjä kestoparametreja:

Parametri	Tyyppi	Kuvaus
`$seconds`	`int`	Odotettavat sekunnit
`$minutes`	`int`	Odotettavat minuutit
`$hours`	`int`	Odotettavat tunnit
`$days`	`int`	Odotettavat päivät

Kaikki arvot lasketaan yhteen. Nämä ovat keskenään samanarvoisia:

PHP

->delay( seconds: 3600 )
->delay( minutes: 60 )
->delay( hours: 1 )

Voit yhdistellä niitä:

PHP

->delay( hours: 1, minutes: 30 ) // 90 minutes total

Viivevaiheiden toiminta

Kun työnkulku saavuttaa viivevaiheen, Queuety lähettää sisäisen __queuety_delay-työn, jonka available_at-sarakkeen arvoksi asetetaan nykyinen aika lisättynä viiveen kestolla. Työ odottaa tietokannassa, eikä mikään työntekijä ota sitä käsittelyyn ennen viiveen päättymistä.

Tämä tarkoittaa seuraavaa:

Ei kyselyitä. Työntekijät eivät tarkista viivettä toistuvasti. Työ tulee saataville, kun sen aika koittaa.
Ei muistinkäyttöä. Odotuksen aikana ei suoriteta mitään. Viive on olemassa vain tietokantarivinä.
Säilyy uudelleenkäynnistyksissä. Jos työntekijä käynnistetään uudelleen, viivetyö on yhä jonossa oikealla available_at-aikaleimalla.

Kun viivetyö otetaan käsittelyyn viiveen jälkeen, työnkulku siirtyy automaattisesti seuraavaan vaiheeseen.

Esimerkki: viivästetyt ilmoitukset

Lähetä muistutus 1 tunti käyttäjän rekisteröitymisen jälkeen, mutta vain jos hän ei ole suorittanut perehdytystä loppuun:

PHP

Queuety::workflow( 'onboarding_reminder' )
    ->then( CreateAccountHandler::class )
    ->delay( hours: 1 )
    ->then( CheckOnboardingHandler::class )
    ->then( SendReminderHandler::class )
    ->dispatch( [ 'email' => 'user@example.com' ] );

CheckOnboardingHandler-vaihe voi tarkistaa tilan ja käyttää ehdollista haarautumista muistutuksen ohittamiseen, jos perehdytys on jo suoritettu.

Esimerkki: uudelleenyritys viiveellä

Lisää tarkoituksellisia viiveitä uudelleenyritysten kaltaisten vaiheiden väliin:

PHP

Queuety::workflow( 'poll_external_api' )
    ->then( CheckStatusHandler::class, 'check' )
    ->delay( minutes: 5 )
    ->then( CheckStatusHandler::class, 'recheck' )
    ->delay( minutes: 15 )
    ->then( CheckStatusHandler::class, 'final_check' )
    ->then( ProcessResultHandler::class )
    ->dispatch( [ 'external_id' => 'abc-123' ] );

Useita viiveitä

Työnkulussa voi olla kuinka monta viivevaihetta tahansa. Kukin viive on itsenäinen, ja sitä seurataan työnkulun tilassa järjestysnumerolla varustetulla nimellä (delay_0, delay_1 jne.).

PHP

Queuety::workflow( 'multi_step_drip' )
    ->then( StepA::class )
    ->delay( hours: 2 )
    ->then( StepB::class )
    ->delay( days: 1 )
    ->then( StepC::class )
    ->delay( minutes: 30 )
    ->then( StepD::class )
    ->dispatch( $payload );