|
8 | 8 | MCP_HOST = os.getenv('MCP_HOST', '127.0.0.1')
|
9 | 9 | MCP_PORT = os.getenv('MCP_PORT', 8000)
|
10 | 10 |
|
11 |
| -REDIS_CFG = {"host": os.getenv('REDIS_HOST', '127.0.0.1'), |
12 |
| - "port": int(os.getenv('REDIS_PORT',6379)), |
13 |
| - "username": os.getenv('REDIS_USERNAME', None), |
14 |
| - "password": os.getenv('REDIS_PWD',''), |
15 |
| - "ssl": os.getenv('REDIS_SSL', False) in ('true', '1', 't'), |
16 |
| - "ssl_ca_path": os.getenv('REDIS_SSL_CA_PATH', None), |
17 |
| - "ssl_keyfile": os.getenv('REDIS_SSL_KEYFILE', None), |
18 |
| - "ssl_certfile": os.getenv('REDIS_SSL_CERTFILE', None), |
19 |
| - "ssl_cert_reqs": os.getenv('REDIS_SSL_CERT_REQS', 'required'), |
20 |
| - "ssl_ca_certs": os.getenv('REDIS_SSL_CA_CERTS', None), |
21 |
| - "cluster_mode": os.getenv('REDIS_CLUSTER_MODE', False) in ('true', '1', 't'), |
22 |
| - "db": int(os.getenv('REDIS_DB', 0))} |
| 11 | +def _load_redis_config(): |
| 12 | + """Load Redis configuration from environment variables.""" |
| 13 | + return {"host": os.getenv('REDIS_HOST', '127.0.0.1'), |
| 14 | + "port": int(os.getenv('REDIS_PORT',6379)), |
| 15 | + "username": os.getenv('REDIS_USERNAME', None), |
| 16 | + "password": os.getenv('REDIS_PWD',''), |
| 17 | + "ssl": os.getenv('REDIS_SSL', False) in ('true', '1', 't'), |
| 18 | + "ssl_ca_path": os.getenv('REDIS_SSL_CA_PATH', None), |
| 19 | + "ssl_keyfile": os.getenv('REDIS_SSL_KEYFILE', None), |
| 20 | + "ssl_certfile": os.getenv('REDIS_SSL_CERTFILE', None), |
| 21 | + "ssl_cert_reqs": os.getenv('REDIS_SSL_CERT_REQS', 'required'), |
| 22 | + "ssl_ca_certs": os.getenv('REDIS_SSL_CA_CERTS', None), |
| 23 | + "cluster_mode": os.getenv('REDIS_CLUSTER_MODE', False) in ('true', '1', 't'), |
| 24 | + "db": int(os.getenv('REDIS_DB', 0))} |
| 25 | + |
| 26 | +REDIS_CFG = _load_redis_config() |
| 27 | + |
| 28 | + |
| 29 | +def reload_redis_config(): |
| 30 | + """Reload Redis configuration from environment variables.""" |
| 31 | + global REDIS_CFG |
| 32 | + REDIS_CFG = _load_redis_config() |
23 | 33 |
|
24 | 34 |
|
25 | 35 | def parse_redis_uri(uri: str) -> dict:
|
@@ -104,3 +114,4 @@ def set_redis_env_from_config(config: dict):
|
104 | 114 | if isinstance(value, bool):
|
105 | 115 | value = 'true' if value else 'false'
|
106 | 116 | os.environ[env_var] = str(value)
|
| 117 | + print(f"Setting {env_var} to {value}") |
0 commit comments