ホームページ  >  記事  >  バックエンド開発  >  (集) Redisを動作させるPythonの総まとめ

(集) Redisを動作させるPythonの総まとめ

不言
不言転載
2018-10-16 13:48:373810ブラウズ

この記事は、Redis の Python 操作 (まとめ) を包括的にまとめたものです。一定の参考価値があります。必要な友人は参照してください。お役に立てば幸いです。

1. 文字列文字列

文字列で Redis を操作する Python の Redis モジュールの主な操作関数には、SET、GET、GETSET、SETEX、SETNX 、MSET、 MSETNX、INCR (INCRBY、DECR、DECRBY は Python の同じ関数 incr で実装されます)、APPEND、SETRANGE、STRLEN。関数の説明は次のとおりです。

  1. SET: 指定されたキー (key) の値 (value) を設定します。set(self, name, value, * *クワーグス)。

  2. GET: 指定されたキー (key) にバインドされた値を取得します (get(self, name))。

  3. GETSET: 指定されたキー (key) に新しい値 (value) を設定し、古い値 (old Value) を返します。 getset(self, name , value)

  4. SETEX: 指定されたキー (key)、setex(self、name、value、time)

    # の有効期限を秒単位で設定します。
  5. SETNX: キーが存在しない場合は、キーの値を指定します。setnx(self, name, value)

  6. #MSET

    : 複数のキーと値 (キーと値) のペアを一度に設定します。関数によって設定されたキーと値のペア (つまり、マッピングによって指定されたコンテンツ) のデータは、Python で渡す必要があります。辞書データ型、mset(self, Mapping)

  7. MSETNX

    : キーと値のペアが存在しない場合は、キーと値 (キーと値) を設定します。ペア、msetnx(self、mapping)、マッピング値は 6

  8. INCR

    を参照します。自動インクリメント関数、デフォルトのステップ サイズは 1、コントロールが渡されます。ステップ サイズ (量) と文字の関数は、INCRBY (amount>=1)、DECR (amount=-1)、DECRBY (amount<=-1)、incr(self, name, amount=1 ) などの関数を実装します。

  9. APPEND

    : 指定された文字列に値を追加します。値が存在しない場合は、直接作成します。append(self, key, value)

  10. SETRANGE

    : value パラメーターを使用して、指定されたキーに格納されている文字列値をオフセット offset から上書きします。setrange(self, name, offset, value)

  11. #STRLEN
  12. : 文字列の長さを返します。名前が存在しない場合は 0 を返します。strlen(self, name)

    サンプル コード
  13. #!/usr/bin/python
    # -*- coding:utf-8 -*-
    # __author__ = &#39;Jack&#39;
    
    pool = redis.ConnectionPool(host=&#39;127.0.0.1&#39;, port=6379)
    r = redis.Redis(connection_pool=pool)
    r.flushall()  # 清空Redis
    
    r.setex(&#39;name&#39;, value=&#39;liaogx&#39;, time=2)  # 设置新值,过期时间为3s
    r.mset(k1 = &#39;v1&#39;, k2 = &#39;v2&#39;, k3 = &#39;v3&#39;)  # 批量设置新值
    print(r.mget(&#39;k1&#39;, &#39;k2&#39;, &#39;k3&#39;, &#39;k4&#39;))  # 批量获取新值
    print(r.getset(&#39;name&#39;, &#39;liaogaoxiang&#39;))  # 设置新值并获取原来的值
    print(r.getrange(&#39;name&#39;, 0, 1))  # 获取子序列 0 <= x <= 1
    r.setrange(&#39;name&#39;, 0, &#39;LIAO&#39;)  # 修改字符串内容,从指定字符串索引开始向后替换(新值太长时,则向后添加),返回值的长度
    i = 0
    while i < 4:
        print(r.get(&#39;name&#39;))
        time.sleep(1)
        i += 1
    source = &#39;foo&#39;
    r.set(&#39;n1&#39;, source)
    r.setbit(&#39;n1&#39;, 7, 1)
    &#39;&#39;&#39;
    注:如果在Redis中有一个对应: n1 = "foo",
        那么字符串foo的二进制表示为:01100110 01101111 01101111
        所以,如果执行 setbit(&#39;n1&#39;, 7, 1),则就会将第7位设置为1,
        那么最终二进制则变成 01100111 01101111 01101111,即:"goo"
    &#39;&#39;&#39;
    print(r.get(&#39;n1&#39;))
    print(r.getbit(&#39;n1&#39;, 7))  # 获取n1对应的值的二进制表示中的某位的值 (0或1)
    r.set(&#39;n2&#39;, &#39;廖高祥&#39;)
    print(r.strlen(&#39;n2&#39;))  # 返回对应的字节长度(一个汉字3个字节)
    r.set(&#39;num&#39;, 1)
    r.incr(&#39;num&#39;, amount=10)
    r.decr(&#39;num&#39;, amount=1)
    print(r.get(&#39;num&#39;))  # 自增num对应的值,当name不存在时,则创建name=amount,否则,则自增。
    r.append(&#39;num&#39;, 111)
    print(r.get(&#39;num&#39;))  # 在redis num对应的值后面追加内容
出力結果は次のとおりです:

[b&#39;v1&#39;, b&#39;v2&#39;, b&#39;v3&#39;, None]
b&#39;liaogx&#39;
b&#39;li&#39;
b&#39;LIAOgaoxiang&#39;
b&#39;LIAOgaoxiang&#39;
b&#39;LIAOgaoxiang&#39;
b&#39;LIAOgaoxiang&#39;
b&#39;goo&#39;
1
9
b&#39;10&#39;
b&#39;10111&#39;

2. リスト

Redis 上の Python 操作では、主に redis モジュールを使用してリストを実装します。テーブル操作. この機能は主に Redis の操作コマンド LPUSH、LRANGE、LINDEX、BLPOP、BRPOP をシミュレートします。関数の説明は次のとおりです。

    lpush
  1. この関数は、指定された Redis リストの先頭からデータをプッシュする関数を実装します、

    lpush キー値

  2. lrange
  3. リストの指定範囲を取得する関数、

    lrange key start end

  4. lindex
  5. リストのサブスカラーに基づいてリスト要素の値を取得します。

    lindex キー インデックス

  6. blpop
  7. Takeリストの先頭から最初の要素を取り出して return 要素の値をリストから削除します (l は left、left を表します)

  8. brpop
  9. 最初の要素を取得しますリストの最後から要素の値を返し、リストから削除します (l は右、右を表します)

  10. LPUSHX、RPUSHX
  11. およびその他の Redis リスト(リスト) 関数は現在のバージョンでは実装できません。実装方法のコード例がブログにあれば更新されます。

    サンプル コードは次のとおりです:
  12. #!/usr/bin/python
    # -*- coding:utf-8 -*-
    # __author__ = &#39;Jack&#39;
    
    pool = redis.ConnectionPool(host=&#39;127.0.0.1&#39;, port=6379)
    r = redis.Redis(connection_pool=pool)
    r.flushall()  # 清空Redis
    
    r.lpush(&#39;oo&#39;, 11)  # 保存顺序为: 33,22,11
    r.lpushx(&#39;oo&#39;, 00)  # 在name对应的list中添加元素,只有name已经存在时,值添加到列表的最左边
    print(r.llen(&#39;oo&#39;))  # name对应的list元素的个数
    
    r.linsert(&#39;oo&#39;, &#39;before&#39;, 11, 99)  # 在11之前插入值99
    r.lset(&#39;oo&#39;, 1, 88)  # 对name对应的list中的某一个索引位置重新赋值
    print(r.lrange(&#39;oo&#39;, 0, -1))  # 在name对应的列表分片获取数据
    
    r.lrem(&#39;oo&#39;, 88, num=1)  # 在name对应的list中删除指定的值.num=0,删除列表中所有的指定值;num=2,从前到后,删除2个;num=-2,从后向前,删除2个
    print(r.lrange(&#39;oo&#39;, 0, -1))
    
    print(r.lpop(&#39;oo&#39;))  # 在name对应的列表的左侧获取第一个元素并在列表中移除,返回值则是第一个元素
    print(r.lindex(&#39;oo&#39;, 0))  # 在name对应的列表中根据索引获取列表元素
    r.lpush(&#39;l1&#39;, 11)  # index为0
    r.rpush(&#39;l1&#39;, 22)
    r.rpush(&#39;l1&#39;, 33)
    r.rpush(&#39;l1&#39;, 44)
    r.rpush(&#39;l1&#39;, 55)  # index为4
    r.ltrim(&#39;l1&#39;, 1, 3)  # 在name对应的列表中移除没有在[start-end]索引之间的值
    print(r.lrange(&#39;l1&#39;, 0, -1))
    
    r.rpoplpush(&#39;l1&#39;, &#39;l1&#39;)  # 从一个列表取出最右边的元素,同时将其添加至另一个列表的最左边;src要取数据的列表的name, dst要添加数据的列表的name
    print(r.lrange(&#39;l1&#39;, 0, -1))
    
    r.brpoplpush(&#39;l1&#39;, &#39;l1&#39;, timeout=3)  # # timeout,当src对应的列表中没有数据时,阻塞等待其有数据的超时时间(秒),0 表示永远阻塞
    print(r.lrange(&#39;l1&#39;, 0, -1))
    
    print(r.blpop(&#39;l1&#39;, 3))  # 从列表头部取出第一个元素,返回该元素值并从列表删除(l代表left,左边)
    print(r.lrange(&#39;l1&#39;, 0, -1))
    &#39;&#39;&#39;
        # 由于redis类库中没有提供对列表元素的增量迭代,如果想要循环name对应的列表的所有元素,那么就需要:
        # 1、获取name对应的所有列表
        # 2、循环列表
        # 但是,如果列表非常大,那么就有可能在第一步时就将程序的内容撑爆,所有有必要自定义一个增量迭代的功能:
    &#39;&#39;&#39;
    print(&#39;自定义增量迭代:&#39;)
    r.flushall()
    r.lpush(&#39;l1&#39;, 11)  # index为0
    r.rpush(&#39;l1&#39;, 22)
    r.rpush(&#39;l1&#39;, 33)
    r.rpush(&#39;l1&#39;, 44)
    r.rpush(&#39;l1&#39;, 55)  # index为4
    
    def list_iter(name):
        list_count = r.llen(name)
        for index in range(list_count):
            yield r.lindex(name, index)
    
    for item in list_iter(&#39;l1&#39;):
        print(item)
出力結果は次のとおりです:

2
[b&#39;0&#39;, b&#39;88&#39;, b&#39;11&#39;]
[b&#39;0&#39;, b&#39;11&#39;]
b&#39;0&#39;
b&#39;11&#39;
[b&#39;22&#39;, b&#39;33&#39;, b&#39;44&#39;]
[b&#39;44&#39;, b&#39;22&#39;, b&#39;33&#39;]
[b&#39;33&#39;, b&#39;44&#39;, b&#39;22&#39;]
(b&#39;l1&#39;, b&#39;33&#39;)
[b&#39;44&#39;, b&#39;22&#39;]
自定义增量迭代:
b&#39;11&#39;
b&#39;22&#39;
b&#39;33&#39;
b&#39;44&#39;
b&#39;55&#39;

3. コレクション セット

Redis データベース セット オブジェクト (セット オブジェクト) は、繰り返し要素のない文字列型の不要なコレクションです。基になるエンコーディングは intset または hashtable です。 intset でエンコードされたコレクション オブジェクトは、最下位レベルの整数コレクションとして実装され、すべてのオブジェクト要素は整数コレクションに格納されます。 Python の redis モジュールは、SADD、SCARD、SDIFF、SDIFFSTORE、SINTER、SINTERSTORE、SISMEMBER、SMEMBERS、SMOVE、SPOP、SRANDMEMBER、SREM、SUNION、および SUNIONSTORE 操作コマンドの基本的な使用法を実装します。関数の説明は次のとおりです。

#SADD
    : コレクション オブジェクトにメンバーを追加します。sadd(self, name, value)
  1. #SCARD

    : コレクション要素の数を取得します。shard(self, name)
  2. SDIFF

    : の差集合を返します。複数の指定されたコレクション オブジェクト (set key1-set key2..-set keyn)、左から右へセットの差を計算、sdiff(self,keys, *args)
  3. SDIFFSTORE

    : 指定された複数のコレクション オブジェクトの差分セットを返し、それをターゲット (dest) コレクション、 sdiffstore(self、dest、keys、*args)
  4. に格納します。 #SINTER

    : 指定されたすべてのセット (keys、
  5. args) の共通部分を返します。sinter(self、keys、
  6. args)

    SINTERSTORE

    : 指定されたすべてのセット (keys、
  7. args) の共通部分を返し、それをセット (dest)、sinterstore(self、dest、keys、
  8. args)

    に格納します。 SISMEMBER

    : value 要素がセット名のメンバーであるかどうかを判断し、ブール論理値 True または False を返します。sismember(self, name, value)
  9. SMEMBERS:返回集合中所元素值的Python集合类型数据,smembers(self, name)

  10. SMOVE:将元素value从集合src移动到 集合 dest。若元素value在集合src中不存在,则集合dest中不会添加元素value, smove(self, src, dest, value)

  11. SPOP:移除并返回集合中的一个随机元素, spop(self, name)

  12. SRANDMEMBER:返回集合中一个随机数,但是不做移除操作, srandmember(self, name)。从Redis 2.6 版本开始, 在命令行下Srandmember 命令接受可选返回元素数量的参数 redis>SRANDMEMBER  name count

  13. SREM:移除集合中一个元素,srem(self, name, value),redis模块任然沿用Redis 2.4 版本以前的只接受单个元素的用法。

  14. SUNION:返回所有给定集合的并集中所有元素,sunion(self, keys, *args)

  15. SUNIONSTORE:所有给定集合的并集存储在集合dest 中, sunionstore(self, dest, keys, *args)

  16. SSCAN:迭代集合中的元素,sscan(self, name, cursor=0, match=None, count=None)

示例代码如下:

#!/usr/bin/python
# -*- coding:utf-8 -*-
# __author__ = 'Jack'

pool = redis.ConnectionPool(host='127.0.0.1', port=6379)
r = redis.Redis(connection_pool=pool)
r.flushall()  # 清空Redis

r.sadd('s1', 'v1', 'v1', 'v2', 'v3')  # name对应的集合中添加元素
r.sadd('s2', 'v2', 'v4')  # name对应的集合中添加元素
print(r.scard('s1'))  # 获取name对应的集合中元素个数
print(r.sdiff('s1', 's2'))  #在第一个name对应的集合中且不在其他name对应的集合的元素集合

r.sdiffstore('s3', 's1', 's2')  # 获取第一个name对应的集合中且不在其他name对应的集合,再将其新加入到dest对应的集合中
print(r.smembers('s3'))  # 获取s3对应的集合的所有成员

print(r.sinter('s1', 's2'))  # 获取s1, s2对应集合的交集
r.sinterstore('s4', 's1', 's2')  # 获取s1, s2对应集合的交集,并将其存放到集合是s4中
print(r.smembers('s4'))

print(r.sunion('s1', 's2'))  # 获取s1, s2对应集合的并集

r.sunionstore('s5', 's1', 's2')  # 获取s1, s2对应集合的交集,并将其存放到集合是s5中
print(r.smembers('s5'))

print(r.sismember('s4', 'v4'))  # 检查value是否是name对应的集合的成员

r.smove('s2', 's1', 'v4')  # 将集合s2中成员v4移至集合s1中
print(r.smembers('s1'))
r.srem('s1', 'v1')  # 在name对应的集合中删除某些值

print(r.spop('s1'))  # 从集合的右侧(尾部)移除一个成员,并将其返回 注意:集合是无序的,故结果随机!

print(r.srandmember('s1'))  # 从name对应的集合中随机获取 numbers 个元素(Redis 2.6+)

输出结果如下:

3
{b'v3', b'v1'}
{b'v3', b'v1'}
{b'v2'}
{b'v2'}
{b'v3', b'v2', b'v4', b'v1'}
{b'v3', b'v2', b'v4', b'v1'}
False
{b'v3', b'v2', b'v4', b'v1'}
b'v2'
b'v3'

四、有序集合 sorted sets

命令 描述
Redis Zadd 命令 向有序集合添加一个或多个成员,或者更新已存在成员的分数
Redis Zcard 命令 获取有序集合的成员数
Redis Zcount 命令 计算在有序集合中指定区间分数的成员数
Redis Zincrby 命令 有序集合中对指定成员的分数加上增量 increment
Redis Zinterstore 命令 计算给定的一个或多个有序集的交集并将结果集存储在新的有序集合 key 中
Redis Zlexcount 命令 在有序集合中计算指定字典区间内成员数量
Redis Zrange 命令 通过索引区间返回有序集合成指定区间内的成员
Redis Zrangebylex 命令 通过字典区间返回有序集合的成员
Redis Zrangebyscore 命令 通过分数返回有序集合指定区间内的成员
Redis Zrank 命令 返回有序集合中指定成员的索引
Redis Zrem 命令 移除有序集合中的一个或多个成员
Redis Zremrangebylex 命令 移除有序集合中给定的字典区间的所有成员
Redis Zremrangebyrank 命令 移除有序集合中给定的排名区间的所有成员
Redis Zremrangebyscore 命令 移除有序集合中给定的分数区间的所有成员
Redis Zrevrange 命令 返回有序集中指定区间内的成员,通过索引,分数从高到底
Redis Zrevrangebyscore 命令 返回有序集中指定分数区间内的成员,分数从高到低排序
Redis Zrevrank 命令 返回有序集合中指定成员的排名,有序集成员按分数值递减(从大到小)排序
Redis Zscore 命令 返回有序集中,成员的分数值
Redis Zunionstore 命令 计算给定的一个或多个有序集的并集,并存储在新的 key 中
Redis Zscan 命令 迭代有序集合中的元素(包括元素成员和元素分值)

示例代码如下:

#!/usr/bin/python
# -*- coding:utf-8 -*-
# __author__ = 'Jack'

pool = redis.ConnectionPool(host='127.0.0.1', port=6379)
r = redis.Redis(connection_pool=pool)
r.flushall()  # 清空Redis

r.zadd('z1', '11', 1, '22', 2, '33', 3, '44', 4, '55', 5, '66', 6, '66', 7)  # 在name对应的有序集合中添加元素
print(r.zcard('z1'))  # 获取name对应的有序集合元素的数量
print(r.zcount('z1', 1, 2))  # 获取name对应的有序集合中分数 在 [min,max] 之间的个数
r.zincrby('z1', '11', amount=5)  # 自增name对应的有序集合的 name 对应的分数
print(r.zrange('z1', 0, -1, desc=False, withscores=True))  # 值11被排序到最后;此处表示按元素的值升序排列

print(r.zrank('z1', 33))  # 获取某个值在 name对应的有序集合中的排行(从 0 开始)

r.zrem('z1', '66')  # 删除name对应的有序集合中值是values的成员
print(r.zrange('z1', 0, -1, desc=False, withscores=True))

r.zremrangebyrank('z1', 0, 1)  # 根据排行范围删除
print(r.zrange('z1', 0, -1, desc=False, withscores=True))

r.zremrangebyscore('z1', 4.5, 5.5)  # 根据分数范围删除
print(r.zrange('z1', 0, -1, desc=False, withscores=True))

print(r.zscore('z1', 11))  # 获取name对应有序集合中 value 对应的分数

r.zadd("zset_name", "a1", 6, "a2", 2, "a3", 5)
r.zadd('zset_name1', a1=7, b1=10, b2=5)
'''
    获取两个有序集合的交集并放入dest集合,如果遇到相同值不同分数,则按照aggregate进行操作
    aggregate的值为: SUM  MIN  MAX
'''
r.zinterstore('zset_name2', ('zset_name', 'zset_name1'), aggregate='Sum')

print(r.zrange('zset_name2', 0, -1, desc=False, withscores=True))

输出结果如下:

6
2
[(b'22', 2.0), (b'33', 3.0), (b'44', 4.0), (b'55', 5.0), (b'11', 6.0), (b'66', 6.0)]
1
[(b'22', 2.0), (b'33', 3.0), (b'44', 4.0), (b'55', 5.0), (b'11', 6.0)]
[(b'44', 4.0), (b'55', 5.0), (b'11', 6.0)]
[(b'44', 4.0), (b'11', 6.0)]
6.0
[(b'a1', 13.0)]

五、哈希 hashes

Redis 数据库hash数据类型是一个string类型的key和value的映射表,适用于存储对象。redis 中每个hash可以存储键值对多达40亿。Python的redis模块实现了Redis哈希(Hash)命令行操作的几乎全部命令,包括HDEL、HEXISTS、HGET、HGETALL、HINCRBY、HKEYS、HLEN 、HMGET 、HMSET 、HSET 、HSETNX 、HVALS 、HINCRBYFLOAT等命令。函数说明如下:

  1. HDEL:删除对应哈希(Hash)表的指定键(key)的字段,hdel(self,  name, key)

  2. HEXISTS:检测哈希(Hash)表对应键(key)字段是否存在,返回布尔逻辑,hexists(self,  name, key)

  3. HGET:获取哈希(Hash)指定键(key)对应的值,hget(self,  name, key)

  4. HGETALL:获取哈希(Hash)表的键-值对(key-value pairs),返回python字典类型数据,hgetall(self,  name)

  5. HINCRBY:为哈希表(Hash)指定键(key)对应的值(key)加上指定的整数数值(int,可为负值)hincrby(self>, name, key, amount=1),Redis 中本操作的值被限制在 64 位(bit)有符号数字。

  6. HKEYS:返回哈希表(Hash)对应键(key)的数组(Python称之为列表List),hkeys(self,  name)

  7. HLEN: 获取哈希表(Hash)中键-值对(key-value pairs)个数,hlen(self, name)

  8. HMGET:获取哈希表(Hash)中一个或多个给点字段的值,不存在返回nil(Redis命令行)/None(Python),hmget(self,  name, keys),其中keys可以为列表(list)

  9. HMSET:设置对个键-值对(key-value pairs)到哈希表(Hash)中,python输入值(mapping)为字典(dictionary)类型,hmset(self,  name, mapping)

  10. HSET:为哈希表(Hash)赋值,若键(key)存在值(value)则覆盖,不存在则创建,hset(self,  name, key, value)

  11. HSETNX:为哈希表(Hash)不存值(value)的键(key)赋值,存在操作无效,对应值(value)无变化,hsetnx(self,  name, key, value)

  12. HVALS:返回哈希表(Hash)对应值(value)的列表,hvals(self,  name)

  13. HINCRBYFLOAT:为哈希表 key 中的指定字段的浮点数值加上增量 increment ,hincrbyfloat(self, name, key, amount=1.0)

示例代码如下:

#!/usr/bin/python
# -*- coding:utf-8 -*-
# __author__ = 'Jack'

pool = redis.ConnectionPool(host='127.0.0.1', port=6379)
r = redis.Redis(connection_pool=pool)
r.flushall()  # 清空Redis

r.hset('n1', 'k1', 'v1')  # hset(name, key, value),name对应的hash中设置一个键值对(不存在,则创建;否则,修改)
print(r.hget('n1', 'k1'))
r.hmset('n2', {'k1': 'v1', 'k2': 'v2', 'k3': 'v3'})  # hmset(name, mapping),在name对应的hash中批量设置键值对
print(r.hmget('n2', 'k2'))
print(r.hgetall('n2'))  # 获取name对应hash的所有键值
print(r.hlen('n2'))  # 获取name对应的hash中键值对的个数
print(r.hkeys('n2'))  # 获取name对应的hash中所有的key的值
print(r.hvals('n2'))  # 获取name对应的hash中所有的value的值
print(r.hexists('n2', 'k4')) # 检查name对应的hash是否存在当前传入的key
r.hdel('n2', 'k3')  # 将name对应的hash中指定key的键值对删除
r.hset('n3', 'k1', 1)
r.hincrby('n3', 'k1', amount=1)  # hincrby(name, key, amount=1),自增name对应的hash中的指定key的value的值,不存在则创建key=amount
print(r.hgetall('n3'))

输出结果如下:

b'v1'
[b'v2']
{b'k1': b'v1', b'k2': b'v2', b'k3': b'v3'}
3
[b'k1', b'k2', b'k3']
[b'v1', b'v2', b'v3']
False
{b'k1': b'2'}

以上が(集) Redisを動作させるPythonの総まとめの詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。

声明:
この記事はsegmentfault.comで複製されています。侵害がある場合は、admin@php.cn までご連絡ください。