Запуск функции Window для набора значений Max'd

Итак, у меня есть объект Trainer который имеет обратные отношения ко многим Survey объекты. каждый Survey Объект имеет загрузку целочисленных полей и представляет статистику в определенный момент времени. Не каждый Survey Объект будет заполнено каждое поле, поэтому я использую django.db.models.Max() чтобы получить последние значения (значения никогда не могут снизиться).

Затем я пытаюсь сравнить эти значения со всеми остальными во всех других Trainer объекты в базе данных с django.db.models.functions.windows.PercentRank() чтобы получить их процентиль.

Это то, что у меня есть, и работает нормально до Window Expression - Calculate Percentile после чего я получаю ошибку!

from django.db.models import Max, Window, F
from django.db.models.functions.window import PercentRank

from survey.models import Survey, Trainer

fp_default_fields = ['badge_travel_km', 'badge_capture_total', 'badge_evolved_total', 'badge_hatched_total', 'badge_pokestops_visited', 'badge_big_magikarp', 'badge_battle_attack_won', 'badge_small_rattata', 'badge_pikachu', 'badge_legendary_battle_won', 'badge_berries_fed', 'badge_hours_defended', 'badge_raid_battle_won', 'gymbadges_gold', 'badge_challenge_quests', 'badge_max_level_friends', 'badge_trading', 'badge_trading_distance']

def calculate_foo_points(survey: Survey, fields: str=fp_default_fields, top_x: int=10):
    '''
    Calculates a Trainer's Foo Points at the time of Surveying
    '''

# Base Query - All Trainers valid BEFORE the date of calculation
query = Trainer.objects.filter(survey__update_time__lte=survey.update_time)
# Modify Query - Exclude Spoofers
query = query.exclude(account_falsify_location_spawns=True,account_falsify_location_gyms=True,account_falsify_location_raids=True,account_falsify_location_level_up=True)
# Extend Query - Get Max'd Values
query = query.annotate(**{x:Max(f'survey__{x}') for x in fields})
# Window Expression - Calculate Percentile
query = query.annotate(**{f'{x}_percentile':Window(expression=PercentRank(x), order_by=F(x).asc()) for x in fields})
# Delay the fields we don't need
query = query.only('user__id')
# Get Trainer
trainer = [x for x in query if x.pk == survey.trainer.pk]
# Get 10* most highest ranked fields
top_x_result = sorted([getattr(trainer, x) for x in fields])[:top_x]
# Average together fields
result = sum(top_x_result, top_x)
return result

Ошибка:

Traceback (most recent call last):
  File "/mnt/sshd/Gits/tl40/env/lib/python3.7/site-packages/django/db/backends/utils.py", line 85, in _execute
    return self.cursor.execute(sql, params)
psycopg2.ProgrammingError: WITHIN GROUP is required for ordered-set aggregate percent_rank
LINE 1: ...e_trading_distance") AS "badge_trading_distance", PERCENT_RA...
                                                             ^

Если кто-нибудь сможет объяснить, что это значит или как обойти это, это было бы здорово:)

Спасибо!

1 ответ

Решение

Проблема заключалась в том, что функция PercentRank не принимает никаких аргументов. Документация Django была не очень понятной.

Другие вопросы по тегам