python 异步操作redis

由于python对redis进行连接、增删改查等操作时都是网络IO，可能需要一定时间，因此实现异步操作可提高并发性。

首先需要先安装aioredis模块

pip install aioredis==1.3.1

我在虚拟机中运行redis（前台启动）：

在虚拟机中先查看能否ping通主机：

ping通的话我设置不需要密码就可以访问redis：

czc@czc-VirtualBox:~$ redis-cli
127.0.0.1:6379> config set protected-mode no

接下来在主机通过python代码异步操作redis：

示例1：

import asyncio
import aioredisasync def execute1(address, password):print("开始连接redis：",address)# 网络IO操作：创建redis连接redis = await aioredis.create_redis(address, password=password)# 网络IO操作：在redis中设置哈希值person，内部在设两个键值对await redis.hmset_dict("person",{"name1":"cc", "age":19})# 网络IO操作：去redis中获取值result = await redis.hgetall("person",encoding="utf-8")print(result)# 网络IO操作：关闭redis连接redis.close()print("结束连接redis：", address)async def execute2(address, password):print("开始连接redis：",address)# 网络IO操作：创建redis连接redis = await aioredis.create_redis(address, password=password)# 网络IO操作：在redis中设置哈希值person，内部在设两个键值对await redis.hmset_dict("person",{"name2":"mm", "age":18})# 网络IO操作：去redis中获取值result = await redis.hgetall("person",encoding="utf-8")print(result)# 网络IO操作：关闭redis连接redis.close()print("结束连接redis：", address)async def main():print("开始执行任务")task_list = [asyncio.create_task(execute1("redis://192.168.1.173:6379", None)),asyncio.create_task(execute2("redis://192.168.1.173:6379", None)),]done,pending = await asyncio.wait(task_list, timeout=2)  #timeout表示只等2s，超过2s就不等了print(done,pending)if __name__ == '__main__':asyncio.run(main())

结果：

在虚拟机中查看是否已经存储成功：

python 异步操作redis相关推荐

python的redis数据库连接与使用
Redis redis是一个key-value存储系统.和Memcached类似,它支持存储的value类型相对更多,包括string(字符串).list(链表).set(集合).zset(sorte ...
Redis数据库搭建集群（集群概念、redis集群、搭建集群（配置机器1、2、创建集群、数据操作验证）、Python与redis集群交互）
1. 集群的概念集群是一组相互独立的.通过高速网络互联的计算机,它们构成了一个组,并以单一系统的模式加以管理.一个客户与集群相互作用时,集群像是一个独立的服务器.集群配置是用于提高可用性和可缩放性. ...
Python操作Redis及连接方式
前沿:随着互联网的高速发展,数据变得越来越重要,Python成为了人工智能的热门语言,而Nosql数据库已成为日常开发用品. 今天要写的是Python操作Redis Redis的安装我就不介绍了,你可 ...
python 操作redis之——有序集合(sorted set) （七）
#coding:utf8 import redis r =redis.Redis(host="23.226.74.190",port=63279,password="66 ...
python连接redis有中文_Python连接Redis并操作
首先开启redis的外连 sch01ar@ubuntu:~$ sudo vim /etc/redis/redis.conf 把bind 127.0.0.1这行注释掉然后重启redis sudo /e ...
用python画简单的四叶草-使用 python 操作 redis
1.安装pyredis (1)使用 #easy_install redis (2)直接编译安装 #wget https://pypi.python.org/packages/source/r/redi ...
Windows下安装Redis及使用Python操作Redis的方法
这篇文章主要介绍了Windows下安装Redis及使用Python操作Redis的方法,非常不错,具有参考借鉴价值,需要的朋友可以参考下首先说一下在Windows下安装Redis,安装包可以在htt ...
python 操作redis之——HyperLogLog （八）
#coding:utf8 import redis # python 操作redis之--HyperLogLog r =redis.Redis(host="33.23.724.12190&q ...
python 实现redis订阅发布功能
redis是一个key-value存储系统.和Memcached类似,它支持存储的value类型相对更多,包括string(字符串).list(链表).set(集合).zset(sorted set ...

python 异步操作redis

python 异步操作redis相关推荐

最新文章

热门文章