django之排行榜功能
一、记录点击和获取排行的函数
新建method.py，将功能封装到单独的模块中。
# coding:utf-8
# 导入redis，进行建立连接，直接操作redis,而不是cache
from redis import Redis# 需求先启动redis服务器
from api.models import Testrds = Redis(host='127.0.0.1', port=6379)# zincrby方法表示:为有序集 User-clicks 的成员 user_id 的 score 值加上增量 count
# 记录点击的次数的方法
def record_click(user_id, count=1):rds.zincrby('User-clicks',user_id, count)# 获取排行前num位的数据
def get_top_n_users(num):# zrevrange key start stop [WITHSCORES(是否返回数组的形式(article_id, count))]# 返回有序集 key 中，指定区间内的成员user_clicks = rds.zrevrange('User-clicks', 0, 3, withscores=True)[:num]# 返回前num项数据，每一包含（'User-clicks',user_id,count）# 取出id和countusers = Test.objects.in_bulk([int(item[0]) for item in user_clicks])# 根据列表中的所有id,一次取出所有的文章res = []for item in user_clicks:# 遍历列表，将列表中的id值替换成对应的文章对象res.append({int(item[1]): users[int(item[0])]})return res二、视图序列化数据。
def add_click(self, request, *args, **kwargs):'''更新点击用户的次数'''try:pk = int(request.data['id'])user_obj = models.Test.objects.get(id=pk)record_click(pk)return Response({'info': '%s:浏览了一次' % user_obj.name})except:return Response({'info': 'error'})def get_list(self, request, *args, **kwargs):'''获取点击用户的前几条数据'''try:get_res= get_top_n_users(3)res=[]print(get_res)for dic in get_res:for k,v in dic.items():data=self.serializer_class(v).datadata['click_number']=kres.append(data)return Response({'info': res})except:return Response({'info': []})三、结果。
click_number为点击的次数。
Extra(额外的):
redis默认在执行每次请求都会创建（连接池申请连接）和断开（归还连接池）一次连接操作，如果想要在一次请求中指定多个命令，则可以使用pipline实现一次请求指定多个命令并且默认情况下一次pipline 是原子性操作。
管道（pipeline）是redis在提供单个请求中缓冲多条服务器命令的基类的子类。它通过减少服务器-客户端之间反复的TCP数据库包，从而大大提高了执行批量命令的功能。
import redis
import timepool = redis.ConnectionPool(host='localhost', port=6379, decode_responses=True)
r = redis.Redis(connection_pool=pool)# pipe = r.pipeline(transaction=False) # 默认的情况下，管道里执行的命令可以保证执行的原子性，执行pipe = r.pipeline(transaction=False)可以禁用这一特性。
# pipe = r.pipeline(transaction=True)
pipe = r.pipeline() # 创建一个管道pipe.set('name', 'jack')
pipe.set('role', 'player')
pipe.sadd('age', '20')
pipe.incr('num') # 如果num不存在则vaule为1，如果存在，则value自增1
pipe.execute()print(r.get("name"))
print(r.get("role"))
print(r.get("num"))
管道的命令可以写在一起，如：
pipe.set('hello', 'redis').sadd('faz', 'baz').incr('num').execute()
print(r.get("name"))
print(r.get("role"))
print(r.get("num"))
参考：https://blog.csdn.net/weixin_38748717/article/details/79084962
https://blog.csdn.net/songzhiren5560/article/details/80311981
本文来自互联网用户投稿，文章观点仅代表作者本人，不代表本站立场，不承担相关法律责任。如若转载，请注明出处。 如若内容造成侵权/违法违规/事实不符，请点击【内容举报】进行投诉反馈！