Почему запуск celery worker показывает то, что кажется случайными операторами печати

Когда я запускаю celery worker, я получаю следующее. >>> bla bla <<<< заявления печати находятся в различных скриптах, не имеющих никакого отношения к celery или beat. После этого рабочий не показывает никакой активности, когда я сохраняю задание на страницах администрирования beat.

> celery -A mysite worker -l info --pool=solo -n worker3
XXXXXXXXXXXXXXXXX correlator views IndexView XXXXXXXXXXXXXXXXXXXXXXX

>>>>>>>>>>>>>>>>>>> Reviews.views.IndexView <<<<<<<<<<<<<<<<<<<<<<<<<<<<


>>>>>>>>>>>>>>>>>>> Reviews.views.DetailView <<<<<<<<<<<<<<<<<<<<<<<<<<<<

>> correlator/urls.py <<
XXXXXXXXXXXXXXXXX parameters/views.py  ParametersIndexView XXXXXXXXXXXXXXXXXXXXXXX  

QuestionsViewSet

correlator/urls.py
 
 -------------- celery@worker3 v5.1.2 (sun-harmonics)
--- ***** -----
-- ******* ---- Windows-10-10.0.19041-SP0 
2022-11-01 12:33:52
- *** --- * ---
- ** ---------- [config]
- ** ---------- .> app:         mysite:0x18cc6d60208
- ** ---------- .> transport:   amqp://guest:**@localhost:5672//
- ** ---------- .> results:
- *** --- * --- .> concurrency: 12 (solo) 
-- ******* ---- .> task events: OFF (enable -E to monitor tasks in this worker)     
--- ***** -----
 -------------- [queues]
                .> celery           exchange=celery(direct) key=celery


[tasks]
  . correlator.tasks.add
  . correlator.tasks.mul
  . iris.tasks.add
  . iris.tasks.mul
  . mysite.celery.debug_task
  . mysite.celery.hello_world
  . reviews.tasks.add
  . reviews.tasks.mul
  . reviews.tasks.rename_widget

[2022-11-01 12:33:52,901: INFO/MainProcess] Connected to amqp://guest:**@127.0.0.1:5672//
[2022-11-01 12:33:52,906: INFO/MainProcess] mingle: searching for neighbors
[2022-11-01 12:33:53,946: INFO/MainProcess] mingle: all alone
ings.DEBUG leads to a memorARNING/MainProcy                          thub\correlator
            leak, never useelery\fixups\dj this setting in productionsing settings.D environments!
  leak, never use this sett this setting iing in production environments!''')                   ing in producti

[2022-11-01 12:33:53,968: INFO/MainProcess] celery@worNFO/MainProcessker3 ready.

my settings.py

и мой celery.py

from __future__ import absolute_import, unicode_literals
import os
from celery import Celery
import requests
from django.utils import timezone
#from celery.contrib import rdb

# set the default Django settings module for the 'celery' program.
os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'mysite.settings')

app = Celery('mysite')

# Optional configuration, see the application user guide.
# app.conf.update(
#     result_expires=3600,
# )

# if __name__ == '__main__':
#     app.start()

# Using a string here means the worker doesn't have to serialize
# the configuration object to child processes.
# - namespace='CELERY' means all celery-related configuration keys
#   should have a `CELERY_` prefix.

app.config_from_object('django.conf:settings', namespace='CELERY')

# Load task modules from all registered Django app configs.
app.autodiscover_tasks()

@app.task(bind=True)
def debug_task(self):
    print('Request: {0!r}'.format(self.request))

@app.task(bind=True)
def hello_world(self):
    print('Hello world!')
    return('Hello world!')
    

Задача hello world сработала ровно два раза, и результаты можно увидеть в таблице Task Results на странице администратора.

Думаю, если я смогу понять, почему выполняются все эти операторы печати, я смогу добраться до сути дела.

Вернуться на верх