Patvarios delsos

Peržiūrėti kaip Markdown Redaguoti per GitHub Dokumentacija: 2cc7b2b

Darbo eigas tarp žingsnių galima pristabdyti nustatytam laikui naudojant kūrimo grandinės metodą delay(). Delsos žingsniai yra patvarūs: delsa saugoma duomenų bazėje, todėl išlieka paleidus darbuotojus iš naujo, diegiant naują versiją ar perkraunant serverius.

Metodas `->delay()`

Pridėkite delsos žingsnį bet kurioje darbo eigos grandinės vietoje:

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

Darbo eiga:

Vykdomas SendWelcomeEmailHandler
Laukiama 1 dieną
Vykdomas SendFollowUpEmailHandler
Laukiama 3 dienas
Vykdomas SendFinalEmailHandler

Trukmės parametrai

Metodas delay() priima bet kokį vardinių trukmės parametrų derinį:

Parametras	Tipas	Aprašymas
`$seconds`	`int`	Laukimo sekundės
`$minutes`	`int`	Laukimo minutės
`$hours`	`int`	Laukimo valandos
`$days`	`int`	Laukimo dienos

Visos reikšmės sumuojamos. Šie variantai lygiaverčiai:

PHP

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

Galite juos derinti:

PHP

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

Kaip veikia delsos žingsniai

Darbo eigai pasiekus delsos žingsnį, Queuety paskirsto vidinę __queuety_delay užduotį, kurios stulpelio available_at reikšmė nustatoma į esamą laiką pridėjus delsos trukmę. Užduotis lieka duomenų bazėje ir nė vienas darbuotojas jos nepaima, kol nesibaigia delsa.

Tai reiškia:

Jokio apklausimo. Darbuotojai pakartotinai netikrina delsos. Atėjus laikui, užduotis tiesiog tampa prieinama.
Nenaudojama atmintis. Laukimo metu niekas nevykdoma. Delsa egzistuoja tik kaip duomenų bazės eilutė.
Išlieka paleidus iš naujo. Paleidus darbuotoją iš naujo, delsos užduotis lieka eilėje su teisinga laiko žyma available_at.

Pasibaigus delsai ir paėmus užduotį, darbo eiga automatiškai tęsiama nuo kito žingsnio.

Pavyzdys: atidėti pranešimai

Išsiųskite priminimą praėjus 1 valandai po naudotojo registracijos, bet tik jei jis dar neužbaigė įvadinių veiksmų:

PHP

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

Žingsnis CheckOnboardingHandler gali patikrinti būseną ir naudoti sąlyginį šakojimą, kad praleistų priminimą, jei įvadiniai veiksmai jau užbaigti.

Pavyzdys: pakartotinis bandymas su delsa

Tarp žingsnių, imituojančių pakartotinius bandymus, įterpkite numatytas delsas:

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

Kelios delsos

Darbo eigoje gali būti bet koks delsos žingsnių skaičius. Kiekviena delsa yra nepriklausoma ir darbo eigos būsenoje sekama nuosekliu pavadinimu (delay_0, delay_1 ir t. t.).

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