A useful asynchronous library that is built on top of aiobotocore
python -m cowfish.sqsprocesser queue_name region_name
firehose = Firehose(name, worker_params={'maxsize': 1000})
async def go():
await firehose.put({'a': 3, 'b': 4})
...
await firehose.stop()use aioboto3 instead.