Kinesis stream processing

To handle Kinesis events , extend the KinesisHandler class:


use Bref\Context\Context;
use Bref\Event\Kinesis\KinesisEvent;
use Bref\Event\Kinesis\KinesisHandler;
 
class Handler extends KinesisHandler
{
    public function handleKinesis(KinesisEvent $event, Context $context): void
    {
        foreach ($event->getRecords() as $record) {
            $data = $record->getData();
 
            // do something
        }
    }
}

Learn more about using Kinesis in serverless.yml in the Serverless Framework documentation .