Как вызвать периодическую функцию Celery из кода Python с передачей аргументов времени выполнения в функцию? - PullRequest
0 голосов
/ 21 июня 2019

У меня есть проект Django.При запуске мне нужно периодически сохранять некоторые данные в файл.Я могу получить эти данные только при запуске программы.

Теперь я запускаю поток с этой функцией и передаю аргументы функции

threading.Thread(target=save_data, args=(dp, conv_handler)).start()

Но этот поток не умирает, когда основной процесс умирает.Я слышал, что де-факто решением для таких задач является CeleryBeat, но не могу понять, как передать аргументы в функцию, которая работает в сельдерее.Как я могу решить такую ​​проблему?

...