39def initialize():
40 global _CLIENT
41 if get_setting('redis.url'):
42 warnings.warn("setting redis.url is deprecated, use valkey.url", DeprecationWarning)
43 valkey_url = get_setting('valkey.url') or get_setting('redis.url')
44 if not valkey_url:
45 return False
46 try:
47
48 _CLIENT = valkey.Valkey.from_url(valkey_url)
49
50
51 kwargs = _CLIENT.get_connection_kwargs().copy()
52 kwargs.pop('password', None)
53 kwargs = ' '.join([f'{k}={v!r}' for k, v in kwargs.items()])
54 logger.info("connecting to Valkey %s", kwargs)
55
56
57 _CLIENT.ping()
58
59
60 logger.info("connected to Valkey")
61 return True
62 except valkey.exceptions.ValkeyError:
63 _CLIENT = None
64 _pw = pwd.getpwuid(os.getuid())
65 logger.exception("[%s (%s)] can't connect valkey DB ...", _pw.pw_name, _pw.pw_uid)
66 return False