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 00000000..05971151 Binary files /dev/null and b/dsRag/ElasticSearch/Utils/__pycache__/ElasticsearchCollectionManager.cpython-310.pyc differ 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 00000000..2c77d6cb Binary files /dev/null and b/dsRag/ElasticSearch/Utils/__pycache__/ElasticsearchConnectionPool.cpython-310.pyc differ diff --git a/dsRag/ElasticSearch/__pycache__/__init__.cpython-310.pyc b/dsRag/ElasticSearch/__pycache__/__init__.cpython-310.pyc new file mode 100644 index 00000000..94ae6ce2 Binary files /dev/null and b/dsRag/ElasticSearch/__pycache__/__init__.cpython-310.pyc differ