ホームページ > バックエンド開発 > Python チュートリアル > Python による Redis データベースの読み取りおよび書き込み操作の例

Python による Redis データベースの読み取りおよび書き込み操作の例

WBOY
リリース: 2016-06-16 08:44:47
オリジナル
1459 人が閲覧しました

Pythonを使ってRedisを操作するにはどうすればよいですか?以下では、例を使用して、Python を使用して Redis データベースの読み取りと書き込みを行う方法を説明します。
たとえば、次のようにデータを挿入します:

コードをコピー コードは次のとおりです:
import redis

クラス データベース:
def __init__(self):
self.host = 'localhost'
self.port = 6379

def write(self,website,city, year,month,day, deal_number):
try:
key = '_'.join([website,city,str(year),str(month),str(day)])
val = deal_number
r = redis.StrictRedis(host=self.host,port=self.port)
r.set(key,val)
例外を除く、例外:
例外を出力

def read(self,website,city,year,month,day):
try:
key = '_'.join([website,city,str(year),str(month), str(day)])
r = redis.StrictRedis(host=self.host,port=self.port)
value = r.get(key)
出力値
Exception 、例外を除く:
印刷例外
db.read( 'meituan'、 'beijing'、2013,9,1)


上記の操作は、最初にデータを書いてから読み取ります書き込みまたは読み取りの場合は、データが多すぎるため、より効率的なバッチ処理を使用することをお勧めします。


コードをコピー

コードは次のとおりです:
import redis import datetime class Database: def __init__ (self):
self.host = 'localhost'
self.port = 6379
self.write_pool = {}

def add_write(self,website,city,year ,month, day,deal_number):
key = '_'.join([website,city,str(year),str(month),str(day)])
val = deal_number
self .write_pool[ key] = val

defbatch_write(self):
try:
r.mset(self .write_pool)
例外を除く、例外:
例外を出力


def add_data():
beg = datetime.datetime.now()
db = Database()
for i in range(1,10000):
db。 add_write('meituan','beijing',2013,i,1,i)
db.batch_write()
end = datetime .datetime.now()
print end-beg

if __name__ == '__main__':
add_data()

関連ラベル:
ソース:php.cn
このウェブサイトの声明
この記事の内容はネチズンが自主的に寄稿したものであり、著作権は原著者に帰属します。このサイトは、それに相当する法的責任を負いません。盗作または侵害の疑いのあるコンテンツを見つけた場合は、admin@php.cn までご連絡ください。
最新の問題
人気のチュートリアル
詳細>
最新のダウンロード
詳細>
ウェブエフェクト
公式サイト
サイト素材
フロントエンドテンプレート