SQS Broker for TaskIQ
Project description
TaskIQ SQS Broker
Mostly generic SQS async broker for TaskIQ.
Expiration
If you set the sqs_expiry
label to a unix timestamp, the message will be discarded if the worker receives it after that time.
import asyncio
from taskiq_sqs import SQSBroker
broker = SQSBroker("http://sqs.us-east-1.localhost.localstack.cloud:4566/000000000000/my-queue")
@broker.task
async def add_one(value: int) -> int:
return value + 1
async def main() -> None:
# Never forget to call startup in the beginning.
await broker.startup()
# Send the task to the broker.
task = await add_one.kiq(1)
# Wait for the result. (result backend must be configured)
result = await task.wait_result(timeout=2)
print(f"Task execution took: {result.execution_time} seconds.")
if not result.is_err:
print(f"Returned value: {result.return_value}")
else:
print("Error found while executing task.")
await broker.shutdown()
if __name__ == "__main__":
asyncio.run(main())
Project details
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
taskiq_sqs-0.0.8.tar.gz
(16.7 kB
view hashes)
Built Distribution
taskiq_sqs-0.0.8-py3-none-any.whl
(12.7 kB
view hashes)
Close
Hashes for taskiq_sqs-0.0.8-py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | dd77a7c225a1b16f8accc4442ad95bb235ff0f14ad02afb4ea97f8bc2128ba86 |
|
MD5 | fb5a83289ff5f028ccee3fea9023cc32 |
|
BLAKE2b-256 | 47678ba697ba2c0d4a07eb1f88a72a2717ac0c9a9a50d5a4340aee069807b160 |