CeleryBeat与RedBeatScheduler
有关如何在CeleryBeat上运行RedBeatScheduler的简短示例。 这将需要两个终端窗口才能运行:
$ celery worker -A cluster -l info -P eventlet
$ celery beat -A cluster -l info
然后在第三个窗口中:
$ python
>>> import cluster
>>> from redbeat import RedBeatSchedulerEntry as Entry
>>> e = Entry('thingo', 'cluster.add_task', 10, args=[15, 4], app=cluster.app)
>>> e.save()
>>> key = e.key()
您应该在celery worker终端中看到cluste
1