mysql与redis同步数据

import pymysql
import redis

# 连接MySQL
mysql_conn = pymysql.connect(host='localhost', user='user', password='password', db='database')
mysql_cursor = mysql_conn.cursor()

# 连接Redis
redis_client = redis.StrictRedis(host='localhost', port=6379, db=0)

# 示例：更新用户信息
def update_user_info(user_id, new_info):
    try:
        # 更新MySQL
        mysql_cursor.execute("UPDATE users SET info=%s WHERE id=%s", (new_info, user_id))
        mysql_conn.commit()

        # 更新Redis
        redis_client.set(f'user:{user_id}:info', new_info)
    except Exception as e:
        print(f"Error: {e}")

import pymysql
import redis
import pika

# 连接MySQL
mysql_conn = pymysql.connect(host='localhost', user='user', password='password', db='database')
mysql_cursor = mysql_conn.cursor()

# 连接Redis
redis_client = redis.StrictRedis(host='localhost', port=6379, db=0)

# 连接RabbitMQ
connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
channel = connection.channel()
channel.queue_declare(queue='user_update_queue')

# 示例：发送更新消息
def send_update_message(user_id, new_info):
    channel.basic_publish(exchange='', routing_key='user_update_queue', body=f'{user_id}:{new_info}')

# 消费者：处理更新消息
def callback(ch, method, properties, body):
    user_id, new_info = body.decode().split(':')
    try:
        # 更新MySQL
        mysql_cursor.execute("UPDATE users SET info=%s WHERE id=%s", (new_info, user_id))
        mysql_conn.commit()

        # 更新Redis
        redis_client.set(f'user:{user_id}:info', new_info)
    except Exception as e:
        print(f"Error: {e}")

channel.basic_consume(queue='user_update_queue', on_message_callback=callback, auto_ack=True)
channel.start_consuming()