Python使用keys() 獲取 Redis 數(shù)據(jù)庫中的所有鍵

更新時間：2023年08月18日 15:11:52 作者：跡憶客

哈希、列表、集合、排序集合、字符串、JSON 和流是 Redis 支持的眾多數(shù)據(jù)結構之一,本文將討論獲取 Redis 數(shù)據(jù)庫中的所有鍵,感興趣的朋友跟隨小編一起看看吧

使用 keys() 獲取 Redis 數(shù)據(jù)庫中的所有鍵

要使用 redis，我們需要安裝它；您可以查看 Redis 下載頁面以了解操作方法。對于 Linux 和 macOS 用戶來說，這要容易得多；但是，對于 Windows 用戶，您可能必須使用適用于 Linux 的 Windows 子系統(tǒng) (WSL2)，并且您可以按照他們的說明視頻指南進行操作。

假設您已經(jīng)設置了 Redis 數(shù)據(jù)庫，我們將安裝 redis 包，它提供對 Redis 數(shù)據(jù)庫的客戶端訪問。要安裝它，我們將使用 pip 命令。

pip install redis

輸出:

Collecting redis
Downloading redis-4.3.4-py3-none-any.whl (246 kB)
━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━ 246.2/246.2 kB 794.4 kB/s eta 0:00:00
Collecting deprecated>=1.2.3
Downloading Deprecated-1.2.13-py2.py3-none-any.whl (9.6 kB)
Collecting async-timeout>=4.0.2
Downloading async_timeout-4.0.2-py3-none-any.whl (5.8 kB)
Collecting packaging>=20.4
Downloading packaging-21.3-py3-none-any.whl (40 kB)
━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━ 40.8/40.8 kB 1.9 MB/s eta 0:00:00
Collecting wrapt<2,>=1.10
Downloading wrapt-1.14.1-cp310-cp310-win_amd64.whl (35 kB)
Collecting pyparsing!=3.0.5,>=2.0.2
Downloading pyparsing-3.0.9-py3-none-any.whl (98 kB)
━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━ 98.3/98.3 kB 624.8 kB/s eta 0:00:00
Installing collected packages: wrapt, pyparsing, async-timeout, packaging, deprecated, redis
Successfully installed async-timeout-4.0.2 deprecated-1.2.13 packaging-21.3 pyparsing-3.0.9 redis-4.3.4 wrapt-1.14.1

因此，redis 包使用 wrapt、pyparsing、async-timeout、打包和不推薦使用的模塊來為其模塊提供支持。

要使用 redis 包，我們需要導入它。

import redis

進入正題，我們可以使用redis模塊提供的keys()方法來訪問并獲取其中的所有key。

key() 方法從給定的 Redis 數(shù)據(jù)庫返回一個與在其參數(shù)中傳遞的模式相匹配的鍵列表。如果不傳遞任何參數(shù)，則有一個默認模式，即 * ，表示所有鍵。

為了展示工作中的方法，我們使用 +Key 按鈕或以下代碼手動預填充了別名 Temp 和一些鍵的 redis 數(shù)據(jù)庫。

import redis
redisHost = 'localhost'
redisPort = 6379
redisDecodeRes = True
r = redis.StrictRedis(
            host=redisHost,
            port=redisPort,
            decode_responses=redisDecodeRes
        )
r.set("ConnectionPool", "Ox1212af34w3141")

上面的代碼導致鍵 ConnectionPool 被添加到具有相應值的 Temp 數(shù)據(jù)庫中。

set() 方法將鍵值對應用于數(shù)據(jù)庫，而 StrictRedis() 方法創(chuàng)建一個 Redis 連接對象，使我們能夠訪問數(shù)據(jù)庫。

要通過 GUI 顯示數(shù)據(jù)庫（使用別名 Temp）及其密鑰，我們可以使用 RedisInsight 應用程序，如圖所示。

手動向數(shù)據(jù)庫中添加了 11 個密鑰以測試 key() 方法。

