How to configure and run celerybeat

python celery celerybeat
user1289853 picture user1289853 · Aug 3, 2012 · Viewed 9.9k times · Source

I am just getting started with celery,trying to run a periodic task.

Configured *rabbitmq** added celeryconfig.py.

And added following code in tasks.py:

from celery.decorators import periodic_task
from datetime import timedelta

@periodic_task(run_every=timedelta(seconds=2))
def every_2_seconds():
    print("Running periodic task!")

Now when I start celerybeat by typing "celerybeat" in my terminal it starts to run with follwing message

celerybeat 
celerybeat v3.0.3 (Chiastic Slide) is starting.
__    -    ... __   -        _
Configuration ->
    . broker -> amqp://arnold@localhost:5672//
    . loader -> celery.loaders.default.Loader
    . scheduler -> celery.beat.PersistentScheduler
    . db -> celerybeat-schedule
    . logfile -> [stderr]@INFO
    . maxinterval -> now (0s)
[2012-08-03 14:24:52,202: INFO/MainProcess] Celerybeat: Starting...

And there is no output of every_2_seconds method in the terminal.I am assuming I have to specify which app to run or wich tasks during the celerybeat command.How to do that?

How can I specify tasks and print the line after every 2 seconds as a periodic tasks?

Thanks.

Answer

mushfiq picture mushfiq · Aug 3, 2012

Add CELERY_IMPORTS=("tasks",) to your celeryconfig.py then run celerybeat.

Related questions

How to dynamically add / remove periodic tasks to Celery (celerybeat)

If I have a function defined as follows: def add(x,y): return x+y Is there a way to dynamically add this function as a celery PeriodicTask and kick it off at runtime? I'd like to be able to …

Read More
Setting up periodic tasks in Celery (celerybeat) dynamically using add_periodic_task

I'm using Celery 4.0.1 with Django 1.10 and I have troubles scheduling tasks (running a task works fine). Here is the celery configuration: os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'myapp.settings') app = Celery('myapp') app.autodiscover_tasks(lambda: settings.INSTALLED_APPS) app.…

Read More
Celery beat not picking up periodic tasks

I am trying to get started with celery, but I can't get my task up and running. I have installed django-celery-beat and celery4. My settings file. Installed apps (with celery packages) ... 'django_celery_beat', 'django_celery_results' the celery configuration …

Read More