# Enviar eventos en grupo

Si vuestro sistema genera muchos eventos, es mejor enviar los eventos en grupo.

Para enviar eventos en grupo, en lugar de utilizar events()->ingest() cada vez que se produce un evento en vuestro sistema, utiliza algún mecanismo que recopile los eventos cuando se producen, y envíalos después en grupo cada poco tiempo o cuando hayas recopilado muchos, utilizando eventsBatchIngest()->ingest() . Mira cómo funciona:

// Obtén un objeto EventsBatchIngestService para poder reutilizarlo
$eventsBatchIngestService = $client->eventsBatchIngest();

// Inicia una sesión de ingestión de events
$eventsBatchIngestService->startIngestionSession();

// Recorre tus eventos pendientes por enviar en un bucle
while ($event = $query->getRow()) {

    // Crea un objeto EventPayload tal como hacías al cargar productos individualmente
    $eventPayload =
        new EventPayload([
            'type' => $event->getType(),
            'timestamp' => new DateTimeImmutable('@'.$event->getTimestamp()),
            'customerCode' => $event->getCustomerCode(),
            'productCode' => $event->getProductCode()
        ]);

    // Envía el evento para que sea cargado por bloques
    $eventsBatchIngestService->ingest($eventPayload);
}

// Cuando el bucle haya terminado, no olvides cerrar la sesión de ingestión
$batchIngestResult = $eventsBatchIngestService->finishIngestionSession();

Cuando envías los eventos en grupo, sí es imprescindible especificar timestamp, puesto que el momento en que envias el evento puede ser diferente al momento en que realmente se produjo.

Recuerda que cada tipo type de evento requiere parámetros adicionales diferentes, consulta la guía de eventos disponibles para saber qué parametros debes añadir a cada tipo de evento:

Una forma sencilla de enviar los eventos en grupo es crear un proceso que se ejecute regularmente cada N minutos, y que envíe todos los eventos que se hayan producido en los últimos N minutos en grupo, utilizando el método descrito arriba.

Algunas implementaciones más avanzadas guardan los eventos en una cola antes de enviarlos a Biteral, y realizan un envío en grupo de los eventos acumulados cuando la cola alcanza cierto tamaño. Esta cola de eventos puede implementarse de muchas formas, como una base de datos convencional tipo MySQL, un sistema en memoria como Redis o un bróker de mensajes como RabbitMQ.