From a15f21d4770b92ff565a28d9fb1d294c89729f10 Mon Sep 17 00:00:00 2001
From: HuangHai <10402852@qq.com>
Date: Fri, 27 Jun 2025 13:51:37 +0800
Subject: [PATCH] 'commit'

---
 .../Utils/ElasticsearchConnectionPool.py         |   5 +----
 ...lasticsearchCollectionManager.cpython-310.pyc | Bin 0 -> 3488 bytes
 .../ElasticsearchConnectionPool.cpython-310.pyc  | Bin 0 -> 2754 bytes
 .../__pycache__/__init__.cpython-310.pyc         | Bin 0 -> 144 bytes
 4 files changed, 1 insertion(+), 4 deletions(-)
 create mode 100644 dsRag/ElasticSearch/Utils/__pycache__/ElasticsearchCollectionManager.cpython-310.pyc
 create mode 100644 dsRag/ElasticSearch/Utils/__pycache__/ElasticsearchConnectionPool.cpython-310.pyc
 create mode 100644 dsRag/ElasticSearch/__pycache__/__init__.cpython-310.pyc

diff --git a/dsRag/ElasticSearch/Utils/ElasticsearchConnectionPool.py b/dsRag/ElasticSearch/Utils/ElasticsearchConnectionPool.py
index 9225792b..88a877fc 100644
--- a/dsRag/ElasticSearch/Utils/ElasticsearchConnectionPool.py
+++ b/dsRag/ElasticSearch/Utils/ElasticsearchConnectionPool.py
@@ -1,7 +1,4 @@
 from elasticsearch import Elasticsearch
-from elasticsearch.connection import create_connection
-from elasticsearch.connection_pool import ConnectionPool
-from elasticsearch.exceptions import ConnectionError
 import threading
 import logging
 
@@ -28,7 +25,7 @@ class ElasticsearchConnectionPool:
     def _initialize_pool(self):
         """初始化连接池"""
         for _ in range(self.max_connections):
