Вообщем решал более трудную задачу, но обнаружил, что не запускается периодические задачи под celery. Создал тестовый проект и создал там единственную задачу. Структура проекта:
proj:
__init__.py
celery.py
settigns.py
tasks.py
celery.py:
# coding: utf-8
from __future__ import absolute_import
from celery import Celery
app = Celery("tasks", broker="amqp://guest:guest@localhost//")
if __name__ == "__main__":
app.config_from_object("proj.settings")
app.start()
tasks.py:
# coding: utf-8
from __future__ import absolute_import
from proj.celery import app
@app.task
def test():
with open("test.txt", "w+") as fd:
fd.write("Task `test` run")
settings.py:
# coding: utf-8
CELERYBEAT_SCHEDULE = {
'add-every-30-seconds': {
'task': 'tasks.test',
'schedule': 5
},
}
CELERY_TIMEZONE = 'UTC'
Запускаю celery вот так:
celery beat -A proj -l debug
. И к сожалению никакого файла не создаётся… Проект без django. Вообщем вопрос, почему не работает CELERYBEAT_SCHEDULE… Вот, что пишет в консоль при запуске:
celery beat v3.1.18 (Cipater) is starting.
__ - ... __ - _
Configuration ->
. broker -> amqp
/guest:**@localhost:5672//
. loader -> celery.loaders.app.AppLoader
. scheduler -> celery.beat.PersistentScheduler
. db -> celerybeat-schedule
. logfile -> [stderr]@%DEBUG
. maxinterval -> now (0s)
[2015-07-30 12:30:49,934: DEBUG/MainProcess] Setting default socket timeout to 30
[2015-07-30 12:30:49,934: INFO/MainProcess] beat: Starting...
[2015-07-30 12:30:49,946: DEBUG/MainProcess] Current schedule:
<Entry: celery.backend_cleanup celery.backend_cleanup() <crontab: 0 4 * * * (m/h/d/dM/MY)>
[2015-07-30 12:30:49,946: DEBUG/MainProcess] beat: Ticking with max interval->5.00 minutes
[2015-07-30 12:30:49,961: DEBUG/MainProcess] Start from server, version: 0.9, properties: {u'informaopyright (C) 2007-2013 GoPivotal, Inc.', u'capabilities': {u'exchange_exchange_bindings': True, u'co: True, u'consumer_cancel_notify': True, u'publisher_confirms': True}, u'platform': u'Erlang/OTP', u
[2015-07-30 12:30:49,963: DEBUG/MainProcess] Open OK!
[2015-07-30 12:30:49,964: DEBUG/MainProcess] beat: Waking up in 5.00 minutes.
[2015-07-30 12:35:50,026: DEBUG/MainProcess] beat: Waking up in 5.00 minutes