Jack444

Представь что под капотом есть некая очередь транзакций.
Если несколько транзакций пытаются модифицировать один и тот же ресурс, PostgreSQL обрабатывает их по принципу "первый пришёл — первый обслужен".
Например:
Транзакция A изменяет строку и удерживает блокировку.
Транзакция B пытается изменить ту же строку и переходит в состояние ожидания.
Когда Транзакция A завершается (COMMIT или ROLLBACK), блокировка снимается, и Транзакция B получает доступ.

Таблицы client/agent/user_data можно в одну таблицу user упаковать, + добавить поля is_client bool и is_agent bool, но так как вы уже сделали связь к role то перекидывайте туда роли client и agent, если возможно использование нескольких ролей для пользователя то используйте не name varchar a names varchar[] чтобы поле было массивом.
Ещё обычно создаётся таблица permissiion которая привязывается к ролям и юзерам + дополнительно хранит поля table_name и action, либо вместо таблицы типом JSONB добавить ячейку в роли и юзеры.
Вообще postgre изначально умеет работать с пользователями и можно использовать такие фичи как CREATE USER и ALTER ROLE но такой вариант может оказаться костыльным и логику с правами лучше перекинуть на уровень приложения.

Просто сделать такой индекс.
CREATE INDEX dtidx ON table (id, created DESC);
И всё, запрос будет искать id в первичном индексе, как найдёт там будет уже список таймштампов отсортированных по убыванию сделать по ним offset/limit вообще не чего не стоющая операция, ORDER BY писать уже не обязательно.

async def user_exists(user_id):
    conn = await asyncpg.connect(host=host, user=user, password=password, database=database)
    try: return await conn.fetchrow(f"SELECT 1 FROM users WHERE (user_id=} LIMIT 1")
    finally: await conn.close()

Если бд строите под энтерпрайз левел и у вас планируются милиарды строк в таблицах то вполне годно добавлять префиксы и группы таблиц скидывать на отдельные сервера а после на уровне приложения менеджить запросы к нужным серверам, но скорее всего лучше посмотреть в сторону кликхаус, ядб или носиквел базы которые умееют горизонтально масштабироваться и сами распределяют данные по серверам.
Если данных в таблице планируется набор строк до сотни милионов то схема 1 сущность=1 таблица отличный вариант

import psycopg2
E = lambda field: f'$myseckey${field}$myseckey$' if type(field) is str else field
with connection.cursor() as cursor:
        cursor.execute(
            f"""INSERT INTO data(photo_avatar,
                                 name,
                                 type,
                                 reach,
                                 engagemant_er,
                                 engage_percent)
                                 VALUES ({E(profile_name)}, 'N\A', {E(reach)}, {E(engagement)}, {E(engage_per));"""
            )
        
    connection.commit()

А зачем тебе __del__? Ищи в любом фреймворке события startup и shutdown, через них открывай и закрывай коннекты

uid = message.from_user.id
if await sql.fetchrow(f'SELECT True FROM users WHERE id={uid} LIMIT 1'):
    ...
else: 
    ...

А причем здесь потоки? Драйвер же говорит что ему нечего извлечь. Например ты делаешь запрос update или insert которые нечего не возвращают а ты пытаешься что-то от туда извлечь.