async def get_channel(connection: aio_pika.pool.Pool) -> AsyncIterator[aio_pika.pool.Pool]:
async with connection.acquire() as connection:
channel_pool = await connection.channel()
yield channel_pool
await channel_pool.close()
Но в channel_pool получаю <class 'aio_pika.robust_channel.RobustChannel'> и при попытке отправить сообщение, получаю ошибку:
async with self.channel.acquire() as channel:
await channel.set_qos(prefetch_count=prefetch_count)
exchange = await channel.declare_exchange(
exchange_name,
type=exchange_type
)
await exchange.publish(
aio_pika.Message(
message,
content_type=content_type,
headers=headers,
),
"",
)
AttributeError: 'RobustChannel' object has no attribute 'acquire'
Подскажите, как пофиксить, где я делаю не так?
Может быть у кого в открытом доступе есть примеры работы с AioPika?
Обсуждают сегодня