example is needed about redbeat

[zibuyu1995]

@qlygirl this is small and complete example :

config.py

#!/usr/bin/env python
# coding: utf-8

enable_utc = False
timezone = 'Asia/Shanghai'

broker_url = 'redis://:public@localhost:6379/15'

beat_scheduler = 'redbeat.RedBeatScheduler'

beat_max_loop_interval = 5

redbeat_redis_url = broker_url

redbeat_key_prefix = 'redbeat'
redbeat_schedule_key = redbeat_key_prefix + ':schedule'
redbeat_statics_key = redbeat_key_prefix + ':statics'
redbeat_lock_key = redbeat_key_prefix + ':lock'
redbeat_lock_timeout = beat_max_loop_interval * 5


beat_schedule = {
    'add-every-10-seconds': {
        'task': 'task.add_task',
        'schedule': 10.0,
        'args': (16, 16)
    },
    'add-every-5-seconds': {
        'task': 'task.test',
        'schedule': 5.0,
        'args': (16, 16)
    },
}

task.py

#!/usr/bin/env python
# coding: utf-8

import config

from celery import Celery
from datetime import datetime


app = Celery('test')
app.config_from_object(config)


@app.task
def add_task(a, b):
    print a + b
    return u'add task'


@app.task
def test():
    print datetime.now()
    return u'time test'

run

celery -A task worker -l debug
celery  beat -S redbeat.RedBeatScheduler -A task -l debug

[sibson]

If you have a working Celery Beat setup, RedBeat should be enabled by following the Getting Started section. I'd like to keep RedBeat docs focused on the differences between it and schedulers provided by Celery. If there is a way to include an small example that helps RedBeat users without digressing into too much Celery config, then I'd be happy to include it.

[mylovelycodes]

+1
hard to get start.

[qlygirl]

the example is helpful, thanks!