Python交互Redis的實現(xiàn)
更新時間:2022年08月10日 15:09:55 作者:碼農(nóng)的禿頭之旅
本文主要介紹了Python交互Redis的實現(xiàn),文中通過示例代碼介紹的非常詳細(xì),對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧
模塊(redis)
Ubuntu
sudo pip3 install redis
使用流程
import redis # 創(chuàng)建數(shù)據(jù)庫連接對象 r = redis.Redis(host='127.0.0.1',port=6379,db=0,password='123456')
代碼示例
import redis
# 1 創(chuàng)建redis數(shù)據(jù)庫連接對象
r = redis.Redis(password='123456')
# 2 使用,很多命令的返回值是字節(jié)串,需要用字符串
# ?表示時,調(diào)用decode方法.
# 3.1 通用命令...
print(r.keys('*'))
print(r.exists('name'))
# 3.2 字符串類型的操作
r.set('uname', 'aid2102', 60)
print(r.get('uname').decode())
r.mset({'a': 100, 'b': 200, 'c': 300})
print(r.mget(['a', 'b', 'c']))
# 3.3 列表類型的操作
r.lpush('pylk1',100,200,300)
print(r.lrange('pylk1',0,-1))list案例: 一個進(jìn)程負(fù)責(zé)生產(chǎn)任務(wù),一個進(jìn)程負(fù)責(zé)消費任務(wù)
進(jìn)程1: 生產(chǎn)者,product.py
import redis
# 1 創(chuàng)建redis數(shù)據(jù)庫連接對象
r = redis.Redis(password='123456')
# 2.向任務(wù)隊列中添加任務(wù),使用列表類型
# 任務(wù)格式: 任務(wù)類別_發(fā)送者_(dá)接收者_(dá)內(nèi)容
task = 'sendMail_aid2102_mzg_helloworld'
r.lpush('lst:tasks',task)進(jìn)程2: 消費者,consumer.py
import redis
r = redis.Redis(password='123456')
while True:
? ? task = r.brpop('lst:tasks',3)
? ? if task:
? ? ? ? print(task)
? ? ? ? # (b'lst:tasks', b'sendMail_aid2102_mzg_helloworld')
? ? ? ? # 處理任務(wù)
? ? ? ? task_data = task[1].decode()
? ? ? ? print(task_data)
? ? ? ? # sendMail_aid2102_mzg_helloworld
? ? ? ? lst_data = task_data.split('_')
? ? ? ? if lst_data[0] == 'sendMail':
? ? ? ? ? ? print('執(zhí)行發(fā)送郵件的任務(wù)...')
? ? else:
? ? ? ? print('-no task!-')
到此這篇關(guān)于Python交互Redis的實現(xiàn)的文章就介紹到這了,更多相關(guān)Python交互Redis內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!
相關(guān)文章
Redis使用bloom-filter過濾器實現(xiàn)推薦去重
這篇文章主要介紹了Redis使用bloom-filter過濾器實現(xiàn)推薦去重,文中通過示例代碼介紹的非常詳細(xì),對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友可以參考下2020-11-11

