Humilis动觉流处理器插件
humilis-kinesis-processor的Python项目详细描述
动觉事件流处理器
用于部署 Lambda函数 映射aKinesis中的事件 使用python可调用列表的事件流。
安装
pip install humilis-kinesis-processor
测试
单元测试
要运行本地测试套件:
make test
集成测试
在运行集成测试套件之前,您需要设置一些部署 使用命令的秘密:
s3keyring set [group]/[STAGE] [key] [secret]
在组humilis-kinesis-processor中,需要设置以下机密:
- sentry/dsn:是Sentry DSN。
默认情况下,集成测试将部署在名为DEVso的阶段上 设置哨兵DSN的命令是:
s3keyring set humilis-kinesis-processor:DEV sentry.dsn [SENTRYDSN]
要运行集成测试套件:
make testi
上面的命令将部署一个kinisis处理器到您的aws帐户,并将 同时创建额外的资源(例如几个动觉流)来 测试部署是否成功。一旦部署,集成测试 将运行,一旦它们完成测试环境将被破坏。
如果您不希望在测试完成后破坏测试环境 已完成,应改为运行:
make testi DESTROY=no
您还可以通过设置^{tt4}来修改部署阶段的名称。$ 环境变量。例如,要部署到TESTstage:
make testi STAGE=TEST
更多信息
请参阅humilis文档。
接触
如果您有问题、错误报告、建议等,请在 这是GitHub project page。
更改日志
0.9.7
- 支持lambda环境变量
0.9.6
- 如果kinisis负载不是json对象,请不要使异常静音
0.9.5
- 支持传送流筛选器和映射程序
0.9.0
- 更好地调试处理错误
0.8.9
- 向无法处理的事件添加错误注释
0.8.6
- 错误处理逻辑中的错误修复。
0.8.5
- 更好的错误处理。
0.7.7
- 支持输入、错误和输出的多个传送流
0.7.6
- 支持一对多映射程序
0.7.5
- 用户还可以按名称指定输入/输出/错误流,而不是 对另一层输出的引用。
0.6.8
- 为腐殖环境/层/阶段设置环境变量
0.4.0
- 主要错误修复:允许将记录放入传送流中
0.3.0
- 主要错误修复:授予dynamoddb写入状态的权限
0.2.0
- 软件包成为通用的地图复用地图处理器(Germangh)
0.1.1
- 清除包数据(bubenkoff)
0.1.0
- 简化和清理代码的主要重构(germangh)
0.0.1
- <里>初始版本(bubenkoff)