Как получить задания сельдерея из другого модуля - PullRequest
Новая
       7

Как получить задания сельдерея из другого модуля

0 голосов
/ 29 апреля 2018

Я могу успешно получать задания сельдерея из моего основного приложения - однако моя система не может получать задания из другого модуля. Я на удаленном сервере Ubuntu, используя супервизор для сельдерея.

draft1 - мое основное приложение, а post - еще один модуль (от которого я не могу получать задания).

draft1 / __ __ INIT. Ру 

#This will make sure the app is always imported when
#Django starts so that shared_task will use this app.
from .celery import app as celery_app

__all__ = ['celery_app']

draft1 / celery.py 

os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'draft1.settings')

app = Celery("draft1", broker=CELERY_BROKER_URL, include=['post'])
app.config_from_object('django.conf:settings', namespace='CELERY')
app.autodiscover_tasks(lambda: settings.INSTALLED_APPS) #post is in my installed apps

draft1 / tasks.py 

@periodic_task(run_every=timedelta(minutes=1))
def test_job():
    from polls.models import Question
    for i in Question.objects.all():
        if i.question_text == "test":
            i.question_text = "not_test"
            i.save()
    return HttpResponseRedirect('/')


@periodic_task(name='run_scheduled_jobs', run_every=timedelta(seconds=30))
def run_scheduled_jobs():
    return True

сообщение / tasks.py 

@periodic_task(name='test_post', run_every=timedelta(seconds=30))
def test_post():
    from .models import Post
    for i in Post.objects.all():
        if i.entered_category == "test":
            i.entered_category = "not_test"
            i.save()
    return HttpResponseRedirect('/')


@periodic_task(name='post_jobs', run_every=timedelta(seconds=30)) # task name found! celery will do its job
def post_jobs():
    # do whatever stuff you do
    return True

settings.py 

CELERYBEAT_SCHEDULE = {
    'run_scheduled_jobs': {
        'task': 'run_scheduled_jobs', # the same goes in the task name
        'schedule': timedelta(seconds=45),
    },
    'test_job': {
            'task': 'tasks.test_job',
            'schedule': timedelta(minutes=3),
    },
    'post_jobs': {
        'task': 'post.tasks.post_jobs',  #i've also tried tasks.post_jobs
        'schedule': timedelta(minutes=1),
    },
    'test_post': {
        'task': 'post.tasks.test_post',
        'schedule': timedelta(seconds=45),
    }
}

Вот моя команда для запуска рабочего: celery -A draft1 worker -l info

и ритм сельдерея запускается через: celery -A draft1 beat -l info --scheduler.

Задачи из draft1/tasks.py - единственные, которые я получаю:

enter image description here

Почему это?

1 Ответ

0 голосов
/ 29 апреля 2018

Переключатель celery -A, который вы передаете явно, создает работника только для приложения draft1. Вам потребуется отдельный работник для приложения post, а также настройка celery.py для него, чтобы вы могли создать отдельный экземпляр Celery для задач post. Очевидно, они могут совместно использовать одного и того же брокера сообщений (и вы, вероятно, делаете).

...