Пытаюсь создать и взаимодействовать с базой данных PostgreSQL, используя Python и asyncpg. При запуске программы постоянно появляются следующие ошибки:
**ConnectionResetError: [WinError 64] Указанное сетевое имя более недоступно**
и ещё:
**asyncpg.exceptions.ConnectionDoesNotExistError: connection was closed in the middle of operation**
Может кто-то знает, из-за чего могут возникать подобные ошибки?
from typing import Union
import asyncpg
from asyncpg import Connection
from asyncpg.pool import Pool
from data import config
class Database:
def __init__(self):
self.pool: Union[Pool, None] = None
async def create(self):
self.pool = await asyncpg.create_pool(
user=config.DB_USER,
password=config.DB_PASS,
host=config.DB_HOST,
database=config.DB_NAME,
max_inactive_connection_lifetime=3
)
async def execute(self, command, *args,
fetch: bool = False,
fetchval: bool = False,
fetchrow: bool = False,
execute: bool = False
):
async with self.pool.acquire() as connection:
connection: Connection
async with connection.transaction():
if fetch:
result = await connection.fetch(command, *args)
elif fetchval:
result = await connection.fetchval(command, *args)
elif fetchrow:
result = await connection.fetchrow(command, *args)
elif execute:
result = await connection.execute(command, *args)
return result
async def create_table_users(self):
sql = """
CREATE TABLE IF NOT EXISTS Users (
id SERIAL PRIMARY KEY,
full_name VARCHAR(255) NOT NULL,
username varchar(255) NULL,
telegram_id BIGINT NOT NULL UNIQUE
);
"""
await self.execute(sql, execute=True)
@staticmethod
def format_args(sql, parameters: dict):
sql += " AND ".join([
f"{item} = ${num}" for num, item in enumerate(parameters.keys(),
start=1)
])
return sql, tuple(parameters.values())