Celery multi不启动计划任务

2024-10-17 06:13:09 发布

您现在位置:Python中文网/ 问答频道 /正文

我的烧瓶里有点塞满了芹菜

我准备了这个时间表:

CELERYBEAT_SCHEDULE = {
  'scandir-every-day': {
      'task': 'app.core.scanAllPackages',
      'schedule': crontab(hour='*/24')
  },
  'scandir-custo-package':{
      'task': 'app.core.scanCustomPackages',
      'schedule': crontab(minute='*/10')
  }
}

像这样的芹菜路线:

^{pr2}$

我在app/\u init\uy.py中创建了芹菜对象,如下所示:

from extensions import make_celery
celery = make_celery(app)

制作芹菜的方法是这样的:

from celery import Celery
def make_celery(app):
    celery = Celery(app.import_name, broker=app.config['CELERY_BROKER_URL'])
    celery.conf.update(app.config)
    TaskBase = celery.Task
    class ContextTask(TaskBase):
        abstract = True
        def __call__(self, *args, **kwargs):
            with app.app_context():
                return TaskBase.__call__(self, *args, **kwargs)
    celery.Task = ContextTask
    return celery

一切似乎都很好,我让我的员工这样:

celery multi start fast slow -c:slow 1 -c:fast 2 -A app:celery -l debug --verbose

beat是这样启动的:

 celery beat -A app:celery --detach

Basicaly,没什么附件,工人们只是在等着

[2015-08-12 09:45:21,182: DEBUG/MainProcess] | Worker: Starting Hub
[2015-08-12 09:45:21,182: DEBUG/MainProcess] ^-- substep ok
[2015-08-12 09:45:21,182: DEBUG/MainProcess] | Worker: Starting Pool
[2015-08-12 09:45:21,186: DEBUG/MainProcess] ^-- substep ok
[2015-08-12 09:45:21,187: DEBUG/MainProcess] | Worker: Starting Consumer
[2015-08-12 09:45:21,187: DEBUG/MainProcess] | Consumer: Starting Connection
[2015-08-12 09:45:21,206: INFO/MainProcess] Connected to redis://localhost:6379/0
[2015-08-12 09:45:21,206: DEBUG/MainProcess] ^-- substep ok
[2015-08-12 09:45:21,207: DEBUG/MainProcess] | Consumer: Starting Events
[2015-08-12 09:45:21,213: DEBUG/MainProcess] ^-- substep ok
[2015-08-12 09:45:21,213: DEBUG/MainProcess] | Consumer: Starting Mingle
[2015-08-12 09:45:21,213: INFO/MainProcess] mingle: searching for neighbors
[2015-08-12 09:45:22,218: INFO/MainProcess] mingle: all alone
[2015-08-12 09:45:22,219: DEBUG/MainProcess] ^-- substep ok
[2015-08-12 09:45:22,219: DEBUG/MainProcess] | Consumer: Starting Gossip
[2015-08-12 09:45:22,222: DEBUG/MainProcess] ^-- substep ok
[2015-08-12 09:45:22,222: DEBUG/MainProcess] | Consumer: Starting Tasks
[2015-08-12 09:45:22,227: DEBUG/MainProcess] ^-- substep ok
[2015-08-12 09:45:22,227: DEBUG/MainProcess] | Consumer: Starting Control
[2015-08-12 09:45:22,229: DEBUG/MainProcess] ^-- substep ok
[2015-08-12 09:45:22,229: DEBUG/MainProcess] | Consumer: Starting Heart
[2015-08-12 09:45:22,230: DEBUG/MainProcess] ^-- substep ok
[2015-08-12 09:45:22,230: DEBUG/MainProcess] | Consumer: Starting event loop
[2015-08-12 09:45:22,230: WARNING/MainProcess] fast@host01 ready.
[2015-08-12 09:45:22,230: DEBUG/MainProcess] | Worker: Hub.register Pool...
[2015-08-12 09:45:22,231: DEBUG/MainProcess] basic.qos: prefetch_count->8
[2015-08-12 09:45:22,932: DEBUG/MainProcess] slow@host01 joined the party

如果有人知道我的节拍出了什么问题? 那太好了,
谢谢您。在


Tags: debugimportappmakeconsumerokcelery芹菜