pg-task-queue

Python asinc task system with postgres database


License
BSD-3-Clause
Install
pip install pg-task-queue==1.38

Documentation

Installation

$ [sudo] pip install pg-task-queue

Add task example

from pg_tasks_queue.TaskManager import TaskManager
task_manager = TaskManager()
database_dict = {'host': '127.0.0.1',
                 'port': '5432',
                 'dbname': 'task_queue',
                 'schema': 'public',
                 'user': '<user_login>',
                 'password': '<user_password>'}
if task_manager.init(database_dict):
    task_dict = {'module': '<module_name>',
                 'func': '<function_name>',
                 'priority': 1, 
                 'params': {'counter': 3}, 
                 'max_retry_count': 3}
    task_id = task_manager.add_task(task_dict)

Start worker example

from pg_tasks_queue.Worker import Worker
worker = Worker()
config_dict = {
    'database': {'host': '127.0.0.1',
                 'port': '5432',
                 'dbname': 'task_queue',
                 'schema': 'public',
                 'user': '<user_login>',
                 'password': '<user_password>'},
    'worker': {'timeout_sec': 30., 'sleep_sec': .5}
}
if worker.init(config_dict):
    worker.start()