代码之家 › 专栏 › 技术社区 › Diego L

Python中的redis是异步的吗?

redis async-await python

Diego L · 技术社区 · 11 月前

我有以下Python代码:

import redis

from app.infra.services.notifications import INotifier
from app.schemas.notification import NotificationMessage
from app.config import settings


REDIS_CLIENT_PUBSUB = redis.StrictRedis(
    host=settings.REDIS_HOST,
    port=settings.REDIS_PORT,
    password=settings.REDIS_PASSWORD,
)

class RedisNotifier(INotifier):
    def __init__(self):
        self.redis_client = REDIS_CLIENT_PUBSUB

    async def send_notification(self, room: str, notification: NotificationMessage) -> None:
        await self.redis_client.publish(room, notification.json())


redis_notifier = RedisNotifier()

我有一个用FastAPI编写的web应用程序,它将使用redis_notifier向频道发布消息。我的问题是,它是否真的: self.redis-client.publish(文件室,notification.json()) 它是异步的,也就是说,我的web应用程序能够在发布完成时放弃这个协程并做其他事情吗? 我对redis和aioredis库有点困惑,我不知道我的代码是否有意义,或者我做错了什么