11.11海外加速选购

import redis
import json

# 连接到Redis服务器
r = redis.Redis(host='localhost', port=6379, db=0)

def update_order(order_id, order_data):
    # 将订单数据序列化为JSON格式
    order_json = json.dumps(order_data)
    
    # 使用Redis的SET命令更新订单数据
    r.set(f'order:{order_id}', order_json)
    
    # 发布订单更新事件到Redis频道
    r.publish('order_updates', f'order:{order_id}')

def subscribe_to_order_updates():
    # 订阅订单更新频道
    pubsub = r.pubsub()
    pubsub.subscribe('order_updates')
    
    for message in pubsub.listen():
        if message['type'] == 'message':
            order_id = message['data'].decode('utf-8').split(':')[1]
            # 处理订单更新逻辑
            print(f'Order {order_id} has been updated.')

# 示例调用
order_data = {'id': 123, 'status': 'shipped', 'customer': 'John Doe'}
update_order(123, order_data)
subscribe_to_order_updates()