Python×ElastiCache for Redis:初心者向け簡単チュートリアル1-文字列型-

はじめに

AWS Elasticache for Redisは、スケールアウトと高速なキャッシングを提供するマネージド型のインメモリデータストアサービスです。このサービスは、データの読み込みと書き込みのレイテンシーを大幅に削減し、アプリケーションのパフォーマンスを向上させることができます。

しかし、PythonとElasticache for Redisを組み合わせた実装に関する情報は多くなく、特に初心者にとっては取り組みにくいかもしれません。

よって本記事ではPythonを使ったElasticache for Redisの基本的な利用方法をわかりやすく紹介します。

Redisの型は文字列型、ハッシュ型などがあります。

今回は文字列型をPythonで扱う方法について解説します。明日(12/14)はハッシュ型を解説予定です。

以降のプログラムは、Redisのエンジンバージョンは7.0でテストをしています。

内容

事前準備

ElastiCache for Redisを扱うためのライブラリredis-pyをインストールします。

(仮想環境)% pip install redis

Redisとの接続

redis_host = 'エンドポイント'
redis_port = 6379
client = redis.Redis(host=redis_host, port=redis_port,decode_responses=True, ssl=True)

decode_responses=Trueとすると、バイト型の返り値がデコードされて返ってきます。
ssl=Trueは転送の暗号化を行っている場合に必須となります。。

文字列型:Redisへの書き込み

書き込みは以下のようにsetを使います。

key = 'id1'
value = 1
client.set(key, value)

Redisのキーは必ず一意にしなければなりません。

以下のように入れ子になっているjsonファイルをRedisに保存する場合は、以下のように記述すると良いです。

{
    "id1": {
        "a":1,
        "b":2
    },
    "id2": {
        "a":1,
        "b":2
    },
}

import json 

file_path = 'ファイル名'
with open(file_path, 'r') as file:
    data = json.load(file)
    for key, value in data.items():
        client.set(key, json.dumps(value))

入れ子の値をjson.dumps()で文字列にするのがポイントです。

文字列型:Redisへの読み込み

単一のデータを取得する場合のプログラムは以下です。

import json

key = 'id1'
res = client.get(key)
#書き込みでjson.dumps()していた場合に必要
if res:
    res = json.loads(res)

次に条件に該当する値を複数取得する場合のプログラムとして、２通りの書き方を紹介します。

import json

keys_condition = 'id*'

#パターン1:keysを用いる
matching_keys = client.keys(keys_condition) 

#パターン2:scanを用いる
cursor = 0
matching_keys = []
while True:
    cursor, keys = client.scan(cursor, match=keys_condition) 
    matching_keys.extend(keys)
    if cursor == 0:
        break
        
#パターン1&2共通
res = client.mget(matching_keys)
#書き込みでjson.dumps()していた場合に必要
res = [json.loads(r) for r in res if r is not None]

パターン1&2はデータのサイズなどによって、どちらが速いかが異なります。実験して確かめることをオススメします。

おわりに

Python×ElastiCache for Redisの文字列型の使い方の解説は以上となります。

• ハッシュ型での実装はこちら

• 前回までの類似記事はこちら