Uses Azure storage queue/table for a simple worker
Project description
Base project for the paw package. Very much a work in progress.
To create tasks:
# tasks.py
from paw import task
@task(description='Stupid simple example')
def task_one(print_me):
print(print_me)
return True
To start a worker:
# start_workers.py
from paw import MainPawWorker
import tasks # importing tasks from tasks.py in local project
workers = MainPawWorker(
azure_storage_name='storage account name',
azure_storage_private_key='storage account private key',
azure_queue_name='name of the queue',
azure_table_name='name of the table',
tasks_module=tasks,
workers=4
)
if __name__ == '__main__':
workers.start_workers()
To queue a task:
# queue_tasks.py
from paw import queue_task
queue_task(
task_name='task_one',
account_name='storage account name',
account_key='storage account private key',
queue_name='name of the queue',
args=['List', 'of', 'arguments'],
kwargs={'Key_word': 'arguments'}
)
Project details
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
mamba-paw-0.2.2.tar.gz
(7.4 kB
view hashes)
Built Distribution
Close
Hashes for mamba_paw-0.2.2-py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | a29095b553d40f3fb6748bac0abd4af855da885bdf5a7433acd8ec6d04a40b1c |
|
MD5 | 21100fa57ae4c44b432887a66a526345 |
|
BLAKE2b-256 | 7bcebe3242b72760c38506dbe4183b96ba49632379f9b6a43033872e2769b9fe |