redis-py를 사용하여 python 스크립트에서 redis MONITOR 명령을 어떻게 모방 할 수 있습니까?

Question

아쉽게도 redis-py 라이브러리에는 Monitor 루틴이없는 것 같습니다. 내가 redis 서버에 의해받은 모든 명령을 읽고, 그들을 필터링하고 내가 관심있는 것들을 기록하고 싶습니다. 아무도이 일을하는 방법에 대한 아이디어가 있습니까?

Answer 1

다음은 Python으로 모니터 코드를 구현하는 데 필요한 최소 코드입니다.

참고 :

1. 내가 레디 스-평에서 PubSub 클래스에서이 적응. 이 응답을 구문 분석하지 않습니다 client.py
2. 볼 수 있지만 그것으로 충분
3. 는

 
import redis   

class Monitor(): 
    def __init__(self, connection_pool): 
     self.connection_pool = connection_pool 
     self.connection = None 

    def __del__(self): 
     try: 
      self.reset() 
     except: 
      pass 

    def reset(self): 
     if self.connection: 
      self.connection_pool.release(self.connection) 
      self.connection = None 

    def monitor(self): 
     if self.connection is None: 
      self.connection = self.connection_pool.get_connection(
       'monitor', None) 
     self.connection.send_command("monitor") 
     return self.listen() 

    def parse_response(self): 
     return self.connection.read_response() 

    def listen(self): 
     while True: 
      yield self.parse_response() 

if __name__ == '__main__': 
    pool = redis.ConnectionPool(host='localhost', port=6379, db=0) 
    monitor = Monitor(pool) 
    commands = monitor.monitor() 

    for c in commands : 
     print(c)