Primii pași

Instalare

Cerințe

• PHP 8.2 sau mai recent și WordPress 6.4 sau mai recent
• MySQL 8.0+ sau MariaDB 10.6+. Lucrătorii revendică joburi și programări scadente cu SELECT ... FOR UPDATE SKIP LOCKED, sintaxă pe care serverele mai vechi o resping cu o eroare.
• mysqli sau pdo_mysql (consultați mai jos)
• WP-CLI pe server dacă rulați lucrători dedicați cu wp queuety work
• Extensiile pcntl și posix PHP dacă rulați grupuri de lucrători cu --workers sau --min-workers/--max-workers

Queuety necesită fie mysqli, fie pdo_mysql în mediul de execuție PHP care încarcă WordPress și WP-CLI. Alege automat driverul, preferând mysqli pentru mediile de execuție WordPress și păstrând pdo_mysql disponibil pentru utilizarea autonomă/directă a mediului de execuție.

Dacă doriți mediul de execuție bazat pe DB fără stratul de pluginuri WordPress, consultați Utilizare autonomă. Această variantă folosește aceeași conexiune și aceleași tabele pentru mediul de execuție, însă nu include punțile hookurilor WordPress sau înregistrarea WP-CLI.

Din arhiva zip a versiunii

Fiecare versiune GitHub are un fișier queuety.zip: pluginul cu dependențele Composer deja instalate. Instalați ultima versiune cu WP-CLI:

wp plugin install https://github.com/inline0/queuety/releases/latest/download/queuety.zip --activate

Sau descărcați arhiva zip și încărcați-o din Plugins > Add New > Upload Plugin. Aceasta este cea mai simplă variantă pentru un site WordPress obișnuit.

Prin Composer pentru Composer gestionat de WordPress

composer require queuety/queuety

Apoi activați pluginul:

wp plugin activate queuety

Tipul pachetului este wordpress-plugin. Composer îl plasează în directorul de pluginuri doar când proiectul necesită composer/installers și mapează acel tip la o cale de instalare, așa cum face Bedrock, iar proiectul trebuie să-și încarce propriul vendor/autoload.php (și Bedrock face acest lucru). Fără composer/installers, Composer îl instalează în vendor/queuety/queuety, unde WordPress nu îl găsește, așa că folosiți arhiva zip a versiunii pe o instalare WordPress simplă.

Din sursă în timpul dezvoltării

Plasați depozitul în wp-content/plugins/queuety, apoi instalați dependențele PHP:

composer install
wp plugin activate queuety

La activare, Queuety își creează tabelele bazei de date (queuety_jobs, queuety_workflows, queuety_logs, queuety_schedules, queuety_queue_states, queuety_webhooks, queuety_locks, queuety_signals, queuety_workflow_dependencies, queuety_workflow_dispatch_keys, queuety_batches, queuety_chunks, queuety_workflow_events, queuety_artifacts, queuety_state_machines, queuety_state_machine_events), astfel încât lucrătorii să poată prelua sarcini direct din MySQL.

