No project description provided
Project description
Async SQS consumer
This is a simple asynchronous worker for consuming messages from AWS SQS
Usage
from async_sqs_consumer.worker import (
Worker,
)
worker = Worker(
queue_url="https://sqs.us-east-1.amazonaws.com/xxxxxxx/queue_name"
)
@worker.task("report")
async def report(text: str) -> None:
print(text)
worker.start()
Release history Release notifications | RSS feed
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
Built Distribution
Close
Hashes for async_sqs_consumer-0.1.1-py3-none-any.whl
| Algorithm | Hash digest | |
|---|---|---|
| SHA256 | c871dec7daa1208ae067d690592d9bdd643b04ccdf2d2edc7c0c1d6c2e6cbee1 |
|
| MD5 | c8297bf9c62e94b630975b13c664ac40 |
|
| BLAKE2b-256 | 02ac9007c6e07113d079e14b9d9d8149cc31e65ad369f1a7b8edd854d8ca6a7e |
