Revert "clear database_engine imports"
Some checks reported errors
continuous-integration/drone/push Build was killed
Some checks reported errors
continuous-integration/drone/push Build was killed
This reverts commit de9c0e6724.
This commit is contained in:
@@ -1,8 +1,14 @@
|
|||||||
import os
|
import os
|
||||||
from sqlalchemy.ext.asyncio import async_sessionmaker, create_async_engine
|
import asyncpg
|
||||||
|
from sqlalchemy.ext.asyncio import async_sessionmaker, create_async_engine, session
|
||||||
|
import dotenv
|
||||||
|
|
||||||
|
# connection = psycopg2.connect(*(os.getenv(key) for key in ["DATABASE", "DB_HOST", "DB_USER", "DB_PASSWORD"]))
|
||||||
|
# connection.autocommit = True
|
||||||
|
|
||||||
|
dotenv.load_dotenv(".env")
|
||||||
DATABASE_URL = (f"postgresql+asyncpg://{os.getenv('DB_USER')}:{os.getenv('DB_PASSWORD')}@"
|
DATABASE_URL = (f"postgresql+asyncpg://{os.getenv('DB_USER')}:{os.getenv('DB_PASSWORD')}@"
|
||||||
f"{os.getenv('DB_HOST')}/{os.getenv('DATABASE')}")
|
f"{os.getenv('DB_HOST')}/{os.getenv('DATABASE')}")
|
||||||
|
print(DATABASE_URL)
|
||||||
engine = create_async_engine(DATABASE_URL, echo=True)
|
engine = create_async_engine(DATABASE_URL, echo=True)
|
||||||
async_session_ = async_sessionmaker(bind=engine, expire_on_commit=False)
|
async_session_ = async_sessionmaker(bind=engine, expire_on_commit=False)
|
||||||
|
|||||||
Reference in New Issue
Block a user