Ë
|
|
çúh ã ó¨ d dl mZ ddlmZ ddlmZmZmZm Z m
|
Z
|
m Z m Z m Z mZ G d de« Z G d dee « Z G d d
|
ee« Z G d d e ee« Zy )é )ÚPipelineé é ) Ú AGGREGATE_CMDÚ
|
CONFIG_CMDÚINFO_CMDÚ PROFILE_CMDÚ
|
SEARCH_CMDÚSPELLCHECK_CMDÚ SYNDUMP_CMDÚAsyncSearchCommandsÚSearchCommandsc ó4 e Zd ZdZ G d d« ZddZddZy) ÚSearchzy
|
Create a client for talking to search.
|
It abstracts the API of the module and lets you just use the engine.
|
c ó@ e Zd ZdZddZd Z d dZd
|
dZd Zy) úSearch.BatchIndexerú
|
A batch indexer allows you to automatically batch
|
document indexing in pipelines, flushing it every N documents.
|
c ó || _ |j | _ |j dd ¬« | _ d| _ || _ d| _ y )NF)Ú transactionÚ
|
shard_hintr )ÚclientÚexecute_commandÚpipelineÚ _pipelineÚtotalÚ
|
chunk_sizeÚ current_chunk)Úselfr r s õq H:\项ç®\archive\æµè¯ç»\èæ¬\Change_password\venv_build\Lib\site-packages\redis/commands/search/__init__.pyÚ__init__z Search.BatchIndexer.__init__ sA Ø DKØ#)×#9Ñ#9DÔ Ø #__¸È4_Ó PDNØDJØ (DOØ!"DÕ ó c ó> | j r| j « y y )N)r Úcommit©r s r Ú__del__zSearch.BatchIndexer.__del__% s Ø×!Ò!Ø ð "r! Nc ó
|
| j j |f| j ||||||d|¤ | xj dz c_ | xj dz c_ | j | j
|
k\ r| j « yy©z;
|
Add a document to the batch query
|
)ÚconnÚnosaveÚscoreÚpayloadÚreplaceÚpartialÚ no_creater N©r Ú _add_documentr r r r r# © r Údoc_idr) r* r+ r, r- r. Úfieldss r Ú add_documentz Search.BatchIndexer.add_document) s ð &DKK× %Ñ %Øð
|
à^^Ø ØØ Ø Ø Ø#ñ
|
ð ò
|
ð × Ò !Ñ #Õ Ø JJ!OJØ×!Ñ! T§_¡_Ò4Ø ð 5r! c óþ | j j || j ||¬« | xj dz c_ | xj dz c_ | j | j
|
k\ r| j « yy)z7
|
Add a hash to the batch query
|
)r( r* r, r N)r Ú_add_document_hashr r r r r# )r r2 r* r, s r Úadd_document_hashz%Search.BatchIndexer.add_document_hashG sh ð KK× *Ñ *ØT^^°5À'ð +ô ð × Ò !Ñ #Õ Ø JJ!OJØ×!Ñ! T§_¡_Ò4Ø ð 5r! c óF | j j « d| _ y)úL
|
Manually commit and flush the batch indexing query
|
r N©r Úexecuter r$ s r r# zSearch.BatchIndexer.commitS s ð NN× "Ñ "Ô $Ø!"DÕ r! )iè ©Fç ð?NFFF)r= F) Ú__name__Ú
|
__module__Ú __qualname__Ú__doc__r r% r4 r7 r# © r! r Ú BatchIndexerr s4 ñ ó
|
#ò ð ØØØØØó ó<
|
ó #r! rC c ó` i | _ || _ || _ |j | _ |j | _ t | j t | j t | j t | j t | j t | j" t$ | j& i| _ y)z®
|
Create a new Client for the given index_name.
|
The default name is `idx`
|
|
If conn is not None, we employ an already existing redis connection
|
N)Ú_MODULE_CALLBACKSr Ú
|
index_namer r r r Ú _parse_infor
|
Ú _parse_searchr Ú_parse_aggregater Ú_parse_profiler Ú_parse_spellcheckr Ú_parse_config_getr Ú_parse_syndumpÚ_RESP2_MODULE_CALLBACKS)r r rF s r r zSearch.__init__Z s ð "$Ô Ø Ø$Ø %× 5Ñ 5Ô Ø ä d×&Ñ&Ü ×*Ñ*Ü 4×0Ñ0Ü ×,Ñ,Ü D× 2Ñ 2Ü ×.Ñ.Ü ×,Ñ,ð(
|
Õ$r! Nc ó t | j j | j ||¬« }| j |_ |S ©zCreates a pipeline for the SEARCH module, that can be used for executing
|
SEARCH commands, as well as classic core commands.
|
)Úconnection_poolÚresponse_callbacksr r )r r rQ rE rF ©r r r Úps r r zSearch.pipelinep s< ô Ø KK× 7Ñ 7Ø #× 5Ñ 5Ø#Ø!ô
|
ð Ør! )Úidx©TN)r> r? r@ rA rC r r rB r! r r r s ñ÷
|
A#ñ A#óF
|
ô, r! r c ó> e Zd Z G d dej « ZddZy)Ú AsyncSearchc ó* e Zd ZdZ ddZd Zy)úAsyncSearch.BatchIndexerr Nc ó& K | j j |f| j ||||||d|¤ | xj dz c_ | xj dz c_ | j | j
|
k\ r| j « d{ yy7 wr' r/ r1 s r r4 z%AsyncSearch.BatchIndexer.add_document
s è ø ð &DKK× %Ñ %Øð
|
à^^Ø ØØ Ø Ø Ø#ñ
|
ð ò
|
ð × Ò !Ñ #Õ Ø JJ!OJØ×!Ñ! T§_¡_Ò4Økkm×#Ñ#ð 5Ø#ús BBÂB Bc ób K | j j « d{ d| _ y7 w)r9 Nr r: r$ s r r# z AsyncSearch.BatchIndexer.commit£ s+ è ø ð ..×(Ñ(Ó*× *Ð *Ø!"DÕ ð +ús / -¡ /r< )r> r? r@ rA r4 r# rB r! r rC rZ s% ñ ð ØØØØØó $ó< #r! rC Nc ó t | j j | j ||¬« }| j |_ |S rP )Ú AsyncPipeliner rQ rE rF rS s r r zAsyncSearch.pipelineª s< ô Ø KK× 7Ñ 7Ø #× 5Ñ 5Ø#Ø!ô
|
ð Ør! rV )r> r? r@ r rC r rB r! r rX rX ~ s ô)#v×*Ñ*ô )#ôV r! rX c ó e Zd ZdZy)r zPipeline for the module.N©r> r? r@ rA rB r! r r r ¸ s Ú"r! r c ó e Zd ZdZy)r^ z AsyncPipeline for the module.Nr` rB r! r r^ r^ ¼ s Ú'r! r^ N)Ú redis.clientr Ú RedisPipelineÚasyncio.clientÚAsyncioPipelineÚcommandsr r r r r
|
r r r r r rX r^ rB r! r ú<module>rg sX ðÝ 2å 9÷
|
÷
|
õ
|
ôj^ô jôZ7&Ð-ô 7ôt#~}ô #ô(Ð'¨ ¸(õ (r!
|
