Rumah > pangkalan data > Redis > Cara menggunakan redis untuk melaksanakan tugas undur

Cara menggunakan redis untuk melaksanakan tugas undur

王林
Lepaskan: 2023-05-26 21:58:04
ke hadapan
1221 orang telah melayarinya

Contohnya seperti berikut:

import redis
import time

def event_handler(msg):  
    '''
    监听到任何key过期后,得到的消息如下
    msg ={'type': 'pmessage', #返回值类型
    'pattern': '__keyevent@2__:expired', #来源
     'channel': '__keyevent@2__:expired', # 实际的Channel
      'data': 'mykey' # key名称
      }
    可以根据您要监控的key进行业务判断或触发其他事件
    if msg['data']=='mykey':
        do....
    elif msg['data']=='yourkey':
        do ----
    '''
    print(msg)
 
    
redis_conn = redis.Redis(host='host', port='6379', db=2, password='test.123.com', decode_responses=True)
#设置过期时间2秒
redis_conn.set('mykey', 'asjdhkjashdkjahdskjahsd', ex=2)
# 订阅消息
pubsub =redis_conn.pubsub()
# 订阅key过期事件
# __keyevent@2__:expired : __keyevent@{db}__:事件
pubsub.psubscribe(**{'__keyevent@2__:expired': event_handler})
while True:  
    message = pubsub.get_message()
    if message:
        # redis_conn.set('mykey', 'asjdhkjashdkjahdskjahsd', ex=10)
        print('wqwqwqwqwqwqwqwqwqwqwqwqwqwqwqwqwqwq')
    else:
        time.sleep(0.01)
Salin selepas log masuk

Atas ialah kandungan terperinci Cara menggunakan redis untuk melaksanakan tugas undur. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!

Label berkaitan:
sumber:yisu.com
Kenyataan Laman Web ini
Kandungan artikel ini disumbangkan secara sukarela oleh netizen, dan hak cipta adalah milik pengarang asal. Laman web ini tidak memikul tanggungjawab undang-undang yang sepadan. Jika anda menemui sebarang kandungan yang disyaki plagiarisme atau pelanggaran, sila hubungi admin@php.cn
Tutorial Popular
Lagi>
Muat turun terkini
Lagi>
kesan web
Kod sumber laman web
Bahan laman web
Templat hujung hadapan