How to retrieve invalidation message in redis-py when client tracking is used

[theyueli]

hello, I've been trying to play with client tracking in redis-py, I'm using Redis-py 5.0.1 with a local build of the redis main branch.

I have the following testing code:

import redis
from redis import Redis

def our_func(message):
    print(message)

def test_client_tracking_resp_sync():
    client = redis.Redis(host='localhost', port=6379, protocol=3)
    client.ping()
    resp = client.client_tracking_on()
    resp = client.execute_command("GET FOO", push_handler_func=our_func)
    resp = client.execute_command("SET FOO 100", push_handler_func=our_func)
    print(resp)
    resp = client.execute_command("GET FOO", push_handler_func=our_func)
    print(resp)
    resp = client.execute_command("FLUSHDB")
    print(resp)

test_client_tracking_resp_sync()

I'm trying to follow the suggestion here:
https://redis-py.readthedocs.io/en/stable/resp3_features.html

But it seems I can't retrieve the invalidation message as the print statement always just prints out the command result only:

b 'OK'
b '100'
True

Did I miss anything here?

The same flow works well with correctly printed invalidation message on redis-cli.

[sundb]

@theyueli You should use client.pubsub() to monitor the invalidate messages.

[theyueli]

correct me if I'm wrong... when resp3 is used, redis is not using pubsub to send invalidation message, is it?

[sundb]

Yes, when resp3 is used, redis uses push notification to send invalidation message.
you might be able the get help from https://github.com/redis/redis-py for why you can't get the push messages.