import redis
# 缺少端口、密碼、數(shù)據(jù)庫編號配置
r = redis.Redis(host="127.0.0.1")
r.set("username","zhangsan")
print(r.get("username"))

ConnectionError: Error 61 connecting to 127.0.0.1:6379. Connection refused.

import redis
r = redis.Redis(host="127.0.0.1",port=6379,db=0,decode_responses=True)
# 存入哈希數(shù)據(jù)
r.hset("user:1001",mapping={"name":"lisi","age":22})
# 錯誤使用字符串get讀取hash數(shù)據(jù)
res = r.get("user:1001")
print(res)

import redis
r = redis.Redis(host="127.0.0.1",port=6379,db=0,decode_responses=True)
r.set("verify_code","886699")
# 錯誤將秒數(shù)直接當(dāng)成毫秒傳入
r.expire("verify_code",60000)

import redis
r = redis.Redis(host="127.0.0.1",port=6379,db=0,decode_responses=True)
pipe = r.pipeline()
pipe.set("goods:1","手機")
pipe.set("goods:2","耳機")
pipe.set("goods:3","平板")
pipe.execute()

你是后端開發(fā)工程師，幫我排查下面Redis代碼全部錯誤，逐條說明故障原因，輸出可直接運行的完整修復(fù)代碼，同時補充適配業(yè)務(wù)的優(yōu)化建議。
【業(yè)務(wù)場景】本地開發(fā)環(huán)境，Python redis-py操作用戶緩存
【報錯信息】
ConnectionError: Error 61 connecting to 127.0.0.1:6379. Connection refused.
【異常代碼】
import redis
r = redis.Redis(host="127.0.0.1")
r.set("username","zhangsan")
print(r.get("username"))

# 檢查Redis本地服務(wù)運行狀態(tài)
redis-cli -h 127.0.0.1 -p 6379 ping

# 故障原因
1. 創(chuàng)建Redis客戶端僅傳入host參數(shù)，缺少端口port、數(shù)據(jù)庫db配置；
2. 本地Redis服務(wù)未啟動或端口未開放，觸發(fā)連接拒絕報錯；
3. 未開啟自動解碼，取出數(shù)據(jù)會附帶字節(jié)符號，增加使用成本。
# 修復(fù)后可運行代碼
import redis
# 完善全部基礎(chǔ)連接參數(shù)，開啟自動解碼
r = redis.Redis(
    host="127.0.0.1",
    port=6379,
    db=0,
    decode_responses=True,
    socket_timeout=5
)
# 測試連通性
print(r.ping())
r.set("username", "zhangsan")
print(r.get("username"))

# 故障原因
數(shù)據(jù)采用hset哈希方式存儲，讀取時誤用字符串get指令，get只能讀取普通字符串鍵，哈希數(shù)據(jù)需要hgetall、hget讀取。
# 修復(fù)代碼
import redis
r = redis.Redis(host="127.0.0.1",port=6379,db=0,decode_responses=True)
r.hset("user:1001",mapping={"name":"lisi","age":22})
# 使用hgetall讀取整條哈希數(shù)據(jù)
user_info = r.hgetall("user:1001")
print(user_info)
# 單獨讀取某一個字段
user_name = r.hget("user:1001","name")
print(user_name)

# 故障原因
expire指令單位為秒，代碼傳入60000，只會設(shè)置60秒過期；若需要10分鐘，應(yīng)傳入600。
如需毫秒級過期可以使用pexpire指令。
# 修復(fù)代碼
import redis
r = redis.Redis(host="127.0.0.1",port=6379,db=0,decode_responses=True)
r.set("verify_code","886699")
# 設(shè)置10分鐘過期，單位秒
r.expire("verify_code", 600)
# 查看剩余過期時間
print(r.ttl("verify_code"))

import redis
from redis.exceptions import RedisError
try:
    r = redis.Redis(host="127.0.0.1",port=6379,db=0,decode_responses=True)
    pipe = r.pipeline()
    pipe.set("goods:1","手機")
    pipe.set("goods:2","耳機")
    pipe.set("goods:3","平板")
    pipe.execute()
    print("批量緩存寫入完成")
except RedisError as e:
    # 捕獲所有Redis相關(guān)異常，打印故障信息，程序不會中斷
    print("緩存操作異常：", str(e))

基于Python redis-py編寫用戶登錄緩存代碼，存儲用戶ID、昵稱、登錄標(biāo)識，統(tǒng)一設(shè)置30分鐘過期，增加異常捕獲，防止緩存擊穿，輸出完整可運行代碼。

import random
import redis
from redis.exceptions import RedisError
def set_user_login_cache(user_id, nick_name):
    try:
        client = redis.Redis(host="127.0.0.1",port=6379,db=0,decode_responses=True)
        cache_key = f"login:{user_id}"
        # 隨機增加60秒以內(nèi)偏移，避免大量鍵同時過期
        expire_time = 1800 + random.randint(1,60)
        client.hset(
            cache_key,
            mapping={
                "user_id": user_id,
                "nick_name": nick_name,
                "login_status": "1"
            }
        )
        client.expire(cache_key, expire_time)
        return True
    except RedisError as err:
        print("登錄緩存寫入失?。?, err)
        return False
# 調(diào)用示例
set_user_login_cache(10086, "開發(fā)測試用戶")