def create_session():
    engine = create_engine(con_str)
    session_factory = sessionmaker(bind=engine)
    Session = scoped_session(session_factory)
    return Session()