chore(deps): 升级依赖版本并优化ES客户端连接逻辑

- 升级部分包依赖
- 优化 logger 中的 ES 客户端初始化逻辑，支持多版本自动适配（es7,8,9）
- 移除 eureka.py 中无用的 pass 语句
- 更新 README.md 中的 Docker 镜像标签至 v2.7.6

Author: anjia0532

README.md

@@ -9,7 +9,7 @@ gateway等网关插件的高扩展性
 ### 通过docker运行
 
 ```bash
-docker run anjia0532/discovery-syncer-python:v2.7.5
+docker run anjia0532/discovery-syncer-python:v2.7.6
 ```
 
 特别的，`-c ` 支持配置远端http[s]的地址，比如读取静态资源的，比如读取nacos的

app/service/discovery/eureka.py

@@ -50,7 +50,6 @@ def modify_registration(self, registration: Registration, instances: List[Instan
             # PUT /eureka/v2/apps/appID/instanceID/status?value=OUT_OF_SERVICE
             self.eureka_execute(method="PUT", params={"value": eureka_status.get(instance.enabled, "UP")},
                                 uri=f"/{registration.service_name}/{instance.ext.get('instanceId')}/status")
-        pass
 
     def get_instances(self, instance_array: List, enabled_only: bool = True) -> List[Instance]:
 

core/lib/logger.py

@@ -194,12 +194,36 @@ def __init__(self, elastic_hosts: list, elastic_port, index_prefix='pylog-'):
         logging.Handler.__init__(self)
         from elasticsearch import Elasticsearch, helpers
         self._helpers = helpers
-        self._es_client = Elasticsearch(elastic_hosts, )
+        self._es_client = self.get_es_client(elastic_hosts, )
+
         self._index_prefix = index_prefix
         t = Thread(target=self._do_bulk_op)
         t.setDaemon(True)
         t.start()
 
+    def get_es_client(self, elastic_hosts):
+        from elasticsearch7 import Elasticsearch as Elasticsearch7
+        from elasticsearch8 import Elasticsearch as Elasticsearch8
+        from elasticsearch9 import Elasticsearch as Elasticsearch9
+
+        es_versions = [
+            (Elasticsearch9, "Elasticsearch 9"),
+            (Elasticsearch8, "Elasticsearch 8"),
+            (Elasticsearch7, "Elasticsearch 7")
+        ]
+
+        for es_class, version_name in es_versions:
+            try:
+                es_client = es_class(elastic_hosts)
+                # 测试连接
+                if es_client.info():
+                    very_nb_print(f"成功连接到 {version_name}")
+                    return es_client
+            except Exception as e:
+                very_nb_print(f"尝试连接 {version_name} 失败: {e}")
+
+        raise Exception(f"Unsupported ES version: {version}")
+
     @classmethod
     def __add_task_to_bulk(cls, task):
         cls.task_queue.put(task)

requirements.txt

@@ -1,7 +1,8 @@
-fastapi==0.117.1
+fastapi==0.121.1
 python-dotenv==1.1.1
 typing-extensions==4.15.0
-uvicorn[standard]==0.36.0
+uvicorn[standard]==0.38.0
+PyYAML==6.0.3
 pytest==8.4.2
 # pytest-cov==5.0.0
 # pytest-html==4.1.1
@@ -12,14 +13,16 @@ BeautifulReport==0.1.3
 # aiocache~=0.12.2
 # databases==0.9.0
 # asyncpg==0.29.0
-funboost==50.3
-pydantic-settings==2.10.1
+funboost==50.4
+pydantic-settings==2.12.0
 persist-queue[extra]
-db-libs==1.1
+db-libs==1.2
 nb-time
 pydantic-yaml==1.6.0
 cachetools==6.2.0
 async-timeout==5.0.1
 SQLAlchemy==2.0.43
-elasticsearch==8.19.1
+elasticsearch9
+elasticsearch8
+elasticsearch7
 PyMySQL==1.1.2