AWS SQS broker for wiji. Wiji<https://github.com/komuw/wiji> is an asyncio distributed task processor/queue.
Project description
wijisqs
Codacy Badge CircleCI codecov Code style: black
wiji is an asyncio distributed task processor/queue.
wijisqs on the other hand, is an AWS SQS broker for wiji
Installation
pip install wijisqs
Usage
1. As a library
import os
import wiji
import wijisqs
import asyncio
class AdderTask(wiji.task.Task):
async def run(self, a, b):
result = a + b
print("\nresult: {0}\n".format(result))
return result
broker = wijisqs.SqsBroker(
aws_region_name="aws_region_name",
aws_access_key_id=os.environ.get("aws_access_key_id"),
aws_secret_access_key=os.environ.get("aws_secret_access_key"),
)
myAdderTask = AdderTask(the_broker=broker, queue_name="AdderTaskQueue1")
# queue some tasks
myAdderTask.synchronous_delay(a=4, b=37)
myAdderTask.synchronous_delay(a=67, b=847)
# run the workers
worker = wiji.Worker(the_task=myAdderTask)
asyncio.run(worker.consume_tasks())
For extended documentation, see the wiji documentation
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
wijisqs-0.3.0b1.tar.gz
(12.6 kB
view hashes)
Built Distribution
wijisqs-0.3.0b1-py3-none-any.whl
(10.9 kB
view hashes)
Close
Hashes for wijisqs-0.3.0b1-py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | dd3b00d2d2894630e12c216ee384aff5cd565541d88e923ab4db07969a25a3a4 |
|
MD5 | 7e765d399b5a39f81ee109ebdb248e55 |
|
BLAKE2b-256 | 02af48384a2d0e3502c59a3ee732cfb121b12cf6f745c9afde97eaea8542c816 |