Wallogit.com
2017 © Pedro Peláez
Kinesis wrapper to make it easy to work with streams
A simple way to fetch data from Kinesis streams, (*1)
, (*2)
Add:, (*3)
"vsmoraes/kinesis": "dev-master"
To your composer.json, (*4)
or Run:, (*5)
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);
Kinesis wrapper to make it easy to work with streams
MIT