[michael93pl]

#python #django

Mirki, chcę na serwerze odpalać periodic task, który co x minut będzie odpytywał model i sprawdzał czy są w nim maile do wysłania.

Całą resztę ogarnąłem ale mam problem do stworzenia odpowiedniego query w managerze, który ma działać w następujący sposób:

1) w managerze określam aktualną datę(currentdate)
2) w zależności od rodzaju emaila, wybieram okres, po którym ma zostać wysłany(delta) - ponieważ te okresy są dynamiczne, musi być to liczone od aktualnej daty)
3) jeżeli minął określony przeze mnie okres, queryset ma zwrócić te obiekty

Poniżej wrzucam prove of concept, które wywala się oczywiście na tym kawałku
((currentdate - F('created_at')).seconds
dalej wywali się też na delta > 0 ale tak jak mówię, to tylko prove of concept

delta = 60 * 1 * 5
currentdate = timezone.now()
qs = self.annotate(passed=((currentdate - F('created_at')).seconds // delta > 0)).filter(passed=True)

nie wiem czy nie próbuję tego przekombinować trochę, anyway, za każdą poradę będę wdzięczny

[maledorak]

@michael93pl: stack trace błędu wklej

[michael93pl]

@maledorak: teraz to oczywisty błąd,
AttributeError: 'CombinedExpression' object has no attribute 'seconds'
((currentdate - F('createdat')).seconds nie ewaluuje się do datetime.timedelta object ale do CombinedExpression

kombinowałem też z ExpressionWrapper ale bez efektu

[maledorak]

@michael93pl: obliczanie delty wynieś wyżej, po to jest datetime.timedelta
delta = 60 * 1 * 5
sendafter = timezone.now() + datetime.timedelta(seconds=delta)

i wtedy robisz porównanie currentdate z sendafter, który jest oiektem datetime i nie musisz nic kombinować z sekundami

[michael93pl]

@maledorak źle to chyba opisałem
sendafter nic mi nie da jako obiekt datetime, ponieważ musze porownac createdat(DateTimeField w modelu z autoaddnow) do czasu now() i czy minęło od created at 5 minut

[michael93pl]

@maledorak w sumie prościej byłoby zapytać: Jak sprawdzić ile czasu minęło od nowa() do wartości z pola created_at i uzyc to jako filtr managera

[maledorak]

@michael93pl

delta = 60 * 1 * 5
sendafter = timezone.now() - datetime.timedelta(seconds=delta)

[michael93pl]

@maledorak niestety trochę to źle opisałem, createdat nigdy nie będzie większe niż jakakolwiek data, przynajmniej nie o to chodzi
Muszę znaleźć ile wynosi różnica pomiędzy
now() a wartością w polu createdat i jeżeli wynosi więcej niż delta to zwrócić ten obiekt w qs

coś pokroju:
self.annotate(foo=(Sum(F('createdat) - currentdate)) ale obv lokalnie mam tylko sqllite, na którym agregacja przez Sum nie działa, a właśnie wychodzę i nie

[krzysiek_pl]

a może wykorzystać celery do tego? .apply_async z parametrem eta=

[michael93pl]

@krzysiek_pl celery już wykorzystuje
prze systemd śmiga mi proces co x minut, ktory wyciągać te obiekty z bazy i jeżeli mail jest już gotowy do wysłania do przekazuje buduje obiekt maila wraz z contextem i templatem, a następnie przekazuje go przez adapter to zewnętrznego dostawcy usługi wysyłania maili
Muszę tylko osiągnąć to, co przedstawia mój przykład ale ciągle nie wiem jak :/

[michael93pl]

@maledorak: @krzysiek_pl:
dobra, udalo sie, nie jest eleganckie ale działa
qs = self.annotate(sendat=Sum(
currentdate - F('createdat'))).filter(sendat__gt=Sum(timezone.timedelta(seconds=delta)))

[maledorak]

@michael93pl: z tym celery uważaj aby timezony były takie same ustawione na wszystkich maszynach, bo może się okazać że wysyłasz taski w przyszłość, albo przeszłość :P

[michael93pl]

@maledorak: taski celery moga sie lekko "mylic" choc nie powinno miec to znaczenia, sprawdzam jedynie okresy pomiedzy aktualnym czasem na serwerze, a momentem stworzenia obiektu na tym samym serverze, wiec nie powinno byc zadnych roznic ^^

idea byla taka, zeby maile wysylaly sie po wypelnieniu formularza tak dlugo(okresy x, y,z) az klient nie wypelni okreslonego warunku, ktorego stan zmieni sie dopiero wtedy, gdy zewnetrzny dostawca uslugi da mi o tym