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.
################
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
Release history Release notifications | RSS feed
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)