Сельдерей, выполняющий задание несколько раз - PullRequest
Новая
       64

Сельдерей, выполняющий задание несколько раз

0 голосов
/ 24 января 2019

У меня есть задание на сельдерей: 

@celery_app_site24x7.task(queue='site24x7')
    def createWebsiteMonitoring(**kwargs):
        """ Celery Task to create or update website Moniroting """

        time.sleep(100)
        site24x7Instance = Business_api.thirdpartyFactory.instantiate(
            "site24x7")
        # site24x7Instance.login()
        return site24x7Instance.createWebsiteMonitoring(**kwargs)

Проблема в том, что моя задача выполняется несколькими рабочими Fork POOL:

+++++++

[2019-01-23 05: 40: 59,674: INFO / ForkPoolWorker-3] Задача celery_tasks.site24x7.createWebsiteMonitoring [a6eeff3d-fa01-4f2e-9921-849435c9b902] преуспел в 128.61932249739766s: '279832000003876475'

[2019-01-23 05: 49: 32,565: INFO / ForkPoolWorker-2] Задача celery_tasks.site24x7.createWebsiteMonitoring [a6eeff3d-fa01-4f2e-9921-849435c9b902] преуспел в 127.42566008213907s: '279832000003877559'

+++++++

Следовательно, одна и та же задача выполняется несколько раз.

С другой стороны, у меня возникают некоторые ошибки в рабочих журналах следующим образом:

redis.exceptions.ConnectionError: Ошибка при чтении из сокета: ('Соединение закрыто сервером.',)

[2019-01-23 06: 58: 01,453: WARNING / MainProcess] Восстановление 15 неподтвержденное сообщение (я)

[2019-01-23 06: 58: 01,641: INFO / MainProcess] Подключено к Redis: //46.19.177.13: 6379/10

Некоторое время:

[2019-01-23 05: 58: 19,791: ПРЕДУПРЕЖДЕНИЕ / MainProcess] потребитель: подключение к Брокер проиграл. Попытка восстановить соединение ...

Есть ли проблема с моим кодом? Почему одна и та же задача выполняется дважды?

...