Есть необходимость отправлять уведомления разным пользователям, которые находятся в разных городах.
Есть несколько идей, как можно это сделать:
- Передать город, как объект в функцию Celery.
Но я где-то слышал, что передавать объект в функцию - не правильно.
@shared_task
def send_to_users(city):
users = User.objects.filter(city=city)
for user in users:
send_notify(user)
Плюс, не кажется лучшим способом итерировать по queryset'у
- Передать city.id
Этот вариант не сильно отличается от предыдущего, разве что выборка города происходит в самой функции.
@shared_task
def send_to_users(city_id):
city = City.objects.get(id=city_id)
users = User.objects.filter(city=city)
for user in users:
send_notify(user)
- Создавать задачу, для каждого
user
.
Этот подход кажется интересным тем, что я вижу, какому user
не отправилось сообщение, если что-то пошло не так
@shared_task
def send_to_user(user):
send_notify(user)
Но не кажется правильным плодить 100500 задач, для такой простой операции.
Что должны возвращать эти функции ? Если я передаю список юзеров, которым нужно отослать уведомления, то правильно вернуть список тех, кому отправился ?
Я так понимаю, что функции celery должны быть короткими, и не включать в себя проверки на наличие в БД, проверки состояний пр.
Но когда функция вызывается из метода модели, делать выборки из БД - значит замедлить отклик.
Как делать правильно ? Какие лучшие практики ?