如何进行异步Redis订阅调用

import asyncio
import aioredis

async def subscribe(channel):
    redis = await aioredis.create_redis_pool('redis://localhost')
    channel, = await redis.subscribe(channel)
    print(f"Subscribed to {channel.name}")

    while True:
        message = await channel.get(encoding='utf-8')
        if message is not None:
            print(f"Received message: {message}")

async def main():
    await subscribe('my_channel')

if __name__ == "__main__":
    asyncio.run(main())

async def connect_and_subscribe(channel):
    while True:
        try:
            redis = await aioredis.create_redis_pool('redis://localhost')
            channel, = await redis.subscribe(channel)
            print(f"Subscribed to {channel.name}")
            break
        except ConnectionError:
            print("Connection lost, retrying...")
            await asyncio.sleep(5)

    while True:
        message = await channel.get(encoding='utf-8')
        if message is not None:
            print(f"Received message: {message}")