現(xiàn)在，對于 key() 方法，我們必須使用 StrictRedis() 方法創(chuàng)建一個 Redis 連接對象來訪問鍵。 host、port 和 decode_responses 參數(shù)被傳遞來定義連接的參數(shù)。

host 和 port 定義主機名和端口號，decode_responses 定義將傳遞的數(shù)據(jù)解碼為我們可以輕松使用的 Python 字符串。 keys() 方法然后訪問所有可用的鍵，因為沒有傳遞任何參數(shù)。

import redis
redisHost = 'localhost'
redisPort = 6379
redisDecodeRes = True
r = redis.StrictRedis(
    host=redisHost,
    port=redisPort,
    decode_responses=redisDecodeRes,
    db=0
    )
print(r.keys())

輸出:

['bar-two', 'information', 'bar-one', 'details', 'foo', 'jinku', 'bar', 'User-One', 'delft', 'bar-three', 'ConnectionPool']

我們在 Temp 數(shù)據(jù)庫中有一個所有鍵的列表，我們可以使用它。

如果我們有所需的鍵模式，我們可以將其作為參數(shù)傳遞。讓我們列出所有以 bar 開頭的鍵。

print(r.keys(pattern&#61;&#34;bar*&#34;))

輸出:

['bar-two', 'bar-one', 'bar', 'bar-three']

使用 scan_iter() 獲取 Redis 數(shù)據(jù)庫中的所有鍵

對于大型數(shù)據(jù)庫， scan_iter() 允許我們在 Python 應用程序中更好地管理數(shù)據(jù)。此外， key() 方法會阻塞服務器并阻止其他使用操作，而對于 scan_iter() ，其基于批處理的操作允許其他使用操作。

盡管 keys() 可能更快，但它對于多個基于請求的系統(tǒng)來說并不是很好。

現(xiàn)在，讓我們看看它的實際效果。

import redis
redisHost = 'localhost'
redisPort = 6379
redisDecodeRes = True
try:
    r = redis.StrictRedis(
        host=redisHost,
        port=redisPort,
        decode_responses=redisDecodeRes,
        db=0
    )
    for key in r.scan_iter(match="bar*"):
        print(key)
except Exception as e:
    print(e)

輸出:

bar-three
bar-one
bar-two
bar

當我們嘗試使用數(shù)據(jù)庫時，使用 try/except 有助于處理連接問題。使用 StrictRedis() 連接后，我們使用 match 參數(shù)來定義我們正在尋找的鍵模式，并循環(huán)遍歷結果以給出鍵。

使用 zip_longest 獲取 Redis 數(shù)據(jù)庫中的所有鍵

正如我們所說，對于具有大量鍵的大型數(shù)據(jù)庫， scan_iter() 方法更好，但我們可以通過按指定數(shù)量的批次檢索鍵來進一步改進它，以更好地管理結果。

要創(chuàng)建批處理，我們需要 itertools 模塊，它提供可用于不同情況的不同迭代器（或方法）。在 itertools 模塊中，我們有 zip_longest 方法，它返回一個 zip_longest 對象，其 .next() 方法返回一個元組并聚合傳遞給它的 iterable 中的元素。

我們可以使用 zip_longest() 方法創(chuàng)建一個函數(shù)，該函數(shù)根據(jù)傳遞的參數(shù)創(chuàng)建一批指定數(shù)量的鍵。比如我們創(chuàng)建一批2，可以用于很多情況。

import redis
from itertools import zip_longest
redisHost = 'localhost'
redisPort = 6379
redisDecodeRes = True
try:
    r = redis.StrictRedis(
        host=redisHost,
        port=redisPort,
        decode_responses=redisDecodeRes,
        db=0
    )
    def batch(iterable, num):
        initIter = [iter(iterable)] * num
        return zip_longest(*initIter)
    for keyBatch in batch(r.scan_iter('bar*'), 2):
        print(keyBatch)
except Exception as e:
    print(e)

輸出: