FT.AGGREGATE

применяет преобразование 1:1 к одному или нескольким свойствам и либо сохраняет результат в качестве нового свойства в обработке, либо заменяет любое свойство с помощью этого преобразования.

expr — это выражение, которое может использоваться для выполнения арифметических операций над числовыми свойствами, функций, которые могут применяться к свойствам в зависимости от их типов (см. ниже), или любой комбинации из них. Например, APPLY "sqrt(@foo)/log(@bar) + 5" AS baz динамически оценивает это выражение для каждой записи в обработке и сохраняет результат в качестве нового свойства с именем baz, которое может быть использовано в последующих операциях APPLY/SORTBY/GROUPBY/REDUCE обработки.

ограничивает количество возвращаемых результатов только num результатами, начиная с индекса offset (нумерация с нуля). Для ограничения выходных данных операции сортировки гораздо эффективнее использовать SORTBY … MAX. Если ключ истекает во время запроса, попытка получить значение ключа вернет пустой массив.

Однако, limit можно использовать для ограничения результатов без сортировки или для постраничного просмотра n-наибольших результатов, определяемых SORTBY MAX. Например, получение результатов 50-100 из 100 наилучших результатов выражается наиболее эффективно как SORTBY 1 @foo MAX 100 LIMIT 50 50. Удаление MAX из SORTBY приводит к сортировке всей обработки всех записей, а затем постраничному просмотру результатов 50-100.

фильтрует результаты с помощью предикатных выражений, связанных со значениями в каждом результате. Они применяются после запроса и относятся к текущему состоянию обработки.

Обрабатывает часть результатов с помощью более быстрого варианта, чем LIMIT. См. API курсора для получения дополнительной информации.

если установлено, переопределяет параметр таймаута модуля.

определяет один или несколько параметров значений. Каждый параметр имеет имя и значение.

Параметры в query можно ссылаться с помощью $, после которого следует имя параметра, например, $user. Каждая такая ссылка в запросе поиска на имя параметра заменяется соответствующим значением параметра. Например, с определением параметра PARAMS 4 lon 29.69465 lat 34.95126, выражение @loc:[$lon $lat 10 km] вычисляется в @loc:[29.69465 34.95126 10 km]. Параметры нельзя ссылаться в строке запроса, где конкретные значения недопустимы, например, в именах полей, например, @loc. Для использования PARAMS, установите DIALECT на 2 или больше 2.

выбирает версию диалекта, в которой должен выполняться запрос. Если не указано, запрос будет выполнен в соответствии с установленной по умолчанию версией диалекта при загрузке модуля или с помощью команды FT.CONFIG SET.

Найти посещения страницы about.html, сгруппировать их по дню посещения, посчитать количество посещений и отсортировать их по дням.

FT.AGGREGATE idx "@url:\"about.html\""
    APPLY "day(@timestamp)" AS day
    GROUPBY 2 @day @country
      REDUCE count 0 AS num_visits
    SORTBY 4 @day

Поиск книг, чаще всего публикуемых в конкретном году.

FT.AGGREGATE books-idx *
    GROUPBY 1 @published_year
      REDUCE COUNT 0 AS num_published
    GROUPBY 0
      REDUCE MAX 1 @num_published AS max_books_published_per_year

В последнем примере использовался GROUPBY 0. Используйте GROUPBY 0 для применения функции REDUCE ко всем результатам с последней стадии агрегационной обработки — это работает как для начального запроса, так и для последующих операций GROUPBY.

Поиск библиотек в радиусе 10 километров от долготы -73.982254 и широты 40.753181, а затем их аннотирование расстоянием между их местоположением и этими координатами.

 FT.AGGREGATE libraries-idx "@location:[-73.982254 40.753181 10 km]"
    LOAD 1 @location
    APPLY "geodistance(@location, -73.982254, 40.753181)"

Здесь нам потребовалось использовать LOAD для предварительной загрузки атрибута @location, поскольку это атрибут GEO.

Далее, посчитать события GitHub по пользователям (акторам), чтобы определить наиболее активных пользователей.

127.0.0.1:6379> FT.AGGREGATE gh "*" GROUPBY 1 @actor REDUCE COUNT 0 AS num SORTBY 2 @num DESC MAX 10
 1) (integer) 284784
 2) 1) "actor"
    2) "lombiqbot"
    3) "num"
    4) "22197"
 3) 1) "actor"
    2) "codepipeline-test"
    3) "num"
    4) "17746"
 4) 1) "actor"
    2) "direwolf-github"
    3) "num"
    4) "10683"
 5) 1) "actor"
    2) "ogate"
    3) "num"
    4) "6449"
 6) 1) "actor"
    2) "openlocalizationtest"
    3) "num"
    4) "4759"
 7) 1) "actor"
    2) "digimatic"
    3) "num"
    4) "3809"
 8) 1) "actor"
    2) "gugod"
    3) "num"
    4) "3512"
 9) 1) "actor"
    2) "xdzou"
    3) "num"
    4) "3216"
[10](10)) 1) "actor"
    2) "opstest"
    3) "num"
    4) "2863"
11) 1) "actor"
    2) "jikker"
    3) "num"
    4) "2794"
(0.59s)