summaryrefslogtreecommitdiff
path: root/searx/shared
diff options
context:
space:
mode:
authorMarkus Heiser <markus.heiser@darmarit.de>2022-01-03 17:43:20 +0100
committerMarkus Heiser <markus.heiser@darmarit.de>2022-01-03 20:56:39 +0100
commita6cfab93fa7c1b1f0a04c073df42b50f2834d845 (patch)
tree3ea5eb2b6ede194671f9ef9e8e8c2e7531d77e5e /searx/shared
parent4f1130d6639ca93cd827f8c2bdaed1c3864f1af3 (diff)
downloadsearxng-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.py41
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