Python aioredis 模块：快速参考指南

import aioredis  # 导入aioredis库
import asyncio  # 导入asyncio库以支持异步操作

async def main():
    # 创建Redis连接
    redis = await aioredis.from_url("redis://localhost")  # 连接到本地Redis数据库
    await redis.set("key", "value")  # 设置键值对
    value = await redis.get("key")  # 获取键值
    print(value)  # 输出获取的值

# 运行主异步函数
asyncio.run(main())

import aioredis
import asyncio

async def main():
    redis = await aioredis.from_url("redis://localhost")
    async with redis.pipeline() as pipe:  # 使用管道进行批量操作
        await pipe.set("key1", "value1")  # 批量设置多个键值
        await pipe.set("key2", "value2")
        await pipe.execute()  # 提交所有操作

    value1 = await redis.get("key1")  # 获取第一个键的值
    print(value1)  # 输出key1的值

asyncio.run(main())

import aioredis
import asyncio

async def subscriber():
    redis = await aioredis.from_url("redis://localhost")
    pubsub = redis.pubsub()  # 创建发布/订阅对象
    await pubsub.subscribe("my_channel")  # 订阅频道
    async for message in pubsub.listen():  # 监听频道消息
        if message['type'] == 'message':  # 当收到消息时
            print(f"Received: {message['data']}")  # 输出消息内容

async def publisher():
    redis = await aioredis.from_url("redis://localhost")
    await redis.publish("my_channel", "Hello, World!")  # 向频道发布消息

# 运行发布和订阅的异步任务
async def main():
    await asyncio.gather(subscriber(), publisher())  # 并发执行

asyncio.run(main())