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

#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, но без него не работает.
Как правильно запрашивать курсор без этой лапши?

4 ответов

20 просмотров

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

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

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

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

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

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

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

Обсуждают сегодня

Господа, а что сейчас вообще с рынком труда на делфи происходит? Какова ситуация?
Rꙮman Yankꙮvsky
29
А вообще, что может смущать в самой Julia - бы сказал, что нет единого стандартного подхода по многим моментам, поэтому многое выглядит как "хаки" и произвол. Короче говоря, с...
Viktor G.
2
30500 за редактор? )
Владимир
47
а через ESC-код ?
Alexey Kulakov
29
Чёт не понял, я ж правильной функцией воспользовался чтобы вывести отладочную информацию? но что-то она не ловится
notme
18
У меня есть функция где происходит это: write_bit(buffer, 1); write_bit(buffer, 0); write_bit(buffer, 1); write_bit(buffer, 1); write_bit(buffer, 1); w...
~
14
Добрый день! Скажите пожалуйста, а какие программы вы бы рекомендовали написать для того, чтобы научиться управлять памятью? Можно написать динамический массив, можно связный ...
Филипп
7
Недавно Google Project Zero нашёл багу в SQLite с помощью LLM, о чём достаточно было шумно в определённых интернетах, которые сопровождались рассказами, что скоро всех "ибешни...
Alex Sherbakov
5
Ребят в СИ можно реализовать ООП?
Николай
33
https://github.com/erlang/otp/blob/OTP-27.1/lib/kernel/src/logger_h_common.erl#L174 https://github.com/erlang/otp/blob/OTP-27.1/lib/kernel/src/logger_olp.erl#L76 15 лет назад...
Maksim Lapshin
20
Карта сайта