import redis  
 import time  
   
 # 連接到Redis  
 r = redis.Redis(host='localhost', port=6379, db=0)  
   
 # 假設(shè)有一個任務(wù)需要在30秒后執(zhí)行  
 task_id = 'task_123'  
 execute_at = int(time.time()) + 30  # 當前時間加上延時秒數(shù)  
   
 # 將任務(wù)添加到ZSet中  
 r.zadd('delay_queue', {task_id: execute_at})

def process_delay_queue(r, queue_key):  
     # 獲取當前時間戳  
     now = int(time.time())  
       
     # 使用ZRANGEBYSCORE和ZREM命令結(jié)合Lua腳本來原子性地檢查并移除到期的任務(wù)  
     # 這里為了簡化，直接用Python代碼模擬，實際生產(chǎn)環(huán)境建議使用Lua腳本以保證原子性  
     while True:  
         # 查找并移除分數(shù)小于等于當前時間戳的任務(wù)  
         # 注意：這里ZRANGEBYSCORE返回的是成員列表，需要再調(diào)用ZREM移除  
         # 但由于ZRANGEBYSCORE+ZREM不是原子操作，實際使用時推薦使用Lua腳本  
         ready_tasks = r.zrangebyscore(queue_key, 0, now, withscores=True)  
         if not ready_tasks:  
             break  # 沒有到期的任務(wù)，跳出循環(huán)  
   
         for task_id, _ in ready_tasks:  
             # 假設(shè)這里執(zhí)行任務(wù)  
             print(f"Executing task: {task_id}")  
               
             # 移除已執(zhí)行的任務(wù)  
             r.zrem(queue_key, task_id)  
   
 # 調(diào)用函數(shù)處理延時隊列  
 process_delay_queue(r, 'delay_queue')

-- Lua腳本，用于原子性地查找并移除到期的任務(wù)  
 local queue_key = KEYS[1]  
 local now = ARGV[1]  
   
 -- 使用redis.call執(zhí)行Redis命令  
 local ready_tasks = redis.call('ZRANGEBYSCORE', queue_key, 0, now)  
 if #ready_tasks > 0 then  
     redis.call('ZREM', queue_key, unpack(ready_tasks))  
     -- 這里可以添加邏輯來實際執(zhí)行任務(wù)，但Lua腳本中通常不推薦進行復雜的邏輯處理  
     -- 可以將任務(wù)ID返回給客戶端，由客戶端執(zhí)行具體的任務(wù)邏輯  
     return ready_tasks  
 else  
     return nil  
 end

# 加載并執(zhí)行Lua腳本（略去具體加載腳本的代碼）  
 # ...  
   
 # 調(diào)用Lua腳本處理延時隊列  
 now = int(time.time())  
 script_result = r.eval（script, 1, 'delay_queue', now)  
 if script_result:  
     # 處理返回的到期任務(wù)列表  
     for task_id in script_result:  
         print(f"Executing task (Lua script): {task_id}")