rockettm 0.0.2

Rocket task manager

Rocket task manager

Server task manager in python

Install

pip install rockettm

Link pypi: https://pypi.python.org/pypi/rockettm

Example

Send task

# send task
from rockettm import send_task

send_task("queue_name", "name_task", "arg1", ["arg2", "2"], {'args': 3}, ('arg', 4))

Declare new task

Warning! if there are 2 tasks registered with the same name, will run 2!

# task example
from rockettm import task


@task('name_task')
def function1(*args, **kwargs):
    return True

settings.py example

# settings.py example
ip = "localhost"
port = 5672
imports = ['examples.test1',
           'examples.test2']

queues = [{'name': 'rocket1', 'concurrency': 7},
          {'name': 'rocket2', 'concurrency': 1}]

Run server

rabbitmq_server file_settings.py

Documentation

Functions

• task(name_task_event) It is a decorator to create tasks

• send_task(queue, name_task, *args) Send task

• add_task(name_task, func(object)) Add manual task

CHANGELOG

0.0.2 (2016-03-14)

• Add documentation

0.0.1 (2016-03-14)

• initial version