0

我正在使用具有这种配置的芹菜

default_exchange = Exchange('default', type='direct')
latest_exchange = Exchange('latest', type='direct')

shared_celery_config = {
    'BROKER_URL': 'redis://localhost:6379/0',
    'CELERY_RESULT_BACKEND': 'redis://localhost:6379/0',
    'CELERY_DEFAULT_EXCHANGE': 'default',
    'CELERY_DEFAULT_ROUTING_KEY': 'default',
    'CELERY_DEFAULT_QUEUE': 'default',
    'CELERY_QUEUES': (
        Queue('default', default_exchange, routing_key='default'),
        Queue('latest', latest_exchange, routing_key='latest'),
    ),
}

celery = Celery('tasks', config_source=shared_celery_config)

但是当我创建一个任务时，没有一个工作人员正在使用它，也没有任何反应。我开始工人： celery worker -A tasks --loglevel=debug --hostname=worker1. 我可以从ps aux | grep celery输出中看到它们，但是当执行一些命令来获取统计信息时，就像celery -A tasks status我收到以下错误消息 一样Error: No nodes replied within time constraint.。因此，所有任务都处于PENDING状态。我相信这是一些错误配置，但无法弄清楚出了什么问题以及如何调试这样的事情。任何建议都会非常有帮助

4

1 回答 1

0

问题已解决。我有一个使用 gevent 的 Web 应用程序，并且在tasks模块中我从另一个具有monkey.patch_all(). 不知何故，它阻止了台球，因此阻止了工作人员启动池，这导致了这种后果。无论如何，不​​要使用 gevent，恕我直言。

于 2016-09-08T11:57:16.873 回答