Zaporedne verige

Prikaži kot Markdown Uredi na GitHub Dokumentacija za 2cc7b2b

Najpogostejši vzorec poteka dela je linearna veriga korakov. Vsak korak se izvede, ko se prejšnji konča, pri čemer se zbrano stanje posreduje naprej.

Metoda `->then()`

Za dodajanje zaporednih korakov poteku dela uporabite ->then():

PHP

use Queuety\Queuety;

Queuety::workflow( 'onboarding' )
    ->then( CreateAccountHandler::class )
    ->then( SendWelcomeEmailHandler::class )
    ->then( NotifyAdminHandler::class )
    ->dispatch( [ 'email' => 'user@example.com' ] );

Koraki se izvajajo v vrstnem redu, v katerem so dodani. Potek dela napreduje šele, ko se trenutni korak uspešno konča.

Vmesnik Step

Obravnavalniki korakov poteka dela implementirajo vmesnik Queuety\Step:

PHP

use Queuety\Step;

class CreateAccountHandler implements Step {
    public function handle( array $state ): array {
        $user_id = wp_create_user( $state['email'], wp_generate_password() );
        return [ 'user_id' => $user_id ];
    }

    public function config(): array {
        return [
            'max_attempts' => 3,
        ];
    }
}

Ključne razlike v primerjavi z vmesnikom Handler:

	`Handler` (opravila)	`Step` (poteki dela)
Podpis metode	`handle(array $payload): void`	`handle(array $state): array`
Vhod	Tovor opravila	Zbrano stanje poteka dela
Izhod	Nič (void)	Podatki za združitev s stanjem

Pretok stanja

Vsak korak prejme celotno zbrano stanje in vrne polje novih parov ključ-vrednost. Vrnjeni podatki se združijo s stanjem za naslednje korake:

PHP

class FetchUserHandler implements Step {
    public function handle( array $state ): array {
        // $state contains: ['user_id' => 42]
        $user = get_user_by( 'ID', $state['user_id'] );
        return [ 'user_name' => $user->display_name, 'user_email' => $user->user_email ];
    }

    public function config(): array {
        return [];
    }
}

class GenerateReportHandler implements Step {
    public function handle( array $state ): array {
        // $state contains: ['user_id' => 42, 'user_name' => 'Alice', 'user_email' => 'alice@example.com']
        $report = build_report( $state['user_name'] );
        return [ 'report_url' => $report->url ];
    }

    public function config(): array {
        return [];
    }
}

Konfiguracija korakov

Metoda config() podpira naslednje ključe:

Ključ	Vrsta	Privzeto	Opis
`max_attempts`	`int`	`3`	Največje število poskusov ponovitve za ta korak
`backoff`	`string`	`exponential`	Strategija čakanja pred ponovitvami

Primer cevovoda LLM

Pogost primer uporabe je povezovanje klicev LLM API z obdelavo podatkov:

PHP

use Queuety\Step;

class BuildPromptHandler implements Step {
    public function handle( array $state ): array {
        $user = get_user_by( 'ID', $state['user_id'] );
        $posts = get_posts( [ 'author' => $user->ID, 'numberposts' => 10 ] );
        $context = implode( "\n", array_map( fn( $p ) => $p->post_content, $posts ) );

        return [
            'prompt' => "Summarize this author's recent work:\n\n{$context}",
        ];
    }

    public function config(): array {
        return [];
    }
}

class CallOpenAIHandler implements Step {
    public function handle( array $state ): array {
        $response = wp_remote_post( 'https://api.openai.com/v1/chat/completions', [
            'timeout' => 120,
            'headers' => [
                'Authorization' => 'Bearer ' . OPENAI_API_KEY,
                'Content-Type'  => 'application/json',
            ],
            'body' => json_encode( [
                'model'    => 'gpt-4',
                'messages' => [ [ 'role' => 'user', 'content' => $state['prompt'] ] ],
            ] ),
        ] );

        $body = json_decode( wp_remote_retrieve_body( $response ), true );
        return [ 'summary' => $body['choices'][0]['message']['content'] ];
    }

    public function config(): array {
        return [ 'max_attempts' => 5 ];
    }
}

class SaveSummaryHandler implements Step {
    public function handle( array $state ): array {
        $post_id = wp_insert_post( [
            'post_title'   => "Summary for user #{$state['user_id']}",
            'post_content' => $state['summary'],
            'post_status'  => 'publish',
        ] );
        return [ 'summary_post_id' => $post_id ];
    }

    public function config(): array {
        return [];
    }
}

Sprožite cevovod:

PHP

Queuety::workflow( 'summarize_author' )
    ->then( BuildPromptHandler::class )
    ->then( CallOpenAIHandler::class )
    ->then( SaveSummaryHandler::class )
    ->on_queue( 'llm' )
    ->max_attempts( 5 )
    ->dispatch( [ 'user_id' => 42 ] );

Če klic OpenAI poteče, izvajalec ponovi samo ta korak. Poziv, sestavljen v koraku 0, je že varno shranjen v stanju poteka dela.