Skip to main content

A Celery Beat Scheduler that uses MongoDB to store both schedule definitions and status information

Project description

celerybeat-mongo
################

This is a Celery Beat Scheduler (http://celery.readthedocs.org/en/latest/userguide/periodic-tasks.html)
that stores both the schedules themselves and their status
information in a backend Mongo database. It can be installed by
installing the celerybeat-mongo Python egg::

# pip install celerybeat-mongo

And specifying the scheduler when running Celery Beat, e.g.::

$ celery beat -S celerybeatmongo.schedulers.MongoScheduler

Settings for the scheduler are defined in your celery configuration file
similar to how other aspects of Celery are configured::

Schedules can be manipulated in the Mongo database using the
mongoengine models in celerybeatmongo.models or through
direct database manipulation. There exist two types of schedules,
interval and crontab::

{
"_id" : ObjectId("533c5b29b45a2092bffceb13"),
"name" : "interval test schedule",
"task" : "task-name-goes-here",
"enabled" : true,
"interval" : {
"every" : 5,
"period" : "minutes"
},
"args": ["param1", "param2"]
"kwargs" : {
"max_targets" : 100
},
"total_run_count" : 5
"last_run_at" : ISODate("2014-04-03T02:19:22.666Z"),
}

{
"_id" : ObjectId("533c5b29b45a2092bffceb13"),
"name" : "crontab test schedule",
"task" : "task-name-goes-here",
"enabled" : true,
"crontab" : {
"minute": "30",
"hour": "2",
"day_of_week": "*",
"day_of_month": "*",
"day_of_year": "*",
},
"args": ["param1", "param2"]
"kwargs" : {
"max_targets" : 100
},
"total_run_count" : 5
"last_run_at" : ISODate("2014-04-03T02:19:22.666Z"),
}


The following fields are required: name, task, crontab || interval,
enabled when defining new tasks.
total_run_count and last_run_at are maintained by the
scheduler and should not be externally manipulated.

Project details


Download files

Download the file for your platform. If you're not sure which to choose, learn more about installing packages.

Source Distribution

celerybeat-mongo-0.0.0.tar.gz (3.6 kB view hashes)

Uploaded Source

Supported by

AWS AWS Cloud computing and Security Sponsor Datadog Datadog Monitoring Fastly Fastly CDN Google Google Download Analytics Microsoft Microsoft PSF Sponsor Pingdom Pingdom Monitoring Sentry Sentry Error logging StatusPage StatusPage Status page