cowfish

A useful asynchronous library that is built on top of aiobotocore

Usage

python -m cowfish.sqsprocesser queue_name region_name

Examples

firehose = Firehose(name, worker_params={'maxsize': 1000})

async def go():
    await firehose.put({'a': 3, 'b': 4})
    ...
    await firehose.stop()

For dynamodb

use aioboto3 instead.