# -*- coding: utf-8 -*- """Redis 连接(向后兼容 re-export 层)。 Phase 1 重构后真实实现在 BiddingKG.dl.infra.redis。 本模块保留原函数名 getConnect_redis_baseline / getConnect_redis_error_att, 保证老代码无需改动即可运行。 原硬编码: REDIS_HOST = "127.0.0.1" / "192.168.0.115" REDIS_PASS = "daf!#@#fdasf234" 已移除,改走 config/redis.yaml + 环境变量。 anchor_file 探测逻辑不再需要,由环境变量 BIDDINGKG_REDIS_HOST 覆盖即可。 """ from __future__ import absolute_import from BiddingKG.dl.infra.redis import ( get_baseline_redis as _get_baseline_redis, get_error_att_redis as _get_error_att_redis, redis_main_config as _redis_main_config, ) __all__ = [ "getConnect_redis_baseline", "getConnect_redis_error_att", "REDIS_HOST", "REDIS_PORT", "REDIS_PASS", ] def getConnect_redis_baseline(): """原 common/source.py::getConnect_redis_baseline,db=6。""" return _get_baseline_redis() def getConnect_redis_error_att(): """原 common/source.py::getConnect_redis_error_att,db=10。""" return _get_error_att_redis() # ===== 向后兼容:保留模块级变量名 ===== _main = _redis_main_config() REDIS_HOST = _main.get("host", "127.0.0.1") REDIS_PORT = int(_main.get("port", 6379)) REDIS_PASS = _main.get("password", "")