À l'aide de Céleri sur les processus et les gevent dans les tâches en même temps

Je crois que la méthode recommandée pour démarrer la tâche est comme suit.

python manage.py celery worker -P gevent --loglevel=INFO

Gevent doit être corrigée dès que possible.

À partir de mon expérience étrange, le Céleri Battre ne peut pas fonctionner correctement avec les travailleurs avec gevent piscine (tâches planifiées sont bloqués et attendre une éternité), sauf si vous activez gevent monkey patching pour Battre processus.

Cependant, celery beat ne prend pas en charge --pool=gevent ou -P gevent option. La bonne façon d'injecter gevent monkey patching est d'utiliser un curstomized celery binaires, tels que:

#!/usr/bin/env python
# -*- coding: utf-8 -*-

from gevent import monkey
monkey.patch_all()

import re
import sys

from celery.__main__ import main

if __name__ == '__main__':
    sys.argv[0] = re.sub(r'(-script\.pyw|\.exe)?$', '', sys.argv[0])
    sys.exit(main())

De l'enregistrer comme celery-gevent, et exécuter Battre le service comme suit:

celery-gevent beat --app=proj.celery:app --loader=djcelery.loaders.DjangoLoader -f /var/log/celery/beat.log -l INFO --workdir=/my/proj --pidfile=/var/run/celery/beat.pid

Dans proj.celery vous devez également patch Django connexion pour éviter DatabaseError:

from __future__ import absolute_import

import os
# Set the Django settings module for the 'celery' program
os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'proj.settings')

import django
# Load Django model definitions, etc
django.setup()

from django.db import connection
# Allow thread sharing to ensure that Django database connection
# works properly with gevent.
connection.allow_thread_sharing = True

from django.conf import settings
from celery import Celery

app = Celery('proj')

# Using a string here means the worker will not have to
# pickle the object when using Windows.
app.config_from_object('django.conf:settings')
app.autodiscover_tasks(lambda: settings.INSTALLED_APPS)

(L'exemple ci-dessus fonctionne pour Python 2.7.10, Céleri 3.1.18, Django 1.8.2 et gevent 1.0.2)