SQLAlchemy 1.4 / 2.0 support for aiohttp.
Project description
SQLAlchemy 1.4 / 2.0 support for AIOHTTP.
The library provides the next features:
initializing asynchronous sessions through a middlewares;
initializing asynchronous sessions through a decorators;
simple access to one asynchronous session by default key;
preventing attributes from being expired after commit by default;
support different types of request handlers;
support nested applications.
Documentation
Installation
pip install aiohttp-sqlalchemy
Simple example
Install aiosqlite for work with sqlite3:
pip install aiosqlite
Copy and paste this code in a file and run:
from aiohttp import web
import aiohttp_sqlalchemy
from aiohttp_sqlalchemy import sa_session
from datetime import datetime
import sqlalchemy as sa
from sqlalchemy import orm
metadata = sa.MetaData()
Base = orm.declarative_base(metadata=metadata)
class MyModel(Base):
__tablename__ = 'my_table'
pk = sa.Column(sa.Integer, primary_key=True)
timestamp = sa.Column(sa.DateTime(), default=datetime.now)
async def main(request):
db_session = sa_session(request)
async with db_session.begin():
db_session.add_all([MyModel()])
stmt = sa.select(MyModel)
result = await db_session.execute(stmt)
items = result.scalars()
data = {}
for item in items:
data[item.pk] = item.timestamp.isoformat()
return web.json_response(data)
async def app_factory():
app = web.Application()
aiohttp_sqlalchemy.setup(app, [
aiohttp_sqlalchemy.bind('sqlite+aiosqlite:///'),
])
await aiohttp_sqlalchemy.init_db(app, metadata)
app.add_routes([web.get('/', main)])
return app
if __name__ == '__main__':
web.run_app(app_factory())
Project details
Release history Release notifications | RSS feed
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
Built Distribution
Close
Hashes for aiohttp-sqlalchemy-0.15.4.tar.gz
Algorithm | Hash digest | |
---|---|---|
SHA256 | 539a2d17cc4786840fe65df603e9f8dc959ca44834377981d7e2c0b4af84221f |
|
MD5 | 150a4d5343c2a5cee72e7df46e7fdc1d |
|
BLAKE2b-256 | 1b8f2dd7d271ba6e1ef8f8fcb3ca9b4a43fc06eaa67cfad5ab5f4954355f8ae2 |
Close
Hashes for aiohttp_sqlalchemy-0.15.4-py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | 2f2bc6ec7d9ec98b1a006a41d196a575c01e3c0c3675f829fb676399b9625f88 |
|
MD5 | f1992e9bbdb3164990ca6379ac03e5eb |
|
BLAKE2b-256 | c19f1e2c169925b8e5e94c68b313f414178312e67d96f63d352300c1c3a6621a |