Asynchrone Verarbeitung und KI in Shopware 6: Rechenintensive Aufgaben im Hintergrund

Asynchrone Verarbeitung heisst: Eine Aufgabe wird nicht im Moment der Anfrage erledigt, sondern an eine Warteschlange übergeben und später von einem Worker abgearbeitet. Shopware 6 nutzt dieses Prinzip für Indexierung, Mails und Importe, und es ist der richtige Weg, um KI-Dienste anzubinden.

Ein Shop-Request sollte in Millisekunden antworten. Aufgaben, die länger dauern, blockieren sonst Kunden und Mitarbeiter: tausende Produkte neu indexieren, hundert Rechnungen erzeugen, einen Produkttext von einem Sprachmodell schreiben lassen. Asynchrone Verarbeitung entkoppelt das: Der Request legt nur eine Nachricht in die Warteschlange und antwortet sofort; ein Hintergrundprozess erledigt die eigentliche Arbeit, mit Wiederholung bei Fehlern und ohne Zeitlimit des Webservers.

• Message Queue: Shopware baut auf dem Symfony Messenger auf. Nachrichten landen standardmässig in der Datenbank (Doctrine-Transport), in grösseren Installationen in Redis, RabbitMQ oder Amazon SQS.
• Worker: Der Befehl bin/console messenger:consume async verarbeitet die Nachrichten. Im Produktivbetrieb läuft er dauerhaft, überwacht durch Supervisor oder systemd; der Admin-Worker über den Browser ist nur für die Entwicklung gedacht.
• Scheduled Tasks: zeitgesteuerte Aufgaben (bin/console scheduled-task:run), die ihrerseits Nachrichten in die Queue stellen, etwa für Sitemap, Cleanup oder Produktexporte. Mehr dazu im Eintrag Cronjob.
• Indexer: Produkt-, Kategorie- und Suchindizes werden nach Änderungen asynchron aktualisiert; siehe Indexer.
• Eigene Nachrichten: Plugins definieren eigene Message-Klassen und Handler und übergeben damit beliebige Aufgaben an die Queue.

KI-Dienste wie Sprachmodelle oder Bildanalysen antworten in Sekunden, nicht in Millisekunden, und ihre APIs haben Limits. Sie gehören deshalb nie in den Request, sondern in die Warteschlange:

• Produkttexte: Beim Anlegen eines Produkts wird eine Nachricht „Text erzeugen“ eingereiht; der Handler ruft das Modell auf, prüft Länge und Pflichtangaben und schreibt Beschreibung und Meta-Texte zurück, optional in einen Freigabestatus.
• Bilder: Alt-Texte, Freisteller oder Kategorisierung werden nach dem Upload im Hintergrund berechnet.
• Klassifizierung und Anreicherung: Lieferantendaten werden per Modell Kategorien, Eigenschaften und Tags zugeordnet, bevor sie in den Katalog gelangen.
• Kundenservice: Eingehende Anfragen werden zusammengefasst und priorisiert, Antworten als Entwurf vorbereitet.
• Übersetzungen: Neue Inhalte werden für weitere Sprachen vorübersetzt, für Schweizer Shops etwa ins Französische und Italienische, und zur Prüfung vorgelegt.

Der Shop bleibt dabei reaktionsschnell, und fehlgeschlagene Aufrufe (Timeout, Rate-Limit) werden vom Messenger automatisch wiederholt. Welche Werkzeuge sich dafür eignen, zeigt der Eintrag KI-Integrationsplattform.

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

// Handler
#[AsMessageHandler]
final class GenerateDescriptionHandler
{
    public function __invoke(GenerateDescriptionMessage $message): void
    {
        // Produkt laden, KI-Dienst aufrufen, Beschreibung speichern
    }
}

// Einreihen, zum Beispiel in einem Event-Subscriber
$this->messageBus->dispatch(new GenerateDescriptionMessage($productId));

Das AsyncMessageInterface sorgt dafür, dass Shopware die Nachricht über den asynchronen Transport leitet.

• Worker überwachen: Läuft kein Consumer, bleiben Mails, Indizes und KI-Aufgaben liegen, ohne dass der Shop einen Fehler zeigt.
• Transport wählen: Die Datenbank reicht für kleine Shops; bei hohem Aufkommen Redis oder RabbitMQ.
• Idempotenz: Handler müssen Wiederholungen vertragen; vor dem Schreiben prüfen, ob die Arbeit schon erledigt ist.
• Fehler sichtbar machen: Der Failure-Transport sammelt endgültig gescheiterte Nachrichten; regelmässig prüfen und benachrichtigen.
• Kosten und Limits: KI-Aufrufe bündeln, Ergebnisse zwischenspeichern, Rate-Limits mit Verzögerung respektieren.
• Datenschutz: Nur die Daten an externe Modelle senden, die der Zweck erfordert, keine personenbezogenen Kundendaten ohne Rechtsgrundlage (in der Schweiz nach dem revDSG, bei Kunden in der EU zusätzlich nach der DSGVO).

Hintergrundjob-Automatisierung, Ereignisgesteuerte Workflows, GPT-Integration und KI-Orchestrierung. Für die Umsetzung eigener Handler unterstützen wir Händler in der Schweiz und in Deutschland mit Shopware-Plugin-Entwicklung. Alle Begriffe im Shopware-Wörterbuch.