În mod implicit, pluginul programează și un lucrător cu o singură execuție prin WordPress cron în fiecare minut pentru coada default. Astfel aveți o soluție de bază fără shell pentru sarcini și fluxuri de lucru care rulează pe default, cu condiția ca WordPress cron să se declanșeze. Fiecare execuție procesează cel mult o sarcină și nu declanșează programări recurente, nu recuperează sarcini rămase blocate și nu verifică termenele fluxurilor de lucru; acestea rulează doar într-un proces wp queuety work de lungă durată (#14). Pentru cozi personalizate, programări recurente, latență mai mică sau volume de lucru mai mari, treceți la procese wp queuety work dedicate.

Configurare

Toate constantele sunt opționale. Definiți-le în wp-config.php înainte de încărcarea pluginului sau înainte ca Queuety să pornească într-o instalare încorporată în stilul unei teme:

Constantele pentru admiterea resurselor și pentru pool-ul adaptiv (QUEUETY_RESOURCE_*, QUEUETY_WORKER_POOL_*) sunt enumerate pe pagina Lucrători.

QUEUETY_TABLE_PREFIX modifică doar segmentul Queuety al numelor tabelelor. Prefixul bazei de date WordPress încapsulează în continuare rezultatul, astfel că $wpdb->prefix = 'wp_' și QUEUETY_TABLE_PREFIX = 'themequeue_' produc tabele precum wp_themequeue_jobs. Constantele explicite QUEUETY_TABLE_* au în continuare prioritate pentru tabele individuale.

Conexiunile independente pot seta și prefixul tabelului Queuety pentru fiecare conexiune:

$conn = new Connection(
    host: '127.0.0.1:3306',
    dbname: 'wordpress',
    user: 'root',
    password: 'secret',
    prefix: 'wp_',
    table_prefix: 'themequeue_',
);

Astfel, prefixul bazei de date WordPress rămâne intact, iar doar segmentul tabelului Queuety se modifică.

Prima sarcină

Creați o clasă de gestionare care implementează interfața Handler:

use Queuety\Handler;

class SendEmailHandler implements Handler {
    public function handle( array $payload ): void {
        wp_mail( $payload['to'], $payload['subject'], $payload['body'] );
    }

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

Înregistrați-o și lansați sarcina:

use Queuety\Queuety;

Queuety::register( 'send_email', SendEmailHandler::class );

Queuety::dispatch( 'send_email', [
    'to'      => 'user@example.com',
    'subject' => 'Welcome',
    'body'    => 'Hello from Queuety!',
] );

Sau folosiți clasa modernă de sarcină lansabilă:

use Queuety\Contracts\Job;
use Queuety\Dispatchable;

readonly class SendEmailJob implements Job {
    use Dispatchable;

    public function __construct(
        public string $to,
        public string $subject,
        public string $body,
    ) {}

    public function handle(): void {
        wp_mail( $this->to, $this->subject, $this->body );
    }
}

SendEmailJob::dispatch( 'user@example.com', 'Welcome', 'Hello from Queuety!' );

Primul flux de lucru

Definiți gestionare de pași care implementează interfața Step:

use Queuety\Step;

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

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

class CallLLMHandler implements Step {
    public function handle( array $state ): array {
        $response = wp_remote_post( 'https://api.openai.com/v1/chat/completions', [
            'body' => json_encode( [ 'prompt' => "Generate report for {$state['user_name']}" ] ),
        ] );
        return [ 'llm_response' => wp_remote_retrieve_body( $response ) ];
    }

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

class FormatOutputHandler implements Step {
    public function handle( array $state ): array {
        $url = save_report( $state['user_name'], $state['llm_response'] );
        return [ 'report_url' => $url ];
    }

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

Lansați fluxul de lucru:

$workflow_id = Queuety::workflow( 'generate_report' )
    ->then( FetchDataHandler::class )
    ->then( CallLLMHandler::class )
    ->then( FormatOutputHandler::class )
    ->dispatch( [ 'user_id' => 42 ] );

Porniți un lucrător

wp queuety work

Lucrătorul verifică dacă există sarcini în așteptare, le execută, avansează fluxurile de lucru și așteaptă când coada este goală. Apăsați Ctrl+C pentru a opri; procesul se încheie imediat, chiar și în mijlocul unei sarcini (consultați Lucrători).

SendEmailHandler de mai sus își trimite sarcinile în coada emails prin config(), astfel încât un lucrător de pe default nu le preia. Specificați fiecare coadă pe care o folosiți:

wp queuety work --queue=emails,default

Dacă nu rulați un lucrător dedicat, Queuety are în continuare soluția de rezervă implicită WordPress cron, descrisă mai sus, care rulează o dată pe minut și este limitată la coada default și la o singură sarcină per execuție. Lucrătorul dedicat oferă debit mai mare și latență mai mică.

Pentru producție, rulați mai mulți lucrători:

wp queuety work --workers=4

Procesați mai multe cozi cu ordonare după prioritate:

wp queuety work --queue=high,default,low

Ce urmează

• Sarcini pentru ghidul complet despre lansare și gestionare
• Fluxuri de lucru pentru lanțuri, pași paraleli, ramificare condiționată și lansarea fluxurilor de lucru
• Middleware pentru limitarea ratei, reducerea frecvenței și logica personalizată a pipeline-ului
• Procesare în loturi pentru lansarea grupurilor de sarcini cu funcții callback
• Pași cu transmitere în flux pentru salvarea datelor transmise în flux, segment cu segment
• Programare pentru sarcini recurente
• Memorare în cache pentru stratul de cache modular
• Testare pentru QueueFake și aserțiunile de testare
• CLI Referință pentru toate comenzile disponibile
• PHP API pentru acces programatic