Ë
|
|
çúh:- ã óÚ d dl mZmZmZmZ d dlmZ e« Z G d d« Z G d d« Z
|
G d d« Z G d d
|
e « Z G d d e « Z G d d« Z G d d« Z G d d« Zy)é )ÚListÚOptionalÚTupleÚUnion)ÚDEFAULT_DIALECTc ó( e Zd ZddededdfdZd Zy)ÚLimitÚoffsetÚcountÚreturnNc ó || _ || _ y ©N)r
|
r )Úselfr
|
r s õt H:\项ç®\archive\æµè¯ç»\èæ¬\Change_password\venv_build\Lib\site-packages\redis/commands/search/aggregation.pyÚ__init__zLimit.__init__ s Ø Ø
|
ó c ót | j r+dt | j « t | j « gS g S )NÚLIMIT)r Ústrr
|
©r s r Ú
|
build_argszLimit.build_args s, Ø ::ØS §¡Ó -¬s°4·:±:«Ð?Ð ?àIr )r r ©Ú__name__Ú
|
__module__Ú __qualname__Úintr r © r r r r s! ñsð ¨sð ¸4ó ór r c óT e Zd ZdZdZdeddfdZdedd fdZede edf fd « Z
|
y)
|
ÚReducerzr
|
Base reducer object for all reducers.
|
|
See the `redisearch.reducers` module for the actual reducers.
|
NÚargsr c ó. || _ d | _ d | _ y r )Ú_argsÚ_fieldÚ_alias©r r s r r zReducer.__init__ s Ø&*
|
Ø%) Ø%) r Úaliasc óp |t u r&| j s t d« | j dd }|| _ | S )a
|
Set the alias for this reducer.
|
|
### Parameters
|
|
- **alias**: The value of the alias for this reducer. If this is the
|
special value `aggregation.FIELDNAME` then this reducer will be
|
aliased using the same name as the field upon which it operates.
|
Note that using `FIELDNAME` is only possible on reducers which
|
operate on a single field value.
|
|
This method returns the `Reducer` object making it suitable for
|
chaining.
|
z(Cannot use FIELDNAME alias with no fieldé N)Ú FIELDNAMEr# Ú
|
ValueErrorr$ )r r& s r r& z Reducer.alias" s< ð IÑ Ø;;Ü Ð!KÓLÐLð A BØ Ø r .c ó | j S r )r" r s r r z Reducer.args: s àzzÐr ) r r r Ú__doc__ÚNAMEr r r& Úpropertyr r r r r r r sW ñð Dð*cð * dó *ð
|
3ð 9ó ð0 ðeC Hoò ó ñr r c ó6 e Zd ZU dZdZee ed< deddfdZy)Ú SortDirectionz@
|
This special class is used to indicate sort direction.
|
NÚ DIRSTRINGÚfieldr c ó || _ y r )r2 )r r2 s r r zSortDirection.__init__F s Ø
|
r ) r r r r, r1 r r Ú__annotations__r r r r r0 r0 ? s*
ñð $Ix}Ó#ðcð dô r r0 c ó e Zd ZdZdZy)ÚAsczK
|
Indicate that the given field should be sorted in ascending order
|
ÚASCN©r r r r, r1 r r r r6 r6 J s ñð Ir r6 c ó e Zd ZdZdZy)ÚDesczL
|
Indicate that the given field should be sorted in descending order
|
ÚDESCNr8 r r r r: r: R s ñð Ir r: c ó e Zd ZdZd deddfdZdedd fdZdeeee f de dd fd Z
|
d d
|
Z d e d e dd fd Z dedd fdZdeeee f dd fdZd dZd dZdedd fdZd dZd de dedd fdZdee fdZde dd fdZy) ÚAggregateRequestzH
|
Aggregation request which can be passed to `Client.aggregate`.
|
Úqueryr Nc ó¦ || _ g | _ g | _ d| _ d| _ d| _ d| _ g | _ t | _ d| _
|
d| _ y)a}
|
Create an aggregation request. This request may then be passed to
|
`client.aggregate()`.
|
|
In order for the request to be usable, it must contain at least one
|
group.
|
|
- **query** Query string for filtering records.
|
|
All member methods (except `build_args()`)
|
return the object itself, making them useful for chaining.
|
Fr ÚTFIDFN) Ú_queryÚ_aggregateplanÚ _loadfieldsÚ_loadallÚ_maxÚ _with_schemaÚ _verbatimÚ_cursorr Ú_dialectÚ _add_scoresÚ_scorer)r r> s r r zAggregateRequest.__init___ sU ð ! Ø)+ÔØ&(ÔØ # Ø Ø"'ÔØ $Ø"$ Ü , Ø!&ÔØ # r Úfieldsc óR |r | j j |« | S d| _ | S )aC
|
Indicate the fields to be returned in the response. These fields are
|
returned in addition to any others implicitly specified.
|
|
### Parameters
|
|
- **fields**: If fields not specified, all the fields will be loaded.
|
Otherwise, fields should be given in the format of `@field`.
|
T)rC ÚextendrD )r rL s r ÚloadzAggregateRequest.loadx s0 ñ Ø × Ñ × #Ñ # FÔ +ð ð !DMØ r Úreducersc ór t |t « r|gn|}dt t |« « g|¢}|D ]i }|d|j t t |j « « gz }|j |j « |j Y|d|j gz }k | j j |« | S )a|
|
Specify by which fields to group the aggregation.
|
|
### Parameters
|
|
- **fields**: Fields to group by. This can either be a single string,
|
or a list of strings. both cases, the field should be specified as
|
`@field`.
|
- **reducers**: One or more reducers. Reducers may be found in the
|
`aggregation` module.
|
ÚGROUPBYÚREDUCEÚAS)Ú
|
isinstancer Úlenr- r rN r$ rB )r rL rP ÚretÚreducers r Úgroup_byzAggregateRequest.group_by s¨ ô (¨´Ô 4&¸&à#c &kÓ*Ð4¨VÐ4Ø ò .GØ Hgll¬C´°G·L±LÓ0AÓ,BÐCÑ CCØ JJw||Ô $Ø~~Ñ)ØgnnÐ-Ñ-ð .ð ×Ñ×"Ñ" 3Ô'Ø r c ó |j « D ]- \ }}d|g}||d|gz }| j j |« / | S )aQ
|
Specify one or more projection expressions to add to each result
|
|
### Parameters
|
|
- **kwexpr**: One or more key-value pairs for a projection. The key is
|
the alias for the projection, and the value is the projection
|
expression itself, for example `apply(square_root="sqrt(@foo)")`
|
ÚAPPLYrT )ÚitemsrB rN )r Úkwexprr& ÚexprrW s r ÚapplyzAggregateRequest.apply¢ sU ð "<<>ò ,KE4ØD/CØÐ Øe}Ñ$Ø × Ñ × &Ñ & sÕ +ð ,ð r r
|
Únumc óp t ||« }| j j |j « « | S )a
|
Sets the limit for the most recent group or query.
|
|
If no group has been defined yet (via `group_by()`) then this sets
|
the limit for the initial pool of results from the query. Otherwise,
|
this limits the number of items operated on from the previous group.
|
|
Setting a limit on the initial search results may be useful when
|
attempting to execute an aggregation on a sample of a large data set.
|
|
### Parameters
|
|
- **offset**: Result offset from which to begin paging
|
- **num**: Number of results to return
|
|
|
Example of sorting the initial results:
|
|
```
|
AggregateRequest("@sale_amount:[10000, inf]") .limit(0, 10) .group_by("@state", r.count())
|
```
|
|
Will only group by the states found in the first 10 results of the
|
query `@sale_amount:[10000, inf]`. On the other hand,
|
|
```
|
AggregateRequest("@sale_amount:[10000, inf]") .limit(0, 1000) .group_by("@state", r.count() .limit(0, 10)
|
```
|
|
Will group all the results matching the query, but only return the
|
first 10 groups.
|
|
If you only wish to return a *top-N* style query, consider using
|
`sort_by()` instead.
|
|
)r rB rN r )r r
|
r` Ú_limits r ÚlimitzAggregateRequest.limit´ s3 ôT vsÓ#Ø ×Ñ×"Ñ" 6×#4Ñ#4Ó#6Ô7Ø r c óZ g }|D ]: }t |t t f« r ||j |j gz }5||gz }< dt t |« « g}|j |« |j dd« }|dkD r|dt |« gz }| j j |« | S )a,
|
Indicate how the results should be sorted. This can also be used for
|
*top-N* style queries
|
|
### Parameters
|
|
- **fields**: The fields by which to sort. This can be either a single
|
field or a list of fields. If you wish to specify order, you can
|
use the `Asc` or `Desc` wrapper classes.
|
- **max**: Maximum number of results to return. This can be
|
used instead of `LIMIT` and is also faster.
|
|
|
Example of sorting by `foo` ascending and `bar` descending:
|
|
```
|
sort_by(Asc("@foo"), Desc("@bar"))
|
```
|
|
Return the top 10 customers:
|
|
```
|
AggregateRequest() .group_by("@customer", r.sum("@paid").alias(FIELDNAME)) .sort_by(Desc("@paid"), max=10)
|
```
|
ÚSORTBYÚmaxr ÚMAX)
|
rU r6 r: r2 r1 r rV rN ÚgetrB )r rL ÚkwargsÚ fields_argsÚfrW rf s r Úsort_byzAggregateRequest.sort_byâ s® ð: Øò #AÜ!c¤4[Ô)Ø §¡¨¯©Ð 5Ñ5 à sÑ" ð #ð S Ó -Ó.Ð/Ø
|
|
;Ô Øjj Ó"Ø 7Ø E3s8Ð$Ñ $Cà ×Ñ×"Ñ" 3Ô'Ø r Ú expressionsc ót t |t « r|g}|D ] }| j j d|g« ! | S )zÿ
|
Specify filter for post-query results using predicates relating to
|
values in the result set.
|
|
### Parameters
|
|
- **fields**: Fields to group by. This can either be a single string,
|
or a list of strings.
|
ÚFILTER)rU r rB rN )r rm Ú
|
expressions r ÚfilterzAggregateRequest.filter sD ô k¤3Ô 'Ø&-Kà%ò ?JØ × Ñ × &Ñ &¨°*Ð'=Õ >ð ?ð r c ó d| _ | S )z|
|
If set, the `schema` property will contain a list of `[field, type]`
|
entries in the result object.
|
T)rF r s r Ú with_schemaz AggregateRequest.with_schema! s ð
|
!ÔØ r c ó d| _ | S )zM
|
If set, includes the score as an ordinary field of the row.
|
T)rJ r s r Ú
|
add_scoreszAggregateRequest.add_scores) s ð ÔØ r Úscorerc ó || _ | S )zÚ
|
Use a different scoring function to evaluate document relevance.
|
Default is `TFIDF`.
|
|
:param scorer: The scoring function to use
|
(e.g. `TFIDF.DOCNORM` or `BM25`)
|
)rK )r rv s r rv zAggregateRequest.scorer0 s ð Ø r c ó d| _ | S )NT)rG r s r ÚverbatimzAggregateRequest.verbatim; s Ø Ø r r Úmax_idlec óh dg}|r|dt |« gz }|r|dt |dz « gz }|| _ | S )NÚ
|
WITHCURSORÚCOUNTÚMAXIDLEiè )r rH )r r rz r s r ÚcursorzAggregateRequest.cursor? sF Ø ~Ù Ø Wc %jÐ)Ñ )DÙ Ø Y¤ H¨t¡OÓ 4Ð5Ñ 5DØ Ø r c ó | j g}| j r|j d« | j r|j d« | j r |j d| j g« | j r|j d« | j r|| j z }| j r#|j d« |j d« ne| j rY|j d« |j t t | j « « « |j | j « | j r&|j dt | j « g« |j | j « |S )NÚ
|
WITHSCHEMAÚVERBATIMÚSCORERÚ ADDSCORESÚLOADÚ*ÚDIALECT)rA rF ÚappendrG rK rN rJ rH rD rC r rV rI rB )r rW s r r zAggregateRequest.build_argsH s à{{mà × Ò Ø JJ|Ô $à >>Ø JJzÔ "à <<Ø JJ $§,¡,Ð/Ô 0à × Ò Ø JJ{Ô #à <<Ø 4<<Ñ Cà ==Ø JJvÔ Ø JJsOà × Ò Ø JJvÔ Ø JJs3t× /Ñ /Ó0Ó1Ô 2Ø JJt×'Ñ'Ô (à ==Ø JJ ¤3 t§}¡}Ó#5Ð6Ô 7à
|
|
4×&Ñ&Ô'à
|
r Údialectc ó || _ | S )z
|
Add a dialect field to the aggregate command.
|
|
- **dialect** - dialect version to execute the query under
|
)rI )r r s r r zAggregateRequest.dialectk s ð Ø r )r )r r= )r g )r r r r, r r rO r r r rY r_ r rc rl rq rs ru rv ry Úfloatr r r r r r r= r= Z s ññ$cð $¨Dó $ð2Cð Ð$6ó ð ØC c¡NÑ+ðØ8?ðà óó4ð$,Cð , cð ,Ð.@ó ,ð\+sð +Ð1Có +ðZ %¨¨T°#©Y¨Ñ"7ð Ð<Nó ó$óð Sð Ð%7ó óñCð ¨uð Ð?Qó ð!D Ió !ðFsð Ð'9ô r r= c ó" e Zd ZdeddfdZd Zy)ÚCursorÚcidr Nc ó. || _ d| _ d| _ y )Nr )r rz r ©r r s r r zCursor.__init__v s ØØ Ø
|
r c óÊ t | j « g}| j r|dt | j « gz }| j r|dt | j « gz }|S )Nr~ r} )r r rz r r% s r r zCursor.build_args{ sS ÜDHH Ø ==Ø Y¤ D§M¡MÓ 2Ð3Ñ 3DØ ::Ø Wc $§*¡*oÐ.Ñ .DØ r r r r r r r u s ðCð Dó ó
|
r r c ó( e Zd ZdeddfdZdefdZy)ÚAggregateResultr r Nc ó. || _ || _ || _ y r )Úrowsr Úschema)r r r r s r r zAggregateResult.__init__
s Ø Ø Ø r c óÊ | j r| j j nd}d| j j dt | « ddt | j « d| d S )Néÿÿÿÿú<z at 0xÚxz Rows=z , Cursor=ú>)r r Ú __class__r ÚidrV r r s r Ú__repr__zAggregateResult.__repr__ sZ Ø!%§¢dkkoo°"à×'Ñ'Ð(¨¬r°$«x¸¨lð ;Ü NÐ# 9¨S¨E°ð 4ð
|
r )r r r r r r r r r r r r s! ð Vð ¸ó ð
|
|
#ô
|
r r N)Útypingr r r r Ú redis.commands.search.dialectr Úobjectr) r r r0 r6 r: r= r r r r r ú<module>r¢ sm ðß /Ó /å 9á H ÷ ñ ÷(ñ (÷Vñ ô-ô ô=ô ÷Xñ X÷v ñ ÷
|
ò
|
r
|
