utilisation multi-processus de Python Redis

Question

class RedisClient(object):
    def __init__(self):
        pool = redis.ConnectionPool(host='127.0.0.1', port=6379)
        self.client = redis.StrictRedis(connection_pool=pool)

Écrivez un client Redis avec un pool de connexions selon la documentation, puis générez une instance pour une utilisation globale.
Il a été testé comme étant normal lors du partage d'une instance dans plusieurs threads.
Mais dans le cas de processus multiples, le test a échoué

class ProcessRdeisTest(Process):
    def __init__(self,client):
        self._client = client

Écrit ainsi, lors de l'exécution de start, une erreur sera signalée et la sérialisation ne pourra pas être effectuée.
changé en :

class ProcessRdeisTest(Process):
    def __init__(self):
        pass
    def run(self):
        self._client = RedisClient()
        while Ture:
            dosomething()
        

Cela fonctionne comme ceci, mais cette méthode de connexion est-elle correcte ? Existe-t-il une meilleure façon d’y parvenir ?

Dans le fil de discussion principal, directement
process1 = ProcessRdeisTest('p1')
process1.start()
Appelez de cette façon

Answer 1

Propriétaire, python redis possède son propre pool de connexions :

import redis
import threading

class RedisPool(object):
    __mutex = threading.Lock()
    __remote = {}

    def __new__(cls, host, passwd, port, db):
        with RedisPool.__mutex:
            redis_key = "%s:%s:%s" % (host, port, db)
            redis_obj = RedisPool.__remote.get(redis_key)
            if redis_obj is None:
                redis_obj = RedisPool.__remote[redis_key] = RedisPool.new_redis_pool(host, passwd, port, db)
        return redis.Redis(connection_pool=redis_obj)

    def __init__(self, host, passwd, port, db):
        pass

    @staticmethod
    def new_redis_pool(host, passwd, port, db):
        redis_obj = redis.ConnectionPool(host=host, password=passwd,
                                         port=port, db=db, socket_timeout=3, max_connections=10) # max_connection default 2**31
        return redis_obj