README.md

pikatasks

pikatasks is a minimalistic library that allows you to run remote tasks easily. There's also a Django integration.

Requirements

• pip install pika
• RabbitMQ as message broker

How-to

Import:

import pikatasks

Configure:

pikatasks.settings.BROKER_HOST = "localhost"
pikatasks.settings.BROKER_PORT = "5671"
pikatasks.settings.SSL_ENABLED = False
pikatasks.settings.VIRTUAL_HOST = "foo"
pikatasks.settings.USERNAME = "lancelot"
pikatasks.settings.PASSWORD = "swalloWcoc0nut"

Or in Django settings:

PIKATASKS_BROKER_HOST = "localhost"
PIKATASKS_BROKER_PORT = "5671"
PIKATASKS_SSL_ENABLED = False
PIKATASKS_VIRTUAL_HOST = "foo"
PIKATASKS_USERNAME = "lancelot"
PIKATASKS_PASSWORD = "swalloWcoc0nut"

Implement a task (server):

@pikatasks.task(name="hello")
def hello(something):
    msg = "Hello, " + something + "!"
    print(msg)
    return msg

Note: you will need a queue with exactly the same name as the task. See section: Queues and Permissions.

Start a server:

pikatasks.worker.start(tasks=[hello])

Run a task (client):

To simply run a task:

pikatasks.run("hello", something="World")

Run a task and get its reult: