Celery rate_limit test script

tasks.py

"""
# Test celery's rate_limit

Tested version of python
$ python --version
Python 2.7.11

## Requirements
$ pip install celery==3.1.23
$ pip install SQLAlchemy==1.0.12

## Launch 5 celery workers
$ celery -A tasks worker -c 5 --loglevel=info
("-c" option specifies a number of celery worker)

## Add task
$ python
>>> import tasks
>>> for i in range(1, 10):
>>>     tasks.hey.delay(i)

... see celery worker log ...

## Stop worker
Ctrl-c
"""
from celery import Celery
from datetime import datetime

app = Celery('tasks', broker='sqla+sqlite:///celery.db')

@app.task(rate_limit='30/m')
def hey(i):
    return 'Hey! {0}'.format(i)