如何等待Redis缓存缓存信息

import redis

r = redis.Redis(host='localhost', port=6379, db=0)
r.set('my_key', 'my_value')

import time

def wait_for_data(key, timeout=10):
    start_time = time.time()
    while True:
        value = r.get(key)
        if value is not None:
            return value
        if time.time() - start_time > timeout:
            raise TimeoutError(f"Data for key {key} not available within {timeout} seconds")
        time.sleep(0.1)  # 等待0.1秒后再次检查

# 使用示例
try:
    data = wait_for_data('my_key')
    print(f"Data retrieved: {data}")
except TimeoutError as e:
    print(e)

import redis

r = redis.Redis(host='localhost', port=6379, db=0)
pubsub = r.pubsub()
pubsub.subscribe('data_update_channel')

def wait_for_notification(key):
    for message in pubsub.listen():
        if message['type'] == 'message' and message['data'] == key.encode():
            return r.get(key)

# 发布更新通知
r.publish('data_update_channel', 'my_key')

# 等待通知并获取数据
data = wait_for_notification('my_key')
print(f"Data retrieved: {data}")