amazon-kinesis-utils: a library of useful utilities for Amazon Kinesis
Project description
amazon-kinesis-utils
A library of useful utilities for Amazon Kinesis
Reference
See: https://amazon-kinesis-utils.readthedocs.io/en/latest/
Usage
# import submodule you want to use with from import
from amazon_kinesis_utils import kinesis
def lambda_handler(event, context):
raw_records = event['Records']
# kinesis.parse_records parses aggregated/non-aggregated records, with or without gzip compression
# it even unpacks CloudWatch Logs subscription filters messages
for payload in kinesis.parse_records(raw_records):
# kinesis.parse_records is a generator, so we only have one payload in memory on every iteration
print(f"Decoded payload: {payload}")
Contributing
Make sure to have following tools installed:
- pre-commit
- Sphinx for docs generation
macOS
$ brew install pre-commit
# set up pre-commit hooks by running below command in repository root
$ pre-commit install
# install sphinx
$ pip install sphinx sphinx_rtd_theme
Project details
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
Built Distribution
Close
Hashes for amazon_kinesis_utils-0.1.6.tar.gz
Algorithm | Hash digest | |
---|---|---|
SHA256 | 93138030bf168d2767d2d8450979656a8c7690f4bbcb0e54b82449e9919ee2ef |
|
MD5 | 410ecb02a3db4d5f9a605b2b5dc9526b |
|
BLAKE2b-256 | e16afd7410efd1aea845d609a7bd60a35f6d2e03f238ff56f0614535e3a81407 |
Close
Hashes for amazon_kinesis_utils-0.1.6-py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | 773a2f7ae640730d196cd2174189e4bd44b41250e521d4d1bec0203b98a73af3 |
|
MD5 | 702c5c1a07f15c5e6ff8b5ba5cf44d9d |
|
BLAKE2b-256 | 4047c9b4d80a681388f120e7f3ebfa371ac6ae9d2711fbf6fef427892c1ef902 |