SQLAlchemy 2.0 support for aiohttp.
Project description
SQLAlchemy 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 datetime import datetime
import sqlalchemy as sa
from aiohttp import web
from sqlalchemy import orm
import aiohttp_sqlalchemy as ahsa
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):
sa_session = ahsa.get_session(request)
async with sa_session.begin():
sa_session.add(MyModel())
result = await sa_session.execute(sa.select(MyModel))
result = result.scalars()
data = {
instance.pk: instance.timestamp.isoformat()
for instance in result
}
return web.json_response(data)
async def app_factory():
app = web.Application()
ahsa.setup(app, [
ahsa.bind('sqlite+aiosqlite:///'),
])
await ahsa.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-1.0.post0.tar.gz
Algorithm | Hash digest | |
---|---|---|
SHA256 | 1606e7114492a621d2a7ade4740fd4cd78d0d73937b6368adfc55cd4565de8ab |
|
MD5 | 9af9b8c5a4a9bb1ad65f797092481975 |
|
BLAKE2b-256 | a706fcc11f54c75fa7f62847fd2068a3e387241fb09d7b04bbfcf703b88bdd55 |
Close
Hashes for aiohttp_sqlalchemy-1.0.post0-py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | 3fffd32e7bad10d7ee386d4ef47ec9de4dcf3925a19c0dadd3eea633ba64989d |
|
MD5 | 081ef4f5746d7ddff9408355befe15ed |
|
BLAKE2b-256 | c0d2dbb71c841ef84baad2be5a4039bc99dd42fe30ff27c257209f5a5aef51fc |