Делаю всё как в примере: https://aio-pika.readthedocs.io/en/latest/quick-start.html?highlight=channel%20pool#connection-pooling @staticmethod

Question

Делаю всё как в примере: https://aio-pika.readthedocs.io/en/latest/quick-start.html?highlight=channel%20pool#connection-pooling @staticmethod

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'

Подскажите, как пофиксить, где я делаю не так?

#backend #programming #python #russian

0

04.09.2021

1 ответов

63 просмотра

smqwe · Answer 1

smqwe Автор вопроса

Может быть у кого в открытом доступе есть примеры работы с AioPika?

0

04.09.2021

170 похожих чатов

Делаю всё как в примере: https://aio-pika.readthedocs.io/en/latest/quick-start.html?highlight=channel%20pool#connection-pooling @staticmethod

1 ответов

Похожие вопросы