diff options
author | Markus Heiser <markus.heiser@darmarit.de> | 2022-01-03 17:43:20 +0100 |
---|---|---|
committer | Markus Heiser <markus.heiser@darmarit.de> | 2022-01-03 20:56:39 +0100 |
commit | a6cfab93fa7c1b1f0a04c073df42b50f2834d845 (patch) | |
tree | 3ea5eb2b6ede194671f9ef9e8e8c2e7531d77e5e /searx/shared | |
parent | 4f1130d6639ca93cd827f8c2bdaed1c3864f1af3 (diff) | |
download | searxng-a6cfab93fa7c1b1f0a04c073df42b50f2834d845.tar.gz searxng-a6cfab93fa7c1b1f0a04c073df42b50f2834d845.zip |
[enh] add redis connector searx/shared/redisdb.py
Add a redis connector, the default DB connector is a socket at::
unix:///usr/local/searxng-redis/run/redis.sock?db=0
To set up a redis instance simply use::
$ ./manage redis.build
$ sudo -H ./manage redis.install
A hint for developers:
To get access rights to this instance, your developer account needs to be added
to the *searxng-redis* group::
$ sudo -H ./manage redis.addgrp "${USER}"
# don't forget to logout & login to get member of group
Signed-off-by: Markus Heiser <markus.heiser@darmarit.de>
Diffstat (limited to 'searx/shared')
-rw-r--r-- | searx/shared/redisdb.py | 41 |
1 files changed, 41 insertions, 0 deletions
diff --git a/searx/shared/redisdb.py b/searx/shared/redisdb.py new file mode 100644 index 000000000..613b82a38 --- /dev/null +++ b/searx/shared/redisdb.py @@ -0,0 +1,41 @@ +# SPDX-License-Identifier: AGPL-3.0-or-later +# lint: pylint +"""Implementation of the redis client (redis-py_). + +.. _redis-py: https://github.com/redis/redis-py + +This implementation uses the :ref:`settings redis` setup from ``settings.yml``. +A redis DB connect can be tested by:: + + >>> from searx.shared import redisdb + >>> redisdb.init() + True + >>> db = redisdb.client() + >>> db.set("foo", "bar") + True + >>> db.get("foo") + b'bar' + >>> + +""" + +import logging +import redis +from searx import get_setting + +logger = logging.getLogger('searx.shared.redis') + + +def client(): + return redis.Redis.from_url(get_setting('redis.url')) + + +def init(): + try: + c = client() + logger.info("connected redis DB --> %s", c.acl_whoami()) + return True + except redis.exceptions.ConnectionError as exc: + logger.error("can't connet redis DB ...") + logger.error(" %s", exc) + return False |