Metadata-Version: 1.2
Name: kinsumer
Version: 0.5.0
Summary: High level Amazon Kinesis Streams consumer
Home-page: UNKNOWN
Author: Ungi Kim
Author-email: ungi@ungikim.me
License: UNKNOWN
Description-Content-Type: UNKNOWN
Description: kinsumer
        ========
        
        High level [Amazon Kinesis Streams](https://aws.amazon.com/kinesis/streams/) consumer.
        
        Some features
        -------------
        
        * Automatically detect shard count changes
        * Checkpoints/sequences persistence can be customized
        * Provided Checkpointer implementation for memory, and file
        * Memory bucket for temporary saving records
        
        Usage
        -----
        
        ```python
        from kinsumer import Consumer
        
        STREAM_REGION = 'ap-south-1'
        STREAM_NAME = 'my-stream'
        consumer = Consumer(__name__)
        consumer.config.from_object(__name__)
        
        @consumer.transform
        def transform(data, shard_id, last_sequence_number, last_arrival_timestamp):
            """do transform and return"""
            return data
        
        @consumer.after_consume
        def after(data, shard_id, last_sequence_number, last_arrival_timestamp):
            """after transform and do something"""
        
        if __name__ == '__main__':
            consumer.process()
        ```
        
        Author and license
        ------------------
        
        kinsumer is written by [Ungi Kim](https://ungikim.me/), maintained by [Balance Hero](http://truebalance.io/), and licensed under the MIT license.  You can find the source code from [Github](https://github.com/balancehero/kinsumer):
        
        ```
        $ git clone git@github.com:balancehero/kinsumer.git
        ```
        
        Missing features
        ----------------
        
        * Redis Checkpointer
        
        (Contributions would be appreciated!)
        
Platform: UNKNOWN
Classifier: Development Status :: 3 - Alpha
Classifier: Environment :: No Input/Output (Daemon)
Classifier: Intended Audience :: Developers
Classifier: Programming Language :: Python :: 3 :: Only
Classifier: Programming Language :: Python :: 3.6
Classifier: Topic :: Software Development :: Libraries :: Python Modules
Requires-Python: >=3.6.0