-            self._connections.append(self._create_connection()
+            self._connections.append(self._create_connection())
 
     def _create_connection(self):
         """创建新的Elasticsearch连接"""
diff --git a/dsRag/ElasticSearch/Utils/__pycache__/ElasticsearchCollectionManager.cpython-310.pyc b/dsRag/ElasticSearch/Utils/__pycache__/ElasticsearchCollectionManager.cpython-310.pyc
new file mode 100644
index 0000000000000000000000000000000000000000..059711511b9f6f86065ee1d816861205a065ccb9
GIT binary patch
literal 3488
zcmb7H-)|g89p9P#d6zreaot}EffWeCk;pU>RA5yFsY$Cy#YMGH#3|~s-Wl8L?CoA>
z_ponuj!>F5F2p2=Hl@S~cA+GFXs85IDRI+R_!ssS_G~{z;(>=g*nDT^?tJG&3hZfS
zXJ@|iotf|V^Zm^CqH?*Y!1IsCUzvMxSW*7TKl&dPKE4kneg-O{5ELjiR7Hrlae!-T
zRTXVD(5f2M)^uvDqpJCWLNuaZP>B8-u3AK$QYywaXizFBE1wM9IPtxhy3Cv79g|V=
zeAEcZNyZ{J>2bOKr?-cvp_eLEM3gEfh~NuKRV6CX;0>!01Kv6*lL9GTKvjbrASLKA
zi3zI@WnUav_PHnssF(Or_yad|XDRb=-;%t|%X3g-ZlD%wDGr<-G~q@79YwqI<jdFd
zo4?2}T^&%r`Iq<djkh;%uWw#?BY*c+PkN&6GPh>?A)$*-=+@|j{eXG-m6gq#AN3|p
zf{luMQz|&qVj9da9rp2o!c2I5{?dtwGbBD8v9s{{A&chWaL{_$ojuc8U`m+#%#RX3
zh`W8#1^3xvyxz<#$MHiyahw9EkGV05dU|AFv-i*I&KWQ!cOSQ*Fy=fo(!(t@ugrr<
z=fRCDC_a>^YZ}4)`<g=3>*_iHtfj2!EyP==0Y+1uT2m6E`7NX@VWgx7V4g{|#A@N!
z&^6^c=F;audI_Jy3upmA*Eq{p@A%5jf4;W$>8H{;_cku&e>~s5vHGvSuH+y7CSSdk
zFTa~FU(4_Otta1c7mXb+3PXvPeIDET>_+>S@Aqbat90S2)HubRY^PtbNkn5ij1rqJ
z`f+m1_84^&Kb*Bgx*(yD9(vyO14`^9vV+Jaw%3E_ggsd)WG3kJJsM|*&=CvYXGRds
z0(3KT!DS&R%*u|?O~G}rc2+pK=+Qa{d8ShyTbUXstfDdljFOcHj+G%QkR&UM3k>tE
zz{$IjG6J3P7*tpvL1SnH89PJj7{bW<8Qw|9AA*g2%I<>*Us6D15*j?Zd1U(t;#wsJ
zyycg<iirh9B?ag!@)(D&@+wIBXbJBDtA)wX3V?(RL(Gmez6468bK6%x+WhT>fz3)l
zRIQp@uY(!mtXOAJowCFSi)%@<PNAlYNoGXTJg_qJENw1CjPOuQT$oUrX#@cWNkYS<
zg4yG+9D59^Oe1bWt0h9im^wd&$r0QBI}CJ$VBD|86)h_^V#>g8^+v)D@ri}RuhBSh
zYxQb@)}|>Tu(b~`<Dryk(-CP-f+r8~FGG4=fTH7F_6Q#^J15%bSq4n69EK8q0V=Fw
zWFU+UY#?n%+c8WFY5&2y+U{c`>9GMrJs{%y0XMnLDaqsL>OP!3dcl7eKGGMYZ)X+m
zF@8(5FuV=$BKX!vEuH&!$!KZpc*`J#Cjkpk_!~n}pH$Wq>333YX={iKt%DxWFwAFj
z0!Z+hN=8~nmk<CG8c>T4+77PZC9`FcQP2eCv@)d#LU{!U#S(;qflwX+La_!2Wo*eh
zX9+@iwDA<`Bb4@=H@DU=wLktizp~uEvI;=Dx3QdG`PKHt%SZFq|GfRy?fk=c?rpr;
z<A?vBQ93hTZBW*9dO(=4+rN8%>rd~=wf3u*yzYq0CI(Tlv;6Y;_S<{6N_QuVbv9vd
zeRi>Z=MP)!x3=!y%{MOZ*BAITKjBhu<=1X(-uX4KCa8i#?g=uQG+5YOOUm>{tEJdu
zem!wwFJcf((@_*;TCEW$>36&+_Cq=aD+Dg{ljhguuE*tpWyBn_kMvG{q+%bnkB>i9
zE%i%4BpPwlU>?m3sQ`L(AprwoafrC106@4r{gle45kiDfA_GoOD67S3fd}+BuTsr^
z>1CV8c->9r#EkUt$wlfl1ba&(+Y5d&XN!d<Z1!cbz?`4N>9D+T?HR%BlEw`n7#fmH
zkL!V-u(FW$!<h*7D6VG_!i*CwJIJe1s44})*CL{;!}8EQYh>jCUuPNxe`dOHm^`D!
zXk3qgeHf?i{Y>y}=sON2o`4D$v4*jR@Gkre!3Lj0t8DyR8+`(J9-|?Qca0rwccd_a
zhTzv@|F1rTC*&?Yo(psz&J{gs2;n0wbNYr*ML^yNLRD?4Jm@=Nikmi4_)laDYK!Lz
zn#>h`EHVTLWxe?{gtFGj4Gdx=W=k6gWqnCIr-@KD8&~-by17An?UVM(?NcXYT(z%W
zY_I>mH`oo9|2+}t%pj5H_yod2=sR^{Ph&4&#7O?e>-p_ZdZU0<!SmQBndwMirw30&
zUZVyVjKrKz?6fHIiW#0fPp0->5+P6miAP6%x@q%GRIE&$rHKR?cZEP88{(~fnA7(#
zml^U9?7Lj<0U*i_NKj5U;ix|Wp_t!%*c?GcR6?V0x%2_$8xH|WpQ;L;WM2bKux-dj
zdA960S<!K75orXxU2>dP8*U&+7{6-RqrBqR8{^1k&+>{V$bA)0G?)ezZ^R|hu#jb1
z<>FZBn_{F=sFrE}zZAw3;OY|tedDy7UB!$WGc$QQ#?!C@82Lq!nz8S}fV47Sv2Pb*
bQ+x-R^^82wvv9G<e;XyGge+9Vqw0SFjPL@i

literal 0
HcmV?d00001

diff --git a/dsRag/ElasticSearch/Utils/__pycache__/ElasticsearchConnectionPool.cpython-310.pyc b/dsRag/ElasticSearch/Utils/__pycache__/ElasticsearchConnectionPool.cpython-310.pyc
new file mode 100644
index 0000000000000000000000000000000000000000..2c77d6cb0573b0c90091426b9fc84ff0e3f8d74b
GIT binary patch
literal 2754
zcmai0|8EpU6rY*hz1usk$5B*N{IXyro)Qv>8f^$M;fp`mT+qf4FX(37S=xi`?sax+
z>E&uliV6tm4~kzX<Ss!F5~ao;L`mfT*kA3P?O$L-5Z{|^?;E7<W!}ur&b&A8^Lg*h
z`F(w90#9-Kd!v8pg#3XoosR-9uR#l50l^8UE*YamN^#6wR%EhQii)GuR7b1RV&Zke
z6|Np9T%BdbBxl1UuPwoDlBZGMUe^l3k{vjfuty6vPIo>nbGu;HAw|jwn8-<mw5V{6
zCytY%%9C7&UgIgAhCad9@C@`x-p8}h>wGO3T^DWavbNjzJjV`8zPI1^-F-_tz=W-J
zSjRDgwi{aTB8V!j5|dOJNLp1uvZ@MF86hCmP^%^CI7(JYO|KKcgo0T%p-@87#`4oR
zaiMYL)5hs@U1wRmb+LK&yXH@|*1Ey6C9E-H)DOa7(CAv+oIBGvRd0OrePeFEabc!+
z%llSPvQ29u933<kf4sDK{n)~-dh^)z=OzM2c-EM+)hJs*FzE}P@7?=>BT9#+OxqD?
zwfXh+#^;xpuAK%Q!^1<U>DSA>TgI%Trrm-Pcg@W-E?rsn=*#)m`a(VxY0{r4-9BTK
z>9iTG?NJwHI+aJMa8x)JFL@)8I^^3&BF%KM%b6vw6qYQvRB_BQ(3#gFHE`TR0!b7J
z6iE~i)8r}<YoWV6v}f=j4-WX^2z2{}e;A?xMsHao2bb|4mSK7D?XctqD|2zEb_dV4
z@>Hao@(iY#0^LCtL_$x{_?M;`S{djfu}8tmW*cIq^<ePf`DFkOz#xS1I!tHj9`bH_
z8iMgKt3epn)H<m{3XW^b0oM;pTXEJ3tpZ@83CkOCBnkr086~W8+3|SPZ`uHC=yaf+
zX9B&5s43x!MGj^}ABe}G1&C{w^;7j;W$UWm^{~_BC3@WQ@*#MMy+rSzDV&~BWEwpU
zpBg95H*WscJU9R6x5v8-#$M)?9=`LcKoEOouTtq*uUlyQDQE$fK*m&xzr@|jwk}J(
z#NCJ6ea>ObNeYWF0GG&T29-nx8$uwEQzS2@@c<MY&Qzk3S*RMra#c;MlivC5B-k<u
zyYTl8G+9-Z2|WG6&9g1a7tj9E`0U)mjhTfT*W$^_j`sNtOccX8I%-V>p~JTt(iO-p
z!*eDLyOq<0d_rVE^K!(v{s@Fnl$^AL2a5&57Aa-FEFQr{m|E>viLxV3*b!7);Hyjy
zoh4`*(j#|QR|oD?o?i{)ZWT5%y7J%!u?CvNcOC{3-!~`;WqQn_RE`j_9(q<&s}gJP
znM$Hc5mySxdIKs66H_lyGR-Kd<icc4=QK=J*(^OzE-+;00HDm-H2aWw56Ar^orKvo
zSIEHsy#s4+K7h4H;n+)`oN9jYd(2Ve{KXc7x1ZQ&m0X7#p>No(A2=Pn3>t-eS~3$U
zuH#91;?!Ob8Y4}vk5YS&+D;j-Ik5qz1zL-gAQX@+GQZPprX%X~^4BjM*Rg`m!mtfA
z1Q=>M%h4=lECbS@`V70r?qvUETJ|57-2C_Id2_$ouDn5BG3F$%AHzWM`f{8%Q2qv{
zspOEw9F8Y}LuKlP7KdsLieZ>|Fo)ytF9f+n4nZ%iC1Wk!Yyw+5AHbF@t{?rp^wkf|
zlQYe^lQC6dBb>32*V~CAo`e~JFtu?PSi_JQxK~!-R}p@(3D<R}j#Tg}%m<iZI!jXq
z*T@Re8MgU$Wz%X|Bk3>X**>Adez<($hQjOLG^4a>j`@7T#c{?o$0sZ|{vy`lIk3LV
zv=)!!Xfq1wP5XdyBrgMG3M*Wk)g(>zoUZBcWY!4$me->`r}JN4T#>QHMoFwCc$udl
m#fM~F5zoSh7%|-4fl13`r0<MRzYDJpS*<ffr#elue&s(gDBD8-

literal 0
HcmV?d00001

diff --git a/dsRag/ElasticSearch/__pycache__/__init__.cpython-310.pyc b/dsRag/ElasticSearch/__pycache__/__init__.cpython-310.pyc
new file mode 100644
index 0000000000000000000000000000000000000000..94ae6ce2baf4d4f283db992edbc385bb28d4e8c7
GIT binary patch
literal 144
zcmd1j<>g`kf+(K23=sVoL?8o3AjbiSi&=m~3PUi1CZpd<h9ZzKg7{_ZVil889G+j4
z4Wt5!^0QKtOMtAP#Pk@~oW$ai%;ezI#G>SknE3e2yv&mLc)fzkTO2mI`6;D2sdga4
KikW}}3j+WHkssOs

literal 0
HcmV?d00001