Asynchrone verwerking en AI in Shopware 6: rekenintensieve taken op de achtergrond

Asynchrone verwerking betekent: een taak wordt niet op het moment van de aanvraag uitgevoerd, maar aan een wachtrij overgedragen en later door een worker afgehandeld. Shopware 6 gebruikt dit principe voor indexering, e-mails en imports, en het is de juiste manier om AI-diensten te koppelen.

Een request in de webshop zou binnen milliseconden moeten antwoorden. Taken die langer duren, blokkeren anders klanten en medewerkers: duizenden producten opnieuw indexeren, honderd facturen genereren, een producttekst door een taalmodel laten schrijven. Asynchrone verwerking ontkoppelt dit: de request plaatst alleen een bericht in de wachtrij en antwoordt direct; een achtergrondproces doet het eigenlijke werk, met herhaling bij fouten en zonder tijdslimiet van de webserver.

• Message Queue: Shopware bouwt voort op de Symfony Messenger. Berichten komen standaard in de database terecht (Doctrine-transport), in grotere installaties in Redis, RabbitMQ of Amazon SQS.
• Worker: Het commando bin/console messenger:consume async verwerkt de berichten. In productie draait het permanent, bewaakt door Supervisor of systemd; de admin-worker via de browser is alleen bedoeld voor ontwikkeling.
• Scheduled Tasks: tijdgestuurde taken (bin/console scheduled-task:run) die op hun beurt berichten in de queue plaatsen, bijvoorbeeld voor de sitemap, cleanup of productexports. Meer hierover in het item Cronjob.
• Indexer: product-, categorie- en zoekindexen worden na wijzigingen asynchroon bijgewerkt; zie Indexer.
• Eigen berichten: plugins definiëren eigen message-klassen en handlers en dragen daarmee willekeurige taken over aan de queue.

AI-diensten zoals taalmodellen of beeldanalyses antwoorden in seconden, niet in milliseconden, en hun API’s hebben limieten. Ze horen daarom nooit in de request thuis, maar in de wachtrij:

• Productteksten: bij het aanmaken van een product wordt een bericht ‘Tekst genereren’ in de wachtrij geplaatst; de handler roept het model aan, controleert lengte en verplichte gegevens en schrijft beschrijving en metateksten terug, optioneel met een goedkeuringsstatus.
• Afbeeldingen: alt-teksten, vrijstaand maken of categorisering worden na de upload op de achtergrond berekend.
• Classificatie en verrijking: leveranciersgegevens krijgen via een model categorieën, eigenschappen en tags toegewezen voordat ze in de catalogus terechtkomen.
• Klantenservice: binnenkomende aanvragen worden samengevat en geprioriteerd, antwoorden worden als concept voorbereid.
• Vertalingen: nieuwe content wordt voor andere talen voorvertaald en ter controle voorgelegd.

De webshop blijft daarbij snel reageren en mislukte aanroepen (time-out, rate limit) worden door de Messenger automatisch herhaald. Welke tools daarvoor geschikt zijn, laat het item AI-integratieplatform zien.

// Bericht
final class GenerateDescriptionMessage implements AsyncMessageInterface
{
    public function __construct(public readonly string $productId) {}
}

// Handler
#[AsMessageHandler]
final class GenerateDescriptionHandler
{
    public function __invoke(GenerateDescriptionMessage $message): void
    {
        // Product laden, AI-dienst aanroepen, beschrijving opslaan
    }
}

// In de wachtrij plaatsen, bijvoorbeeld in een event-subscriber
$this->messageBus->dispatch(new GenerateDescriptionMessage($productId));

De AsyncMessageInterface zorgt ervoor dat Shopware het bericht via de asynchrone transport routeert.

• Worker bewaken: als er geen consumer draait, blijven e-mails, indexen en AI-taken liggen zonder dat de webshop een fout toont.
• Transport kiezen: de database volstaat voor kleine webshops; bij hoge volumes Redis of RabbitMQ.
• Idempotentie: handlers moeten herhalingen aankunnen; vóór het schrijven controleren of het werk al is gedaan.
• Fouten zichtbaar maken: de failure-transport verzamelt definitief mislukte berichten; regelmatig controleren en notificeren.
• Kosten en limieten: AI-aanroepen bundelen, resultaten cachen, rate limits met vertraging respecteren.
• Privacy: alleen de gegevens naar externe modellen sturen die het doel vereist, geen persoonsgegevens van klanten zonder rechtsgrondslag.

Achtergrondtaken-automatisering, Eventgestuurde workflows, GPT-integratie en AI-orchestratie. Voor de implementatie van eigen handlers ondersteunen wij u met Shopware-pluginontwikkeling. Alle begrippen in het Shopware woordenboek.