Skip to main content

amazon-kinesis-utils: a library of useful utilities for Amazon Kinesis

Project description

amazon-kinesis-utils

A library of useful utilities for Amazon Kinesis

PyPi version t Code style: black Language grade: Python

CircleCI codecov Updates Documentation Status

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:

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.

Files for amazon-kinesis-utils, version 0.1.7
Filename, size File type Python version Upload date Hashes
Filename, size amazon_kinesis_utils-0.1.7-py3-none-any.whl (8.8 kB) File type Wheel Python version py3 Upload date Hashes View
Filename, size amazon_kinesis_utils-0.1.7.tar.gz (6.3 kB) File type Source Python version None Upload date Hashes View

Supported by

Pingdom Pingdom Monitoring Google Google Object Storage and Download Analytics Sentry Sentry Error logging AWS AWS Cloud computing DataDog DataDog Monitoring Fastly Fastly CDN DigiCert DigiCert EV certificate StatusPage StatusPage Status page