经验首页 前端设计 程序设计 Java相关 移动开发 数据库/运维 软件/图像 大数据/云计算 其他经验
当前位置:技术经验 » 数据库/运维 » Redis » 查看文章
python redis连接 有序集合去重的代码
来源:jb51  时间:2019/8/5 10:54:45  对本文有异议

python redis连接 有序集合去重的代码如下所述:

  1. # -*- coding: utf-8 -*-
  2. import redis
  3. from constant import redis_ip, redis_db, redis_pw, redis_zset_name
  4. pool = redis.ConnectionPool(host=redis_ip, db=redis_db, password=redis_pw)
  5. # pool = redis.ConnectionPool(db=6, password=redis_pw)
  6. rr = redis.Redis(connection_pool=pool) # # 客户端StrictRedis=Redis 合并了
  7. pipe = rr.pipeline(transaction=True) # 批量操作, 遇到异步容易出错, 可以不使用, 直接用 rr 连接对象,一次一个添加
  8. def distinct_md5(date, eml_md5, eml_path, redis_fail_path):
  9.   """
  10.   用md5标记去重, Redis有序集合去重, Redis版本不一样, 用法有区别
  11.   :param date: 排序分数: int
  12.   :param eml_md5: 文件或者其他md5
  13.   :return: 1 添加成功, 没有去重 0 失败, 去重
  14.   """
  15.  # pipe.zadd(redis_zset_name, eml_md5, date)
  16.   # pipe.zadd(redis_zset_name, {date: eml_md5}, nx=True) # nx 只插入,存在的值不会修改其分数
  17.  # pipe.zadd(redis_zset_name, {date: eml_md5})
  18.   pipe.zadd(redis_zset_name, {eml_md5: date})
  19.   return pipe.execute()[0] # 1 添加, 0 没添加
  20.   # pipe.zcard('eml_md5_zset') # 查看总个数
  21. def del_redis_md5(n, m): # 按照分数值进行删除, n, m 为分数, 前后闭区间
  22.   pipe.zremrangebyscore(redis_zset_name, n, m)
  23.   pipe.execute()

总结

以上所述是小编给大家介绍的python redis连接 有序集合去重的代码,希望对大家有所帮助,如果大家有任何疑问欢迎给我留言,小编会及时回复大家的!

 友情链接:直通硅谷  点职佳  北美留学生论坛

本站QQ群:前端 618073944 | Java 606181507 | Python 626812652 | C/C++ 612253063 | 微信 634508462 | 苹果 692586424 | C#/.net 182808419 | PHP 305140648 | 运维 608723728

W3xue 的所有内容仅供测试,对任何法律问题及风险不承担任何责任。通过使用本站内容随之而来的风险与本站无关。
关于我们  |  意见建议  |  捐助我们  |  报错有奖  |  广告合作、友情链接(目前9元/月)请联系QQ:27243702 沸活量
皖ICP备17017327号-2 皖公网安备34020702000426号