#Aiohttp Итак я начинаю познавать дивный мир aio библиотек и

Question

#Aiohttp Итак я начинаю познавать дивный мир aio библиотек и

у меня есть пару вопросов:
1) aiopg есть коннект а есть пул, в моем понимании пул создает несколько коннектов и смотрит за ними (например переоткрывает новые при ресетах) и это в целом позволяет снизить задержки и увеличить отзывчивость приложения за счет распределения запросов к базе от разных вебзапросов по разным коннектом к базе это так?
2) я создал пул на старте аппа app['aiopg']=aiopg.create_pool(dsn='host=192.168.141.223 dbname=tododb user=user1 password=changeme')
теперь в хендлере я делаю так
async with request.app['aiopg'] as conn:
print(type(conn))
async with conn.acquire() as conn:
async with conn.cursor() as cur:
await cur.execute("select json from playlist where id=%s ", [pid])
async for row in cur:
dbres.append(row)
Я явно что-то делаю не так, но оно работает.
Во всех примерах что я видел нет, самого 1 async, но без него не работает.
Как правильно запрашивать курсор без этой лапши?

#backend #programming #python #russian

0

07.12.2020

4 ответов

4 просмотра

Kino Recovery Автор вопроса

Ruslan Gilfanov
общий совет: лучшего всего самостоятельно в pg_sta...

спасибо за совет. если я убираю 1й with то attributeError: '_PoolContextManager' object has no attribute 'acquire' aiopg

0

07.12.2020

Ruslan Gilfanov

Kino Recovery
спасибо за совет. если я убираю 1й with то attribu...

если убрать async with conn.acquire() as conn, то видимо обращение идут к request.app['aiopg']

0

07.12.2020

genya

Первый with - ты создаёшь пул, второй - берёшь коннект

0

07.12.2020

Ruslan Gilfanov · Accepted Answer

общий совет: лучшего всего самостоятельно в pg_stat_activity заглядывать, указание application_name при создании пула коннекторв очень хорошо помогает 1) главный профит от пула - это, во-первых, избавление от оверхеда при каждом открытии /закрытии коннектов, во-вторых, жесткая регламентация общего числа одновременно открытых соединений (то есть явно знаешь максимально сколько приложение может потреблять ресурсов), насчет распределения нагрузки - я б не сказал, можно получить и 100 запросов (в случае веб-сервера например) и на все запросы откроется 100 коннектов, которые также параллельно будут обращаться к БД 2) тут лучше к документации обратиться или best practices async with conn.acquire() as conn: - тут скорее всего выбирается коннект из пула async with conn.cursor() as cur: - а тут видимо создается программная абстракция для работы с коннектом, наверно и не упростить уже

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

#Aiohttp Итак я начинаю познавать дивный мир aio библиотек и

4 ответов

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