Preskočiť na obsah

Trvalé oneskorenia

Zobraziť ako Markdown Upraviť na GitHub Dokumentácia na 2cc7b2b

Workflowy možno medzi krokmi pozastaviť na pevne stanovený čas pomocou metódy tvorby delay(). Kroky oneskorenia sú trvalé: oneskorenie sa uloží do databázy, takže pretrvá aj po reštarte pracovníkov, nasadení novej verzie a reštarte servera.

Metóda ->delay()

Pridajte krok oneskorenia kdekoľvek do reťazca workflowu:

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 ] );

Workflow bude:

  1. Spustí SendWelcomeEmailHandler
  2. Počká 1 deň
  3. Spustí SendFollowUpEmailHandler
  4. Počká 3 dni
  5. Spustí SendFinalEmailHandler

Parametre trvania

Metóda delay() prijíma ľubovoľnú kombináciu pomenovaných parametrov trvania:

Parameter Typ Opis
$seconds int Počet sekúnd čakania
$minutes int Počet minút čakania
$hours int Počet hodín čakania
$days int Počet dní čakania

Všetky hodnoty sa sčítajú. Tieto zápisy sú rovnocenné:

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

Môžete ich aj kombinovať:

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

Ako fungujú kroky oneskorenia

Keď workflow dosiahne krok oneskorenia, Queuety odošle internú úlohu __queuety_delay so stĺpcom available_at nastaveným na aktuálny čas plus trvanie oneskorenia. Úloha zostane v databáze a žiadny pracovník si ju neprevezme, kým oneskorenie neuplynie.

To znamená:

  • Bez opakovaného kontrolovania. Pracovníci oneskorenie opakovane nekontrolujú. Úloha sa jednoducho sprístupní, keď nastane určený čas.
  • Bez využitia pamäte. Počas čakania nič nebeží. Oneskorenie existuje iba ako riadok v databáze.
  • Pretrvá aj po reštarte. Ak sa pracovník reštartuje, úloha oneskorenia zostane vo fronte so správnou časovou pečiatkou available_at.

Keď sa úloha oneskorenia po uplynutí oneskorenia prevezme, workflow automaticky pokračuje ďalším krokom.

Príklad: odložené upozornenia

Odošlite pripomenutie hodinu po registrácii používateľa, ale iba vtedy, ak ešte nedokončil úvodné nastavenie:

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

Krok CheckOnboardingHandler môže skontrolovať stav a pomocou podmieneného vetvenia preskočiť pripomenutie, ak je úvodné nastavenie už dokončené.

Príklad: opakovanie s postupným oneskorením

Medzi kroky podobné opakovaniu vložte plánované oneskorenia:

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' ] );

Viaceré oneskorenia

Workflow môže obsahovať ľubovoľný počet krokov oneskorenia. Každé oneskorenie je nezávislé a v stave workflowu sa sleduje pomocou sekvenčného názvu (delay_0, delay_1 atď.).

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 );