redis_subscribe.py

import socket


class RedisClient:

    def __init__(self, **kwargs):
        self.sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
        self.sock.connect((kwargs['host'], kwargs['port']))

    def subscribe(self, channel):
        self.sock.send(bytes(f'subscribe {channel}\n\r', 'utf-8'))

    def receive(self):
        while True:
            msg = self.sock.recv(1024).decode('utf-8')
            print(msg)


redis = RedisClient(host='localhost', port=6379)
redis.subscribe('foo')
redis.receive()