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

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

0 голосов
/ 07 октября 2018

Итак, у меня есть объект 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 Ответ

0 голосов
/ 26 октября 2018

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

...