数据库托管11.11活动

import redis
import pymysql

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

def get_data(key):
    data = r.get(key)
    if data is None:
        # 如果缓存中没有数据，从数据库中获取
        conn = pymysql.connect(host='db_host', user='user', password='password', db='dbname')
        cursor = conn.cursor()
        cursor.execute(f"SELECT * FROM table WHERE id={key}")
        data = cursor.fetchone()
        cursor.close()
        conn.close()
        # 将数据存入缓存
        r.setex(key, 3600, data)
    return data

from redis import StrictRedis
from redis_lock import Lock

r = StrictRedis(host='localhost', port=6379, db=0)

def update_data(key, value):
    with Lock(r, f"lock:{key}"):
        # 执行更新操作
        conn = pymysql.connect(host='db_host', user='user', password='password', db='dbname')
        cursor = conn.cursor()
        cursor.execute(f"UPDATE table SET value={value} WHERE id={key}")
        conn.commit()
        cursor.close()
        conn.close()

from cryptography.fernet import Fernet

key = Fernet.generate_key()
cipher_suite = Fernet(key)

def encrypt_data(data):
    return cipher_suite.encrypt(data.encode())

def decrypt_data(encrypted_data):
    return cipher_suite.decrypt(encrypted_data).decode()