A simple way to fetch data from Kinesis streams
Add:
"vsmoraes/kinesis": "dev-master"
To your composer.json
or Run:
composer require vsmoraes/kinesis dev-master
<?php
include __DIR__ . '/vendor/autoload.php';
use Aws\Kinesis\KinesisClient;
use Vsmoraes\Kinesis\Checkpoint\Adapter\ResourceTagAdapter;
use Vsmoraes\Kinesis\Manager;
$kinesis = new KinesisClient([
'region' => 'us-east-1',
'version' => 'latest',
'profile' => 'default'
]);
$checkpoint = new ResourceTagAdapter($kinesis);
$manager = new Manager($kinesis, $checkpoint);
$records = [];
foreach ($manager->records('stream-name-here') as $record) {
$records[] = $record;
}
print_r($records);