Elaborazione asincrona e IA in Shopware 6: attività pesanti in background

Elaborazione asincrona significa che un’attività non viene svolta nel momento della richiesta, ma passata a una coda e poi elaborata da un worker. Shopware 6 usa questo principio per indicizzazione, e-mail e importazioni, ed è la strada giusta per collegare servizi di IA.

Una richiesta al negozio dovrebbe ricevere risposta in pochi millisecondi. Altrimenti le attività più lunghe bloccano clienti e collaboratori: reindicizzare migliaia di prodotti, generare cento fatture, far scrivere un testo prodotto a un modello linguistico. L’elaborazione asincrona separa le due cose: la richiesta inserisce solo un messaggio nella coda e risponde subito; un processo in background svolge il lavoro vero e proprio, con nuovi tentativi in caso di errore e senza il limite di tempo del web server.

• Message queue: Shopware si basa su Symfony Messenger. Per impostazione predefinita i messaggi finiscono nel database (trasporto Doctrine), nelle installazioni più grandi in Redis, RabbitMQ o Amazon SQS.
• Worker: il comando bin/console messenger:consume async elabora i messaggi. In produzione resta sempre attivo, monitorato da Supervisor o systemd; l’admin worker nel browser è pensato solo per lo sviluppo.
• Scheduled task: attività pianificate (bin/console scheduled-task:run) che a loro volta inseriscono messaggi nella coda, ad esempio per sitemap, pulizia o esportazioni prodotto. Approfondimento nella voce Cronjob.
• Indexer: gli indici di prodotti, categorie e ricerca vengono aggiornati in modo asincrono dopo ogni modifica; vedi Indexer.
• Messaggi personalizzati: i plugin definiscono classi di messaggio e handler propri e passano così qualsiasi attività alla coda.

I servizi di IA come modelli linguistici o analisi delle immagini rispondono in secondi, non in millisecondi, e le loro API hanno limiti. Per questo non vanno mai nella richiesta, ma nella coda:

• Testi prodotto: quando si crea un prodotto viene accodato un messaggio „genera testo“; l’handler chiama il modello, controlla lunghezza e informazioni obbligatorie e salva descrizione e meta testi, eventualmente in uno stato di approvazione.
• Immagini: alt text, scontorni o categorizzazione vengono calcolati in background dopo il caricamento.
• Classificazione e arricchimento: i dati dei fornitori vengono assegnati dal modello a categorie, proprietà e tag prima di entrare nel catalogo.
• Servizio clienti: le richieste in arrivo vengono riassunte e prioritizzate, le risposte preparate come bozza.
• Traduzioni: i nuovi contenuti vengono pretradotti in altre lingue, ad esempio in italiano, e sottoposti a revisione.

Il negozio resta reattivo e le chiamate fallite (timeout, rate limit) vengono ripetute automaticamente dal Messenger. Quali strumenti sono adatti lo mostra la voce Piattaforma di integrazione IA.

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

// Handler
#[AsMessageHandler]
final class GenerateDescriptionHandler
{
public function __invoke(GenerateDescriptionMessage $message): void
{
// Caricare il prodotto, chiamare il servizio IA, salvare la descrizione
}
}

// Accodare, ad esempio in un event subscriber
$this->messageBus->dispatch(new GenerateDescriptionMessage($productId));

L’AsyncMessageInterface fa sì che Shopware instradi il messaggio tramite il trasporto asincrono.

• Monitorare i worker: se nessun consumer è attivo, e-mail, indici e attività IA restano in sospeso senza che il negozio mostri errori.
• Scegliere il trasporto: il database basta per i negozi piccoli; con volumi elevati Redis o RabbitMQ.
• Idempotenza: gli handler devono tollerare le ripetizioni; prima di scrivere, verificare se il lavoro è già stato fatto.
• Rendere visibili gli errori: il failure transport raccoglie i messaggi falliti definitivamente; controllarlo regolarmente e inviare notifiche.
• Costi e limiti: raggruppare le chiamate IA, memorizzare i risultati in cache, rispettare i rate limit con un ritardo.
• Protezione dei dati: inviare ai modelli esterni solo i dati necessari allo scopo e nessun dato personale dei clienti senza base giuridica, come richiede il GDPR anche in Italia.

Automazione dei job in background, Workflow basati su eventi, Integrazione GPT e Orchestrazione IA. Per realizzare handler personalizzati La supportiamo con lo sviluppo di plugin Shopware, anche per aziende in Italia. Tutte le voci nel Glossario Shopware.