Liigu sisu juurde
Vaata Markdownina Muuda teenuses GitHub Dokumentatsioon: 2cc7b2b

Ühefaililised töövood

Töövoog võib olla täielikult ühes PHP-failis. Määra samuklassid ja koostaja koos, aseta fail kataloogi ning laadi see kataloog allpool näidatud Queuety::load_workflows() abil. Queuety ei skaneeri ühtegi kataloogi iseseisvalt.

PHP
// workflows/onboard-user.php
use Queuety\Queuety;

class CreateAccount implements \Queuety\Step {
    public function handle(array $state): array {
        $user = create_user($state['email']);
        return ['user_id' => $user->id, 'user_name' => $user->name];
    }
    public function config(): array {
        return ['max_attempts' => 3];
    }
}

class SendWelcome implements \Queuety\Step {
    public function handle(array $state): array {
        wp_mail($state['email'], 'Welcome ' . $state['user_name'], '...');
        return ['welcomed' => true];
    }
    public function config(): array {
        return [];
    }
}

return Queuety::define_workflow('onboard_user')
    ->then(CreateAccount::class, 'create_account')
    ->then(SendWelcome::class, 'send_welcome');

Fail tagastab WorkflowBuilder. Iga samuklass määratletakse tekstis. Faili laadimisel muutuvad klassid kättesaadavaks ja töövoog registreeritakse mallina.

Töövoogude laadimine

Laadi kataloogist kõik töövoofailid:

PHP
// Load all .php files from the workflows directory
$count = Queuety::load_workflows(__DIR__ . '/workflows/');

Või laadi üks fail:

PHP
$template = Queuety::load_workflow_file(__DIR__ . '/workflows/onboard-user.php');

Seejärel käivita nime järgi:

PHP
$workflow_id = Queuety::run_workflow('onboard_user', ['email' => 'user@example.com']);

Rekursiivne laadimine

Anna true teise argumendina, et skaneerida alamkatalooge:

PHP
Queuety::load_workflows(__DIR__ . '/workflows/', recursive: true);

Nii saad töövood kaustadesse korraldada:

Kood
workflows/
├── onboarding/
│   ├── new-user.php
│   └── trial-upgrade.php
├── reports/
│   ├── daily-summary.php
│   └── weekly-digest.php
└── notifications/
    └── digest-email.php

Kõigi töövoofunktsioonide kasutamine

Failipõhised töövood toetavad kõike, mida koostaja, välja arvatud idempotency_key(), mida mallis ei salvestata; anna see iga käivitamise jaoks eraldi argumendiga Queuety::run_workflow( $name, $payload, [ 'idempotency_key' => '...' ] ). Viivitused, signaalid, paralleelsed sammud, tingimuslik hargnemine, töövoogude käivitamine, tühistamiskäsitlejad ja oleku kärpimine toimivad kõik:

PHP
// workflows/approval-flow.php
use Queuety\Queuety;

class SubmitRequest implements \Queuety\Step {
    public function handle(array $state): array {
        return ['submitted_at' => date('Y-m-d H:i:s')];
    }
    public function config(): array { return []; }
}

class ProcessApproval implements \Queuety\Step {
    public function handle(array $state): array {
        return [
            'approved_by' => $state['approved_by'],
            'processed' => true,
        ];
    }
    public function config(): array { return []; }
}

class CleanupRequest implements \Queuety\Handler {
    public function handle(array $payload): void {
        delete_pending_request($payload['request_id']);
    }
    public function config(): array { return []; }
}

return Queuety::define_workflow('approval_flow')
    ->then(SubmitRequest::class)
    ->delay(hours: 24)
    ->wait_for_signal('approved')
    ->then(ProcessApproval::class)
    ->on_cancel(CleanupRequest::class)
    ->prune_state_after(2);

Millal kasutada failipõhiseid töövooge

Failipõhised töövood sobivad ideaalselt, kui:

  • LLM või koodigeneraator loob töövooge programmiliselt
  • Töövoog on piisavalt lihtne, et mahtuda ühte faili
  • Soovid hoida sammuloogika töövoo määratluse lähedal
  • Katsetad prototüüpi ja soovid kiiret arendust

Suuremate töövoogude puhul, kus on jagatud samuklassid, keerukas vahevara või mitmes töövoos korduvkasutatavad sammud, on eraldi klassifailide ja PSR-4 automaatse laadimise tavapärane lähenemine hõlpsamini hooldatav.

Kuidas see töötab

Kapoti all kasutavad failitöövood täpselt sama mootorit mis koostaja API. Iga samm on andmebaasis eraldi töö. Olek liigub tabeli queuety_workflows kaudu. Taasesitust ega determinismikohustust pole ning jõudluses erinevust ei ole.

Iga laadimiskutse requireib faili (mitte require_once), seega laadige iga fail päringu kohta üks kord; teistkordsel laadimisel deklareeritakse selle klassid uuesti ja see ebaõnnestub. Tagastatud WorkflowBuilder teisendatakse WorkflowTemplate-ks ja salvestatakse WorkflowRegistry-sse. Käivitamine ja täitmine toimuvad samamoodi nagu mis tahes muu töövoo puhul.