BIDI_EXTRACTION_AI/BiddingKG/dl/common/source.py

# -*- 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", "")