django-async-tasks 0.1.1

Django application. It's a simple system to process queue task in real time.

It’s a simple system to process queue task in real time.

Requirements

• python 2.7

• Django 1.6 through Django 1.9

• django-redis-cache

Install

1. Download it from PyPi with pip install django-async-tasks

2. Add “async_tasks” to your INSTALLED_APPS setting like this:

   INSTALLED_APPS = (
       ...
       'async_tasks',
   )

3. Configure settings

• Set setting name that defined for Redis in settings.CACHES. The default used ‘default’ setting name.

  ASYNC_TASKS_REDIS_SETTING_NAME = 'default'

• Setup log path and log filename. The default used for path os.path.join(BASE_DIR, 'logs') and filename 'async-tasks.log'.

  ASYNC_TASKS_LOG_PATH = os.path.join(BASE_DIR, 'logs') # Log path
  ASYNC_TASKS_LOG_FILENAME = 'async-tasks.log' # Log filename

4. Add cron job to execute every minute:

   python manage.py django_async_tasks

How to use?

1. Add task to execute delayed_task(your_function, **params), return identification code

2. Check is task ready ready_task(identification_code). Return statuses: 'PROCESS', 'SUCCESS', 'FAIL'

3. Get result result_task(identification_code)

Example

from async_tasks.utils import delay_task, ready_task, result_task

def test(a, b):
    return a + b

def test_delay_task():
    idn = delay_task(test, **{'a': 1, 'b': 2})
    status = None
    while status not in ['SUCCESS', 'FAIL']:
        status = ready_task(idn)

    if status == 'SUCCESS':
        print result_task(idn)
    else:
        print status


if __name__ == "__main__":
    test_delay_task()