А что не работает то? Прописываешь конект и курсор и готово
ну, вот я так делаю
engine = create_async_engine(f'sqlite:///{DB_FILENAME}') # Движок базы данных
session_factory = sessionmaker(bind=engine)
Session = scoped_session(session_factory)
session = Session()
потом обращаюсь к session как в доке
message = Message(operator_id='', web_chat_id=data['chat_id'], msg=data['message'])
await session.add(message)
и не работает