redis 操作

import redis
conn = redis.Redis(host="192.168.20.150",port=6379)
#===========对于字符串用set,get设置，得到值===========
conn.set("k13","v2")    #向远程redis中写入了一个键值对
val = conn.get("k13")   #获取键值对
print(val)
conn.set("names","ss")
val2 = conn.get("names")
print(val2)

#===========对于列表的操作:  lpush操作和lpop操作，（从左边放值，从左边取值）=============
val4 = conn.lpush("names_s",*["海燕","刘伟"])
conn.lpush(‘names_s‘,*[‘把几个‘,‘鲁宁‘])  #‘鲁宁‘,‘把几个‘,"刘伟","海燕",
conn.delete("names_s")
v = conn.llen("names_s")
print(conn.llen("names_s"))  #4
for i in range(v):
    print(conn.lpop("names_s").decode("utf-8"))


# ==========对于列表的操作:  rpush操作和rpop操作，（从右边放值，从右边取值）======
conn.rpush("abcd",[1,2,3])
conn.rpush("abcd",*["a","b","c"])   #[1,2,3],a,b,c   #*代表是解包，如果不加*,放进去的就是一个列表
# conn.delete("abcd")
v = conn.llen("abcd")
# print(v)    #
for i in range(v):
    print(conn.rpop("abcd").decode("utf-8"))  #c,b,a,[1,2,3]

import redis
from crm import models

POOL = redis.ConnectionPool(host=‘47.93.4.198‘, port=6379, password=‘123123‘)
CONN = redis.Redis(connection_pool=POOL)

class AutoSale(object):

    @classmethod
    def fetch_users(cls):
        # [obj(销售顾问id,num),obj(销售顾问id,num),obj(销售顾问id,num),obj(销售顾问id,num),]
        sales = models.SaleRank.objects.all().order_by(‘-weight‘)

        sale_id_list = []
        count = 0
        while True:
            flag = False
            for row in sales:
                if count < row.num:
                    sale_id_list.append(row.user_id)
                    flag = True
            count += 1
            if not flag:
                break

        if sale_id_list:
            CONN.rpush(‘sale_id_list‘, *sale_id_list)  # 自动pop数据
            CONN.rpush(‘sale_id_list_origin‘, *sale_id_list)  # 原来的数据
            return True
        return False

    @classmethod
    def get_sale_id(cls):
        # 查看原来数据是否存在
        sale_id_origin_count = CONN.llen(‘sale_id_list_origin‘)
        if not sale_id_origin_count:
            # 去数据库中获取数据，并赋值给： 原数据，pop数据
            status = cls.fetch_users()
            if not status:
                return None

        user_id = CONN.lpop(‘sale_id_list‘)
        if user_id:
            return user_id

        reset = CONN.get(‘sale_id_reset‘)
        # 要重置
        if reset:
            CONN.delete(‘sale_id_list_origin‘)
            status = cls.fetch_users()
            if not status:
                return None
            CONN.delete(‘sale_id_reset‘)
            return CONN.lpop(‘sale_id_list‘)
        else:
            ct = CONN.llen(‘sale_id_list_origin‘)
            for i in range(ct):
                v = CONN.lindex(‘sale_id_list_origin‘, i)
                CONN.rpush(‘sale_id_list‘, v)
            return CONN.lpop(‘sale_id_list‘)


    @classmethod
    def reset(cls):
        CONN.set(‘sale_id_reset‘,1)

    @classmethod
    def rollback(cls,nid):
        CONN.lpush(‘sale_id_list‘,nid)