redis实战 — python知识散记

— time.time()

— row.to_dict()

–json.dumps(row.to_dict())

#!/usr/bin/env python

import time

def schedule_row_cache(conn,row_id, delay) :
    conn.zadd('delay:', row_id, delay)
    conn.zadd('schedule:', row_id, time.time())

def cache_rows(conn) :
    while not QUIT :
        next = conn.zrange('schedule:', 0, 0, withscores=True)
        now = time.time()
        if not next or next[0][1] > now :
            time.sleep(.05)
            continue
        row_id = next[0][0]

        delay = conn.zscore('delay:', row_id)
        if delay  0 :
            conn.zdel('delay:', row_id)
            conn.zdel('schedule:', row_id)
            conn.delete('inv:' + row_id)
        row = Inventory.get(row_id)
        conn.zadd('schedule:', row_id, now + delay)
        conn.set('inv:' + row_id, json.dumps(row.to_dict()))

— time.time() 需要导入time库

— import time

— row.to_dict()

啦啦啦

Original: https://www.cnblogs.com/ClassNotFoundException/p/9259643.html
Author: limeOracle
Title: redis实战 — python知识散记

原创文章受到原创版权保护。转载请注明出处:https://www.johngo689.com/10841/

转载文章受原作者版权保护。转载请注明原作者出处!

(0)

大家都在看

免费咨询
免费咨询
扫码关注
扫码关注
联系站长

站长Johngo!

大数据和算法重度研究者!

持续产出大数据、算法、LeetCode干货,以及业界好资源!

2022012703491714

微信来撩,免费咨询:xiaozhu_tec

分享本页
返回顶部