#python #django #django-celery #django-celery-beat
#питон #джанго #django-сельдерей #django-celery-beat
Вопрос:
Я внедряю модуль напоминания в приложение, используя Django celery-beat, я создаю вкладку cron в периодических задачах и передаю словарь в параметр kwargs. Он успешно сохраняется в таблице периодических задач Django, но когда запланированная задача выполняется вовремя и вызывает указанную функцию, она не получает данные kwargs и через исключение.
settings.py
INSTALLED_APPS = [
'django_celery_beat',
]
# CELERY STUFF
CELERY_BROKER_URL = "redis://localhost:6379"
CELERY_RESULT_BACKEND = "redis://localhost:6379"
CELERY_BEAT_SCHEDULER = 'django_celery_beat.schedulers:DatabaseScheduler'
CELERY_ACCEPT_CONTENT = ['application/json']
CELERY_RESULT_SERIALIZER = 'json'
CELERY_TASK_SERIALIZER = 'json'
init.py
from .celery import app as celery_app
all = ("celery_app",)
celery.py
import os
from celery import Celery
os.environ.setdefault("DJANGO_SETTINGS_MODULE", "config.settings_local")
app = Celery("baseapp")
app.config_from_object("django.conf:settings", namespace="CELERY")
app.autodiscover_tasks()
Вот функция планировщика задач, которая создает периодические задачи:
def task_scheduler(raw_data):
try:
if raw_data["start"] and raw_data["reminder"]:
reminder_time = datetime.datetime.strptime(raw_data["start"], '%Y-%m-%dT%H:%M:%S.%fZ') - datetime.timedelta(minutes=raw_data["reminder"])
reminder, _ = CrontabSchedule.objects.get_or_create(
minute=reminder_time.minute,
hour=reminder_time.hour,
day_of_week="*",
day_of_month=reminder_time.day,
month_of_year=reminder_time.month,
)
PeriodicTask.objects.update_or_create(
name=raw_data["summary"],
task="reminder_notification",
crontab=reminder,
expire_seconds=7200,
kwargs=json.dumps({'test132':'123'}),
)
except Exception as error:
print(error)
Вот функция напоминания уведомления, которая вызывается, когда задача выполняется вовремя:
@shared_task(name="reminder_notification")
def reminder_notification(*args, **kwargs):
print("hello task")
Вот задачи в базе данных:
Вот ошибка:
[2021-01-07 06:13:00,021: ERROR/Beat] Message Error: Couldn't apply scheduled task celery15: reminder_notification() got an unexpected keyword argument 'test132'
[' File "/home/usman/Documents/venv/bin/celery", line 8, in <module>n sys.exit(main())n', ' File "/home/usman/Documents/venv/lib/python3.8/site-packages/celery/__main__.py", line 15, in mainn sys.exit(_main())n', ' File "/home/usman/Documents/venv/lib/python3.8/site-packages/celery/bin/celery.py", line 213, in mainn return celery(auto_envvar_prefix="CELERY")n', ' File "/home/usman/Documents/venv/lib/python3.8/site-packages/click/core.py", line 829, in __call__n return self.main(*args, **kwargs)n', ' File "/home/usman/Documents/venv/lib/python3.8/site-packages/click/core.py", line 782, in mainn rv = self.invoke(ctx)n', ' File "/home/usman/Documents/venv/lib/python3.8/site-packages/click/core.py", line 1259, in invoken return _process_result(sub_ctx.command.invoke(sub_ctx))n', ' File "/home/usman/Documents/venv/lib/python3.8/site-packages/click/core.py", line 1066, in invoken return ctx.invoke(self.callback, **ctx.params)n', ' File "/home/usman/Documents/venv/lib/python3.8/site-packages/click/core.py", line 610, in invoken return callback(*args, **kwargs)n', ' File "/home/usman/Documents/venv/lib/python3.8/site-packages/click/decorators.py", line 21, in new_funcn return f(get_current_context(), *args, **kwargs)n', ' File "/home/usman/Documents/venv/lib/python3.8/site-packages/celery/bin/base.py", line 132, in callern return f(ctx, *args, **kwargs)n', ' File "/home/usman/Documents/venv/lib/python3.8/site-packages/celery/bin/worker.py", line 327, in workern worker.start()n', ' File "/home/usman/Documents/venv/lib/python3.8/site-packages/celery/worker/worker.py", line 203, in startn self.blueprint.start(self)n', ' File "/home/usman/Documents/venv/lib/python3.8/site-packages/celery/bootsteps.py", line 116, in startn step.start(parent)n', ' File "/home/usman/Documents/venv/lib/python3.8/site-packages/celery/bootsteps.py", line 365, in startn return self.obj.start()n', ' File "/home/usman/Documents/venv/lib/python3.8/site-packages/billiard/process.py", line 124, in startn self._popen = self._Popen(self)n', ' File "/home/usman/Documents/venv/lib/python3.8/site-packages/billiard/context.py", line 276, in _Popenn return _default_context.get_context().Process._Popen(process_obj)n', ' File "/home/usman/Documents/venv/lib/python3.8/site-packages/billiard/context.py", line 333, in _Popenn return Popen(process_obj)n', ' File "/home/usman/Documents/venv/lib/python3.8/site-packages/billiard/popen_fork.py", line 24, in __init__n self._launch(process_obj)n', ' File "/home/usman/Documents/venv/lib/python3.8/site-packages/billiard/popen_fork.py", line 79, in _launchn code = process_obj._bootstrap()n', ' File "/home/usman/Documents/venv/lib/python3.8/site-packages/billiard/process.py", line 327, in _bootstrapn self.run()n', ' File "/home/usman/Documents/venv/lib/python3.8/site-packages/celery/beat.py", line 703, in runn self.service.start(embedded_process=True)n', ' File "/home/usman/Documents/venv/lib/python3.8/site-packages/celery/beat.py", line 627, in startn interval = self.scheduler.tick()n', ' File "/home/usman/Documents/venv/lib/python3.8/site-packages/celery/beat.py", line 339, in tickn self.apply_entry(entry, producer=self.producer)n', ' File "/home/usman/Documents/venv/lib/python3.8/site-packages/celery/beat.py", line 272, in apply_entryn exc, traceback.format_stack(), exc_info=True)n']
Traceback (most recent call last):
File "/home/usman/Documents/venv/lib/python3.8/site-packages/celery/beat.py", line 386, in apply_async
return task.apply_async(entry_args, entry_kwargs,
File "/home/usman/Documents/venv/lib/python3.8/site-packages/celery/app/task.py", line 526, in apply_async
check_arguments(*(args or ()), **(kwargs or {}))
TypeError: reminder_notification() got an unexpected keyword argument 'test132'
During handling of the above exception, another exception occurred:
Traceback (most recent call last):
File "/home/usman/Documents/venv/lib/python3.8/site-packages/celery/beat.py", line 269, in apply_entry
result = self.apply_async(entry, producer=producer, advance=False)
File "/home/usman/Documents/venv/lib/python3.8/site-packages/celery/beat.py", line 394, in apply_async
reraise(SchedulingError, SchedulingError(
File "/home/usman/Documents/venv/lib/python3.8/site-packages/celery/exceptions.py", line 104, in reraise
raise value.with_traceback(tb)
File "/home/usman/Documents/venv/lib/python3.8/site-packages/celery/beat.py", line 386, in apply_async
return task.apply_async(entry_args, entry_kwargs,
File "/home/usman/Documents/venv/lib/python3.8/site-packages/celery/app/task.py", line 526, in apply_async
check_arguments(*(args or ()), **(kwargs or {}))
celery.beat.SchedulingError: Couldn't apply scheduled task celery15: reminder_notification() got an unexpected keyword argument 'test132'
Что я делаю не так?
Комментарии:
1. Ваша ошибка указывает на то, что у вас есть (или был) аргумент ключевого слова с именем
test111вreminder_notification(), Bit, я не мог видеть ничего подобного в данном коде2. Кроме того, добавьте обратную трассировку ошибок как «текст», а не как изображения
3. @JPG во время тестирования я пробовал использовать разные имена, поэтому он отображается с
test111помощью . и трассировка добавляется в текст.
Ответ №1:
Я успешно получаю данные kwargs.
Решение:
Текущий запущенный рабочий не получает обновленные изменения из функции, поэтому нам нужно остановить рабочий и запустить снова.
celery -A baseapp worker --beat --scheduler django --loglevel=info