W mojej witrynie użytkownicy mogą ZAKTUALIZOWAĆ swój profil (ręczny) za każdym razem, gdy chce, lub automatycznie raz dziennie.selera - zadania, które należy uruchomić w priorytecie
To zadanie jest obecnie dystrybuowane z selerem.
ale mam "problem":
Codziennie w automatycznej aktualizacji, zadanie ułożenie wszystkich użytkowników (+ -6k użytkowników) na kolejki:
from celery import group
from tasks import *
import datetime
from lastActivityDate.models import UserActivity
today = datetime.datetime.today()
one_day = datetime.timedelta(days=5)
today -= one_day
print datetime.datetime.today()
user_list = UserActivity.objects.filter(last_activity_date__gte=today)
g = group(update_user_profile.s(i.user.auth.username) for i in user_list)
print datetime.datetime.today()
print g(user_list.count()).get()
Jeśli ktoś spróbować zrobić ręczna aktualizacja, będą one wprowadzane w kolejce i trwać wiecznie, aby zostać wykonane.
Czy istnieje sposób na ręczne uruchomienie tego ręcznego zadania? Lub wykonać dedykowaną dla każdej oddzielonej kolejki: ręczną i automatyczną?
Możesz ograniczyć liczbę wykonywanych zadań, na przykład w godzinach. Następnie inne zadania ... Przeczytaj ich dokumentację ... – catherine