db.py

@@ -8,14 +8,14 @@ from redis import StrictRedis
 
 import util
 from schemas.mc_s import schema
-
+import aioredis
 configuration = manticoresearch.Configuration(host="http://monolith-db-1:9308")
 api_client = manticoresearch.ApiClient(configuration)
 api_instance = manticoresearch.IndexApi(api_client)
 
 log = util.get_logger("db")
 r = StrictRedis(unix_socket_path="/var/run/redis/redis.sock", db=0)
-
+ar = aioredis.from_url("unix:///var/run/redis/redis.sock")
 
 def store_message(msg):
     """

docker/requirements.txt

@@ -7,3 +7,4 @@ python-dotenv
 manticoresearch
 numpy
 ujson
+aioredis[hiredis]

requirements.txt

@@ -8,3 +8,4 @@ python-dotenv
 manticoresearch
 numpy
 ujson
+aioredis[hiredis]