最新国产好看的视频,伊人天堂AV在线,国产Aaaaaa视频,蜜臀视频在线观看一区,人妻av色图,密臀久久久精品影片,青青视频免费观看毛片,久草在线观看视,国产三级精品色情在线

python redis連接 有序集合去重的代碼

 更新時(shí)間:2019年08月04日 15:59:28   作者:misszm  
這篇文章主要介紹了python redis連接 有序集合去重的代碼,代碼簡(jiǎn)單易懂,非常不錯(cuò),具有一定的參考借鑒價(jià)值,需要的朋友可以參考下

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

# -*- coding: utf-8 -*- 
import redis
from constant import redis_ip, redis_db, redis_pw, redis_zset_name
pool = redis.ConnectionPool(host=redis_ip, db=redis_db, password=redis_pw)
# pool = redis.ConnectionPool(db=6, password=redis_pw)
rr = redis.Redis(connection_pool=pool) # # 客戶端StrictRedis=Redis 合并了
pipe = rr.pipeline(transaction=True) # 批量操作, 遇到異步容易出錯(cuò), 可以不使用, 直接用 rr 連接對(duì)象,一次一個(gè)添加
def distinct_md5(date, eml_md5, eml_path, redis_fail_path):
  """
  用md5標(biāo)記去重, Redis有序集合去重, Redis版本不一樣, 用法有區(qū)別 
  :param date: 排序分?jǐn)?shù): int
  :param eml_md5: 文件或者其他md5
  :return: 1 添加成功, 沒(méi)有去重 0 失敗, 去重
  """
   # pipe.zadd(redis_zset_name, eml_md5, date)
   # pipe.zadd(redis_zset_name, {date: eml_md5}, nx=True) # nx 只插入,存在的值不會(huì)修改其分?jǐn)?shù)
   # pipe.zadd(redis_zset_name, {date: eml_md5})
  pipe.zadd(redis_zset_name, {eml_md5: date})
  return pipe.execute()[0] # 1 添加, 0 沒(méi)添加
   # pipe.zcard('eml_md5_zset') # 查看總個(gè)數(shù)
def del_redis_md5(n, m): # 按照分?jǐn)?shù)值進(jìn)行刪除, n, m 為分?jǐn)?shù), 前后閉區(qū)間
  pipe.zremrangebyscore(redis_zset_name, n, m)
  pipe.execute()

總結(jié)

以上所述是小編給大家介紹的python redis連接 有序集合去重的代碼,希望對(duì)大家有所幫助,如果大家有任何疑問(wèn)歡迎給我留言,小編會(huì)及時(shí)回復(fù)大家的!

相關(guān)文章

最新評(píng)論

青阳县| 启东市| 壶关县| 白朗县| 沈丘县| 施秉县| 延吉市| 上林县| 沧源| 济源市| 邹平县| 新昌县| 修文县| 紫云| 泰来县| 马山县| 土默特右旗| 新昌县| 澜沧| 望城县| 正宁县| 陇南市| 新余市| 读书| 武山县| 宾川县| 连平县| 信丰县| 邯郸县| 华蓥市| 铁岭市| 堆龙德庆县| 星子县| 巴楚县| 深泽县| 屏山县| 莫力| 鹤山市| 寻甸| 龙岩市| 德保县|