vsmoraes/kinesis

Kinesis 包装器，使其更容易与流一起工作

维护者

详细信息

github.com/vsmoraes/kinesis

源代码

问题

安装: 198

依赖项: 0

建议: 0

安全性: 0

星标: 2

关注者: 1

分支: 0

开放性问题: 0

dev-master 2016-12-23 16:46 UTC

Requires

Requires (Dev)

MIT 417540939f654e48a62e9515efeaa6ffde757681

  • Vinicius Moraes <vinicius.woop@archlinux.com.br>

This package is auto-updated.

Last update: 2024-08-29 04:19:56 UTC

README

从 Kinesis 流中获取数据的一种简单方法

Build Status Latest Stable Version Total Downloads Latest Unstable Version License

安装

添加

"vsmoraes/kinesis": "dev-master"

到您的 composer.json

或者运行

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);