Extensible consumer made for applications using Amazon's Kinesis Python Client Library (KCL).

You can use pip to install Cerone.

pip install git+https://github.com/bufferapp/cerone

If you prefer, you can clone it and run the setup.py file. Use the following commands to install Cerone from Github:

git clone https://github.com/bufferapp/cerone
cd cerone
python setup.py install

Cerone uses and communicates with the Kinesis Client Library MultiLangDaemon interface. You can found the installation instructions in the Amazon Kinesis Client Python repository. Alternatively, you can use our bufferapp/cerone-consumer Docker image as shown in the example folder.

Once you've defined the function you want to apply to the stream records, you can call Cerone's process_stream. The example main.py code shows a basic processing (saving stream data to a file) being applied to a stream.

Feel free to file an issue for any kind of feedback or bug!