kinesisutils 0.0.6

安装

pip install kinesisutils

要安装开发版本：

pip install git+https://github.com/findhotel/kinesisutils

用法

目前只实现了一个实用程序：python生成器 从动觉流读取记录。您可以这样使用：

import json

from kinesisutils.kinesisutils import KinesisGenerator

# Hit Kinesis with at most 10 requests per second, usin json.loads to
# deserialize the Kinesis records (the default). You could deactivate record
# deserialization by setting des=None.
kg = KinesisGenerator("stream_name", rqs=10, des=json.loads)

for rec in kg:
    print(rec)

默认情况下，生成器将从kinisis中提取记录60 几秒钟。如果需要，可以自定义此超时：

from kinesisutils.kinesisutils import KinesisGenerator

kg = KinesisGenerator("stream_name", timeout=30)

for rec in kg:
    print(rec)

如果使用kinisis生成器读取cloudwatch日志事件 正在使用[日志]转发到动觉流的 subscription][logsubs]您需要解压缩cloudwatch 反序列化之前的记录：

import decompress
import json

kg = KinesisGenerator("stream_name", rqs=10, des=json.loads,
                      preprocess=gzip.decompress)

for rec in kg:
    print(rec)

联系人

如果您有问题、错误报告、建议等，请创建 关于GitHub project page的问题。减贫战略也 欢迎。

许可证

此软件是根据MIT license授权的。

见License file。

版权所有©2017德国戈麦斯·赫雷罗，Find Hotel等。