amazon-kinesis-utils: a library of useful utilities for Amazon Kinesis
Project description
amazon-kinesis-utils
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
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.2.tar.gz
Algorithm | Hash digest | |
---|---|---|
SHA256 | 2d631c0d5c34bd32f72ae2dca97846a15a49c8828a39da441a77ba9514b71248 |
|
MD5 | d83d8ab9ad5dbedec96ee78728c53b69 |
|
BLAKE2b-256 | 8d6d5b17bdd65e19de8cb54f7642ce9f40d2cc1a52213a3d4f8a07c63a74d1b9 |
Close
Hashes for amazon_kinesis_utils-0.1.2-py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | 90ba8e9ac00ed7e518a2aceee3815f1b5ba49dde7651c223ce9d685d49980b54 |
|
MD5 | 4ea66c9a949d8aaddb7c6cf6e149d1b7 |
|
BLAKE2b-256 | b9b35109be3ebc6cf2f096ef9ddabd8d50d71797d4d13c23c49c2a98496d0b64 |