redis python psubscribe to event with callback, without calling .listen()

Question

I'm trying to subscribe to keyspace event in redis using python. I hope to NOT use the for-loop with .listen() after calling .psubscribe(). Is this possible?

I have enabled all keyspace events with KEA.

def subscribe(self, key, handler):

        # this function never gets called, if I don't add the for-loop with listen() below
        def event_handler(msg):
            print('Handler', msg)

        redis_server = StrictRedis(host='localhost', port=6379, db=0)
        pubsub = redis_server.pubsub()
        subscribe_key = '*'
        pubsub.psubscribe(**{subscribe_key: event_handler})

        # without the following for-loop with listen, the callback never fires. I hope to get rid of this.
        for item in pubsub.listen():
            pass

See this GitHub issue for an example of using the asyncio version: github.com/redis/redis-py/issues/3680 — smac89
– smac89, Commented Jul 21 at 15:34

Andre Pastore · Accepted Answer · 2020-06-16 14:09:57Z

13

Using `redis` module threads

A good alternative would be using redis.client.PubSub.run_in_thread method.


def subscribe(self, key, handler):
    def event_handler(msg):
        print('Handler', msg)

    redis_server = StrictRedis(host='localhost', port=6379, db=0)
    pubsub = redis_server.pubsub()
    subscribe_key = '*'
    pubsub.psubscribe(**{subscribe_key: event_handler})

    pubsub.run_in_thread(sleep_time=.01)

There is a good step-by-step explanation here.

Using `asyncio` (`aioredis`)

This code can be updated for an asyncio version, using aioredis Pub/Sub support. Here is the doc and an example.

edited Jun 16, 2020 at 14:09

answered Jul 3, 2019 at 23:14

Andre Pastore

2,9074 gold badges35 silver badges44 bronze badges

Sign up to request clarification or add additional context in comments.

Collectives™ on Stack Overflow

redis python psubscribe to event with callback, without calling .listen()

1 Answer 1

Using `redis` module threads

Using `asyncio` (`aioredis`)

Comments

Your Answer

Hot Network Questions

Collectives™ on Stack Overflow

1 Answer 1

Using redis module threads

Using asyncio (aioredis)

Comments

Your Answer

Sign up or log in

Post as a guest

Related

Using `redis` module threads

Using `asyncio` (`aioredis`)