Python-сообщество

proj:
  __init__.py
  celery.py
  settigns.py
  tasks.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()

# 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")

# coding: utf-8
CELERYBEAT_SCHEDULE = {
    'add-every-30-seconds': {
        'task': 'tasks.test',
        'schedule': 5
    },
}
CELERY_TIMEZONE = 'UTC'

celery beat -A proj -l debug

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

celery inspect -A proj conf

CELERYBEAT_SCHEDULE