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 ответов

17 просмотров

общий совет: лучшего всего самостоятельно в 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 - ты создаёшь пул, второй - берёшь коннект

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

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

Всем привет! Имеется функция: function IsValidChar(ch: UTF8Char): Boolean; var i: Integer; ValidChars: AnsiString; begin ValidChars := 'abcdefghijklmnopqrstuvwxyzABCDE...
Евгений
44
Коллеги, я тут для личных нужд пошел ставить MQTT сервер, пощупал mosquitto, но ужаснулся отсутствию такой банальности, как HTTP API для посмотреть список топиков. А тут что,...
Maksim Lapshin
14
#include <stdio.h> #include <stdlib.h> #include <time.h> void mass_first_generate(int mass[5][7]) {     for (int N = 0; N < 5; N++) {         for (int A = 0; A < 7; A++) {   ...
Чувак
6
Всем привет! Решаю 99 OCaml Problems и столкнулся со следующей проблемой (прошу палками не забивать, я OCaml практически не трогал до этого момента): open OUnit2 let create_...
К|/|pи/\/\ 6е3yглbIи
2
Ну вот просто даже давайте вот как. Какой нибудь конкретный кейс, можете в пример привести, где бч работает и приносит прикладную пользу, а не просто что бы было? Не крипту.
Alexander Andreev
22
https://www.linkedin.com/posts/ugama-benedicta-kelechi-codergirl-103041300_mobiledevelopment-fluttertraining-handsonlearning-activity-7263445699227254784-IdHB?utm_source=share...
CoderGirl
16
возможно ли как-то передать в электрон или таури медиа поток с рендера 2д движка? двиг запускается как dll, а дальше надо как-то отправлять рендер кодировать не подходит, зр...
Kyle Nekto
7
Помогите пожалуйста. Делаю систему плагинов. Проблема сейчас в такая: плагины загружаются в основном потоке. FLibHandle := SafeLoadLibrary(FFileName) Но нужно еще выполнить фу...
Илья 🤣
10
Точно, оно. У тебя там имена потоков выставляются?
Александр (Rouse_) Багель
11
объясните пожалуйста, почему функция не работает должным образом? вроде должно брать активное окно сравнивать его размер с размером экрана, и если есть совпадение = true прове...
JF
12
Карта сайта