From 85047c5701a338d0730772397d7ef41231980fde Mon Sep 17 00:00:00 2001 From: HuangHai <10402852@qq.com> Date: Fri, 11 Jul 2025 16:01:32 +0800 Subject: [PATCH] 'commit' --- dsLightRag/Logs/Log.txt | 464 +++++++++++++++++++++++++++++++++++++ dsLightRag/Test/testPg2.py | 59 ++--- dsLightRag/Test/testPg3.py | 89 +++++++ 3 files changed, 568 insertions(+), 44 deletions(-) create mode 100644 dsLightRag/Logs/Log.txt create mode 100644 dsLightRag/Test/testPg3.py diff --git a/dsLightRag/Logs/Log.txt b/dsLightRag/Logs/Log.txt new file mode 100644 index 00000000..44841e95 --- /dev/null +++ b/dsLightRag/Logs/Log.txt @@ -0,0 +1,464 @@ + +Hybrid Query Time: 62.383761167526245 seconds +2025-07-11 15:38:18,442 - asyncio - ERROR - Fatal error on SSL transport +protocol: +transport: <_ProactorSocketTransport fd=4180 read=<_OverlappedFuture cancelled>> +Traceback (most recent call last): + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 690, in _process_write_backlog + self._transport.write(chunk) + File "D:\anaconda3\envs\py310\lib\asyncio\proactor_events.py", line 365, in write + self._loop_writing(data=bytes(data)) + File "D:\anaconda3\envs\py310\lib\asyncio\proactor_events.py", line 401, in _loop_writing + self._write_fut = self._loop._proactor.send(self._sock, data) +AttributeError: 'NoneType' object has no attribute 'send' +Exception ignored in: +Traceback (most recent call last): + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 321, in __del__ + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 316, in close + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 599, in _start_shutdown + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 604, in _write_appdata + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 712, in _process_write_backlog + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 726, in _fatal_error + File "D:\anaconda3\envs\py310\lib\asyncio\proactor_events.py", line 152, in _force_close + File "D:\anaconda3\envs\py310\lib\asyncio\base_events.py", line 753, in call_soon + File "D:\anaconda3\envs\py310\lib\asyncio\base_events.py", line 515, in _check_closed +RuntimeError: Event loop is closed +2025-07-11 15:38:18,444 - asyncio - ERROR - Fatal error on SSL transport +protocol: +transport: <_ProactorSocketTransport fd=4044 read=<_OverlappedFuture cancelled>> +Traceback (most recent call last): + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 690, in _process_write_backlog + self._transport.write(chunk) + File "D:\anaconda3\envs\py310\lib\asyncio\proactor_events.py", line 365, in write + self._loop_writing(data=bytes(data)) + File "D:\anaconda3\envs\py310\lib\asyncio\proactor_events.py", line 401, in _loop_writing + self._write_fut = self._loop._proactor.send(self._sock, data) +AttributeError: 'NoneType' object has no attribute 'send' +Exception ignored in: +Traceback (most recent call last): + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 321, in __del__ + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 316, in close + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 599, in _start_shutdown + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 604, in _write_appdata + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 712, in _process_write_backlog + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 726, in _fatal_error + File "D:\anaconda3\envs\py310\lib\asyncio\proactor_events.py", line 152, in _force_close + File "D:\anaconda3\envs\py310\lib\asyncio\base_events.py", line 753, in call_soon + File "D:\anaconda3\envs\py310\lib\asyncio\base_events.py", line 515, in _check_closed +RuntimeError: Event loop is closed +2025-07-11 15:38:18,444 - asyncio - ERROR - Fatal error on SSL transport +protocol: +transport: <_ProactorSocketTransport fd=4232 read=<_OverlappedFuture cancelled>> +Traceback (most recent call last): + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 690, in _process_write_backlog + self._transport.write(chunk) + File "D:\anaconda3\envs\py310\lib\asyncio\proactor_events.py", line 365, in write + self._loop_writing(data=bytes(data)) + File "D:\anaconda3\envs\py310\lib\asyncio\proactor_events.py", line 401, in _loop_writing + self._write_fut = self._loop._proactor.send(self._sock, data) +AttributeError: 'NoneType' object has no attribute 'send' +Exception ignored in: +Traceback (most recent call last): + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 321, in __del__ + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 316, in close + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 599, in _start_shutdown + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 604, in _write_appdata + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 712, in _process_write_backlog + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 726, in _fatal_error + File "D:\anaconda3\envs\py310\lib\asyncio\proactor_events.py", line 152, in _force_close + File "D:\anaconda3\envs\py310\lib\asyncio\base_events.py", line 753, in call_soon + File "D:\anaconda3\envs\py310\lib\asyncio\base_events.py", line 515, in _check_closed +RuntimeError: Event loop is closed +2025-07-11 15:38:18,445 - asyncio - ERROR - Fatal error on SSL transport +protocol: +transport: <_ProactorSocketTransport fd=2452 read=<_OverlappedFuture cancelled>> +Traceback (most recent call last): + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 690, in _process_write_backlog + self._transport.write(chunk) + File "D:\anaconda3\envs\py310\lib\asyncio\proactor_events.py", line 365, in write + self._loop_writing(data=bytes(data)) + File "D:\anaconda3\envs\py310\lib\asyncio\proactor_events.py", line 401, in _loop_writing + self._write_fut = self._loop._proactor.send(self._sock, data) +AttributeError: 'NoneType' object has no attribute 'send' +Exception ignored in: +Traceback (most recent call last): + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 321, in __del__ + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 316, in close + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 599, in _start_shutdown + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 604, in _write_appdata + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 712, in _process_write_backlog + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 726, in _fatal_error + File "D:\anaconda3\envs\py310\lib\asyncio\proactor_events.py", line 152, in _force_close + File "D:\anaconda3\envs\py310\lib\asyncio\base_events.py", line 753, in call_soon + File "D:\anaconda3\envs\py310\lib\asyncio\base_events.py", line 515, in _check_closed +RuntimeError: Event loop is closed +2025-07-11 15:38:18,446 - asyncio - ERROR - Fatal error on SSL transport +protocol: +transport: <_ProactorSocketTransport fd=4212 read=<_OverlappedFuture cancelled>> +Traceback (most recent call last): + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 690, in _process_write_backlog + self._transport.write(chunk) + File "D:\anaconda3\envs\py310\lib\asyncio\proactor_events.py", line 365, in write + self._loop_writing(data=bytes(data)) + File "D:\anaconda3\envs\py310\lib\asyncio\proactor_events.py", line 401, in _loop_writing + self._write_fut = self._loop._proactor.send(self._sock, data) +AttributeError: 'NoneType' object has no attribute 'send' +Exception ignored in: +Traceback (most recent call last): + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 321, in __del__ + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 316, in close + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 599, in _start_shutdown + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 604, in _write_appdata + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 712, in _process_write_backlog + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 726, in _fatal_error + File "D:\anaconda3\envs\py310\lib\asyncio\proactor_events.py", line 152, in _force_close + File "D:\anaconda3\envs\py310\lib\asyncio\base_events.py", line 753, in call_soon + File "D:\anaconda3\envs\py310\lib\asyncio\base_events.py", line 515, in _check_closed +RuntimeError: Event loop is closed +2025-07-11 15:38:18,447 - asyncio - ERROR - Fatal error on SSL transport +protocol: +transport: <_ProactorSocketTransport fd=3912 read=<_OverlappedFuture cancelled>> +Traceback (most recent call last): + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 690, in _process_write_backlog + self._transport.write(chunk) + File "D:\anaconda3\envs\py310\lib\asyncio\proactor_events.py", line 365, in write + self._loop_writing(data=bytes(data)) + File "D:\anaconda3\envs\py310\lib\asyncio\proactor_events.py", line 401, in _loop_writing + self._write_fut = self._loop._proactor.send(self._sock, data) +AttributeError: 'NoneType' object has no attribute 'send' +Exception ignored in: +Traceback (most recent call last): + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 321, in __del__ + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 316, in close + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 599, in _start_shutdown + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 604, in _write_appdata + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 712, in _process_write_backlog + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 726, in _fatal_error + File "D:\anaconda3\envs\py310\lib\asyncio\proactor_events.py", line 152, in _force_close + File "D:\anaconda3\envs\py310\lib\asyncio\base_events.py", line 753, in call_soon + File "D:\anaconda3\envs\py310\lib\asyncio\base_events.py", line 515, in _check_closed +RuntimeError: Event loop is closed +2025-07-11 15:38:18,460 - asyncio - ERROR - Fatal error on SSL transport +protocol: +transport: <_ProactorSocketTransport fd=3676 read=<_OverlappedFuture cancelled>> +Traceback (most recent call last): + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 690, in _process_write_backlog + self._transport.write(chunk) + File "D:\anaconda3\envs\py310\lib\asyncio\proactor_events.py", line 365, in write + self._loop_writing(data=bytes(data)) + File "D:\anaconda3\envs\py310\lib\asyncio\proactor_events.py", line 401, in _loop_writing + self._write_fut = self._loop._proactor.send(self._sock, data) +AttributeError: 'NoneType' object has no attribute 'send' +Exception ignored in: +Traceback (most recent call last): + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 321, in __del__ + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 316, in close + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 599, in _start_shutdown + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 604, in _write_appdata + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 712, in _process_write_backlog + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 726, in _fatal_error + File "D:\anaconda3\envs\py310\lib\asyncio\proactor_events.py", line 152, in _force_close + File "D:\anaconda3\envs\py310\lib\asyncio\base_events.py", line 753, in call_soon + File "D:\anaconda3\envs\py310\lib\asyncio\base_events.py", line 515, in _check_closed +RuntimeError: Event loop is closed +2025-07-11 15:38:18,460 - asyncio - ERROR - Fatal error on SSL transport +protocol: +transport: <_ProactorSocketTransport fd=3828 read=<_OverlappedFuture cancelled>> +Traceback (most recent call last): + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 690, in _process_write_backlog + self._transport.write(chunk) + File "D:\anaconda3\envs\py310\lib\asyncio\proactor_events.py", line 365, in write + self._loop_writing(data=bytes(data)) + File "D:\anaconda3\envs\py310\lib\asyncio\proactor_events.py", line 401, in _loop_writing + self._write_fut = self._loop._proactor.send(self._sock, data) +AttributeError: 'NoneType' object has no attribute 'send' +Exception ignored in: +Traceback (most recent call last): + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 321, in __del__ + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 316, in close + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 599, in _start_shutdown + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 604, in _write_appdata + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 712, in _process_write_backlog + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 726, in _fatal_error + File "D:\anaconda3\envs\py310\lib\asyncio\proactor_events.py", line 152, in _force_close + File "D:\anaconda3\envs\py310\lib\asyncio\base_events.py", line 753, in call_soon + File "D:\anaconda3\envs\py310\lib\asyncio\base_events.py", line 515, in _check_closed +RuntimeError: Event loop is closed +2025-07-11 15:38:18,462 - asyncio - ERROR - Fatal error on SSL transport +protocol: +transport: <_ProactorSocketTransport fd=4240 read=<_OverlappedFuture cancelled>> +Traceback (most recent call last): + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 690, in _process_write_backlog + self._transport.write(chunk) + File "D:\anaconda3\envs\py310\lib\asyncio\proactor_events.py", line 365, in write + self._loop_writing(data=bytes(data)) + File "D:\anaconda3\envs\py310\lib\asyncio\proactor_events.py", line 401, in _loop_writing + self._write_fut = self._loop._proactor.send(self._sock, data) +AttributeError: 'NoneType' object has no attribute 'send' +Exception ignored in: +Traceback (most recent call last): + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 321, in __del__ + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 316, in close + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 599, in _start_shutdown + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 604, in _write_appdata + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 712, in _process_write_backlog + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 726, in _fatal_error + File "D:\anaconda3\envs\py310\lib\asyncio\proactor_events.py", line 152, in _force_close + File "D:\anaconda3\envs\py310\lib\asyncio\base_events.py", line 753, in call_soon + File "D:\anaconda3\envs\py310\lib\asyncio\base_events.py", line 515, in _check_closed +RuntimeError: Event loop is closed +2025-07-11 15:38:18,478 - asyncio - ERROR - Fatal error on SSL transport +protocol: +transport: <_ProactorSocketTransport fd=4244 read=<_OverlappedFuture cancelled>> +Traceback (most recent call last): + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 690, in _process_write_backlog + self._transport.write(chunk) + File "D:\anaconda3\envs\py310\lib\asyncio\proactor_events.py", line 365, in write + self._loop_writing(data=bytes(data)) + File "D:\anaconda3\envs\py310\lib\asyncio\proactor_events.py", line 401, in _loop_writing + self._write_fut = self._loop._proactor.send(self._sock, data) +AttributeError: 'NoneType' object has no attribute 'send' +Exception ignored in: +Traceback (most recent call last): + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 321, in __del__ + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 316, in close + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 599, in _start_shutdown + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 604, in _write_appdata + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 712, in _process_write_backlog + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 726, in _fatal_error + File "D:\anaconda3\envs\py310\lib\asyncio\proactor_events.py", line 152, in _force_close + File "D:\anaconda3\envs\py310\lib\asyncio\base_events.py", line 753, in call_soon + File "D:\anaconda3\envs\py310\lib\asyncio\base_events.py", line 515, in _check_closed +RuntimeError: Event loop is closed +2025-07-11 15:38:18,480 - asyncio - ERROR - Fatal error on SSL transport +protocol: +transport: <_ProactorSocketTransport fd=4248 read=<_OverlappedFuture cancelled>> +Traceback (most recent call last): + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 690, in _process_write_backlog + self._transport.write(chunk) + File "D:\anaconda3\envs\py310\lib\asyncio\proactor_events.py", line 365, in write + self._loop_writing(data=bytes(data)) + File "D:\anaconda3\envs\py310\lib\asyncio\proactor_events.py", line 401, in _loop_writing + self._write_fut = self._loop._proactor.send(self._sock, data) +AttributeError: 'NoneType' object has no attribute 'send' +Exception ignored in: +Traceback (most recent call last): + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 321, in __del__ + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 316, in close + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 599, in _start_shutdown + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 604, in _write_appdata + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 712, in _process_write_backlog + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 726, in _fatal_error + File "D:\anaconda3\envs\py310\lib\asyncio\proactor_events.py", line 152, in _force_close + File "D:\anaconda3\envs\py310\lib\asyncio\base_events.py", line 753, in call_soon + File "D:\anaconda3\envs\py310\lib\asyncio\base_events.py", line 515, in _check_closed +RuntimeError: Event loop is closed +2025-07-11 15:38:18,493 - asyncio - ERROR - Fatal error on SSL transport +protocol: +transport: <_ProactorSocketTransport fd=4252 read=<_OverlappedFuture cancelled>> +Traceback (most recent call last): + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 690, in _process_write_backlog + self._transport.write(chunk) + File "D:\anaconda3\envs\py310\lib\asyncio\proactor_events.py", line 365, in write + self._loop_writing(data=bytes(data)) + File "D:\anaconda3\envs\py310\lib\asyncio\proactor_events.py", line 401, in _loop_writing + self._write_fut = self._loop._proactor.send(self._sock, data) +AttributeError: 'NoneType' object has no attribute 'send' +Exception ignored in: +Traceback (most recent call last): + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 321, in __del__ + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 316, in close + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 599, in _start_shutdown + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 604, in _write_appdata + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 712, in _process_write_backlog + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 726, in _fatal_error + File "D:\anaconda3\envs\py310\lib\asyncio\proactor_events.py", line 152, in _force_close + File "D:\anaconda3\envs\py310\lib\asyncio\base_events.py", line 753, in call_soon + File "D:\anaconda3\envs\py310\lib\asyncio\base_events.py", line 515, in _check_closed +RuntimeError: Event loop is closed +2025-07-11 15:38:18,495 - asyncio - ERROR - Fatal error on SSL transport +protocol: +transport: <_ProactorSocketTransport fd=4256 read=<_OverlappedFuture cancelled>> +Traceback (most recent call last): + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 690, in _process_write_backlog + self._transport.write(chunk) + File "D:\anaconda3\envs\py310\lib\asyncio\proactor_events.py", line 365, in write + self._loop_writing(data=bytes(data)) + File "D:\anaconda3\envs\py310\lib\asyncio\proactor_events.py", line 401, in _loop_writing + self._write_fut = self._loop._proactor.send(self._sock, data) +AttributeError: 'NoneType' object has no attribute 'send' +Exception ignored in: +Traceback (most recent call last): + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 321, in __del__ + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 316, in close + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 599, in _start_shutdown + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 604, in _write_appdata + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 712, in _process_write_backlog + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 726, in _fatal_error + File "D:\anaconda3\envs\py310\lib\asyncio\proactor_events.py", line 152, in _force_close + File "D:\anaconda3\envs\py310\lib\asyncio\base_events.py", line 753, in call_soon + File "D:\anaconda3\envs\py310\lib\asyncio\base_events.py", line 515, in _check_closed +RuntimeError: Event loop is closed +2025-07-11 15:38:18,497 - asyncio - ERROR - Fatal error on SSL transport +protocol: +transport: <_ProactorSocketTransport fd=4264 read=<_OverlappedFuture cancelled>> +Traceback (most recent call last): + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 690, in _process_write_backlog + self._transport.write(chunk) + File "D:\anaconda3\envs\py310\lib\asyncio\proactor_events.py", line 365, in write + self._loop_writing(data=bytes(data)) + File "D:\anaconda3\envs\py310\lib\asyncio\proactor_events.py", line 401, in _loop_writing + self._write_fut = self._loop._proactor.send(self._sock, data) +AttributeError: 'NoneType' object has no attribute 'send' +Exception ignored in: +Traceback (most recent call last): + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 321, in __del__ + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 316, in close + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 599, in _start_shutdown + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 604, in _write_appdata + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 712, in _process_write_backlog + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 726, in _fatal_error + File "D:\anaconda3\envs\py310\lib\asyncio\proactor_events.py", line 152, in _force_close + File "D:\anaconda3\envs\py310\lib\asyncio\base_events.py", line 753, in call_soon + File "D:\anaconda3\envs\py310\lib\asyncio\base_events.py", line 515, in _check_closed +RuntimeError: Event loop is closed +2025-07-11 15:38:18,508 - asyncio - ERROR - Fatal error on SSL transport +protocol: +transport: <_ProactorSocketTransport fd=4268 read=<_OverlappedFuture cancelled>> +Traceback (most recent call last): + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 690, in _process_write_backlog + self._transport.write(chunk) + File "D:\anaconda3\envs\py310\lib\asyncio\proactor_events.py", line 365, in write + self._loop_writing(data=bytes(data)) + File "D:\anaconda3\envs\py310\lib\asyncio\proactor_events.py", line 401, in _loop_writing + self._write_fut = self._loop._proactor.send(self._sock, data) +AttributeError: 'NoneType' object has no attribute 'send' +Exception ignored in: +Traceback (most recent call last): + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 321, in __del__ + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 316, in close + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 599, in _start_shutdown + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 604, in _write_appdata + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 712, in _process_write_backlog + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 726, in _fatal_error + File "D:\anaconda3\envs\py310\lib\asyncio\proactor_events.py", line 152, in _force_close + File "D:\anaconda3\envs\py310\lib\asyncio\base_events.py", line 753, in call_soon + File "D:\anaconda3\envs\py310\lib\asyncio\base_events.py", line 515, in _check_closed +RuntimeError: Event loop is closed +2025-07-11 15:38:18,511 - asyncio - ERROR - Fatal error on SSL transport +protocol: +transport: <_ProactorSocketTransport fd=4272 read=<_OverlappedFuture cancelled>> +Traceback (most recent call last): + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 690, in _process_write_backlog + self._transport.write(chunk) + File "D:\anaconda3\envs\py310\lib\asyncio\proactor_events.py", line 365, in write + self._loop_writing(data=bytes(data)) + File "D:\anaconda3\envs\py310\lib\asyncio\proactor_events.py", line 401, in _loop_writing + self._write_fut = self._loop._proactor.send(self._sock, data) +AttributeError: 'NoneType' object has no attribute 'send' +Exception ignored in: +Traceback (most recent call last): + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 321, in __del__ + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 316, in close + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 599, in _start_shutdown + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 604, in _write_appdata + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 712, in _process_write_backlog + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 726, in _fatal_error + File "D:\anaconda3\envs\py310\lib\asyncio\proactor_events.py", line 152, in _force_close + File "D:\anaconda3\envs\py310\lib\asyncio\base_events.py", line 753, in call_soon + File "D:\anaconda3\envs\py310\lib\asyncio\base_events.py", line 515, in _check_closed +RuntimeError: Event loop is closed +2025-07-11 15:38:18,513 - asyncio - ERROR - Fatal error on SSL transport +protocol: +transport: <_ProactorSocketTransport fd=4276 read=<_OverlappedFuture cancelled>> +Traceback (most recent call last): + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 690, in _process_write_backlog + self._transport.write(chunk) + File "D:\anaconda3\envs\py310\lib\asyncio\proactor_events.py", line 365, in write + self._loop_writing(data=bytes(data)) + File "D:\anaconda3\envs\py310\lib\asyncio\proactor_events.py", line 401, in _loop_writing + self._write_fut = self._loop._proactor.send(self._sock, data) +AttributeError: 'NoneType' object has no attribute 'send' +Exception ignored in: +Traceback (most recent call last): + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 321, in __del__ + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 316, in close + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 599, in _start_shutdown + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 604, in _write_appdata + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 712, in _process_write_backlog + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 726, in _fatal_error + File "D:\anaconda3\envs\py310\lib\asyncio\proactor_events.py", line 152, in _force_close + File "D:\anaconda3\envs\py310\lib\asyncio\base_events.py", line 753, in call_soon + File "D:\anaconda3\envs\py310\lib\asyncio\base_events.py", line 515, in _check_closed +RuntimeError: Event loop is closed +2025-07-11 15:38:18,525 - asyncio - ERROR - Fatal error on SSL transport +protocol: +transport: <_ProactorSocketTransport fd=4284 read=<_OverlappedFuture cancelled>> +Traceback (most recent call last): + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 690, in _process_write_backlog + self._transport.write(chunk) + File "D:\anaconda3\envs\py310\lib\asyncio\proactor_events.py", line 365, in write + self._loop_writing(data=bytes(data)) + File "D:\anaconda3\envs\py310\lib\asyncio\proactor_events.py", line 401, in _loop_writing + self._write_fut = self._loop._proactor.send(self._sock, data) +AttributeError: 'NoneType' object has no attribute 'send' +Exception ignored in: +Traceback (most recent call last): + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 321, in __del__ + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 316, in close + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 599, in _start_shutdown + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 604, in _write_appdata + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 712, in _process_write_backlog + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 726, in _fatal_error + File "D:\anaconda3\envs\py310\lib\asyncio\proactor_events.py", line 152, in _force_close + File "D:\anaconda3\envs\py310\lib\asyncio\base_events.py", line 753, in call_soon + File "D:\anaconda3\envs\py310\lib\asyncio\base_events.py", line 515, in _check_closed +RuntimeError: Event loop is closed +2025-07-11 15:38:18,527 - asyncio - ERROR - Fatal error on SSL transport +protocol: +transport: <_ProactorSocketTransport fd=4288 read=<_OverlappedFuture cancelled>> +Traceback (most recent call last): + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 690, in _process_write_backlog + self._transport.write(chunk) + File "D:\anaconda3\envs\py310\lib\asyncio\proactor_events.py", line 365, in write + self._loop_writing(data=bytes(data)) + File "D:\anaconda3\envs\py310\lib\asyncio\proactor_events.py", line 401, in _loop_writing + self._write_fut = self._loop._proactor.send(self._sock, data) +AttributeError: 'NoneType' object has no attribute 'send' +Exception ignored in: +Traceback (most recent call last): + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 321, in __del__ + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 316, in close + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 599, in _start_shutdown + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 604, in _write_appdata + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 712, in _process_write_backlog + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 726, in _fatal_error + File "D:\anaconda3\envs\py310\lib\asyncio\proactor_events.py", line 152, in _force_close + File "D:\anaconda3\envs\py310\lib\asyncio\base_events.py", line 753, in call_soon + File "D:\anaconda3\envs\py310\lib\asyncio\base_events.py", line 515, in _check_closed +RuntimeError: Event loop is closed +2025-07-11 15:38:18,528 - asyncio - ERROR - Fatal error on SSL transport +protocol: +transport: <_ProactorSocketTransport fd=4292 read=<_OverlappedFuture cancelled>> +Traceback (most recent call last): + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 690, in _process_write_backlog + self._transport.write(chunk) + File "D:\anaconda3\envs\py310\lib\asyncio\proactor_events.py", line 365, in write + self._loop_writing(data=bytes(data)) + File "D:\anaconda3\envs\py310\lib\asyncio\proactor_events.py", line 401, in _loop_writing + self._write_fut = self._loop._proactor.send(self._sock, data) +AttributeError: 'NoneType' object has no attribute 'send' +Exception ignored in: +Traceback (most recent call last): + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 321, in __del__ + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 316, in close + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 599, in _start_shutdown + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 604, in _write_appdata + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 712, in _process_write_backlog + File "D:\anaconda3\envs\py310\lib\asyncio\sslproto.py", line 726, in _fatal_error + File "D:\anaconda3\envs\py310\lib\asyncio\proactor_events.py", line 152, in _force_close + File "D:\anaconda3\envs\py310\lib\asyncio\base_events.py", line 753, in call_soon + File "D:\anaconda3\envs\py310\lib\asyncio\base_events.py", line 515, in _check_closed +RuntimeError: Event loop is closed + +进程已结束，退出代码为 0 diff --git a/dsLightRag/Test/testPg2.py b/dsLightRag/Test/testPg2.py index f457ca94..298cd0f6 100644 --- a/dsLightRag/Test/testPg2.py +++ b/dsLightRag/Test/testPg2.py @@ -2,8 +2,6 @@ import asyncio import logging import os import time -from dotenv import load_dotenv - from lightrag import LightRAG, QueryParam from lightrag.utils import EmbeddingFunc from lightrag.kg.shared_storage import initialize_pipeline_status @@ -11,7 +9,6 @@ from lightrag.kg.shared_storage import initialize_pipeline_status from Config.Config import EMBED_DIM, EMBED_MAX_TOKEN_SIZE, LLM_MODEL_NAME from Util.LightRagUtil import embedding_func, llm_model_func -load_dotenv() # 在程序开始时添加以下配置 logging.basicConfig( @@ -36,7 +33,6 @@ if not os.path.exists(WORKING_DIR): # AGE os.environ["AGE_GRAPH_NAME"] = "dickens" - os.environ["POSTGRES_HOST"] = "10.10.14.208" os.environ["POSTGRES_PORT"] = "5432" os.environ["POSTGRES_USER"] = "postgres" @@ -71,51 +67,26 @@ async def initialize_rag(): async def main(): - # Initialize RAG instance - rag = await initialize_rag() + try: + rag = await initialize_rag() - # add embedding_func for graph database, it's deleted in commit 5661d76860436f7bf5aef2e50d9ee4a59660146c - rag.chunk_entity_relation_graph.embedding_func = rag.embedding_func + #with open(f"{ROOT_DIR}/book.txt", "r", encoding="utf-8") as f: + # await rag.ainsert(f.read()) - with open(f"{ROOT_DIR}/book.txt", "r", encoding="utf-8") as f: - await rag.ainsert(f.read()) - - print("==== Trying to test the rag queries ====") - print("**** Start Naive Query ****") - start_time = time.time() - # Perform naive search - print( + print("==== Trying to test the rag queries ====") + print("**** Start Naive Query ****") + start_time = time.time() + # Perform naive search await rag.aquery( "What are the top themes in this story?", param=QueryParam(mode="naive") ) - ) - print(f"Naive Query Time: {time.time() - start_time} seconds") - # Perform local search - print("**** Start Local Query ****") - start_time = time.time() - print( - await rag.aquery( - "What are the top themes in this story?", param=QueryParam(mode="local") - ) - ) - print(f"Local Query Time: {time.time() - start_time} seconds") - # Perform global search - print("**** Start Global Query ****") - start_time = time.time() - print( - await rag.aquery( - "What are the top themes in this story?", param=QueryParam(mode="global") - ) - ) - print(f"Global Query Time: {time.time() - start_time}") - # Perform hybrid search - print("**** Start Hybrid Query ****") - print( - await rag.aquery( - "What are the top themes in this story?", param=QueryParam(mode="hybrid") - ) - ) - print(f"Hybrid Query Time: {time.time() - start_time} seconds") + print(f"Naive Query Time: {time.time() - start_time} seconds") + except Exception as e: + #logger.error(f"Main execution error: {e}") + pass + finally: + # 确保所有资源正确释放 + await asyncio.sleep(0.1) # 给pending任务完成的时间 if __name__ == "__main__": diff --git a/dsLightRag/Test/testPg3.py b/dsLightRag/Test/testPg3.py new file mode 100644 index 00000000..31806422 --- /dev/null +++ b/dsLightRag/Test/testPg3.py @@ -0,0 +1,89 @@ +import asyncio +import inspect +import logging +import os + +from lightrag.kg.shared_storage import initialize_pipeline_status +from lightrag.utils import EmbeddingFunc + +from Config.Config import LLM_MODEL_NAME, EMBED_DIM, EMBED_MAX_TOKEN_SIZE +from Util.LightRagUtil import configure_logging, initialize_rag, print_stream, llm_model_func, embedding_func +from lightrag import QueryParam, LightRAG + +# 在程序开始时添加以下配置 +logging.basicConfig( + level=logging.INFO, # 设置日志级别为INFO + format='%(asctime)s - %(name)s - %(levelname)s - %(message)s' +) + +# 或者如果你想更详细地控制日志输出 +logger = logging.getLogger('lightrag') +logger.setLevel(logging.INFO) +handler = logging.StreamHandler() +handler.setFormatter(logging.Formatter('%(asctime)s - %(name)s - %(levelname)s - %(message)s')) +logger.addHandler(handler) + +ROOT_DIR = '.' +WORKING_DIR = f"{ROOT_DIR}/dickens-pg" + +logging.basicConfig(format="%(levelname)s:%(message)s", level=logging.INFO) + +if not os.path.exists(WORKING_DIR): + os.mkdir(WORKING_DIR) + +# AGE +os.environ["AGE_GRAPH_NAME"] = "dickens" +os.environ["POSTGRES_HOST"] = "10.10.14.208" +os.environ["POSTGRES_PORT"] = "5432" +os.environ["POSTGRES_USER"] = "postgres" +os.environ["POSTGRES_PASSWORD"] = "postgres" +os.environ["POSTGRES_DATABASE"] = "rag" + + +async def initialize_rag(): + rag = LightRAG( + working_dir=WORKING_DIR, + llm_model_func=llm_model_func, + llm_model_name=LLM_MODEL_NAME, + llm_model_max_async=4, + llm_model_max_token_size=32768, + enable_llm_cache_for_entity_extract=True, + embedding_func=EmbeddingFunc( + embedding_dim=EMBED_DIM, + max_token_size=EMBED_MAX_TOKEN_SIZE, + func=embedding_func + ), + kv_storage="PGKVStorage", + doc_status_storage="PGDocStatusStorage", + graph_storage="PGGraphStorage", + vector_storage="PGVectorStorage", + auto_manage_storages_states=False, + ) + + await rag.initialize_storages() + await initialize_pipeline_status() + + return rag + +async def main(): + try: + rag = await initialize_rag() + resp = await rag.aquery( + "What are the top themes in this story", + param=QueryParam(mode="hybrid", stream=True), + # hybrid naive + ) + if inspect.isasyncgen(resp): + await print_stream(resp) + else: + print(resp) + except Exception as e: + print(f"An error occurred: {e}") + finally: + if rag: + await rag.finalize_storages() + + +if __name__ == "__main__": + configure_logging() + asyncio.run(main())