通过Flask/SQLAlchemy使用Python3灵活引擎连接到google sql

Question

我已经将应用程序引擎升级到flexible，现在正在重构代码。除了standard和SQLAlchemy之外，我还没有使用过Flask。我已经设置了我的数据库，并且以前在standard环境中有过有效的、正常工作的连接。我现在尝试在Python3 flexible environment:中执行一个简单的SQL

SELECT id, latitude, longitude FROM weatherData

我现在通过以下方式与数据库建立了有效连接：

app = Flask(__name__)
app.config['WEATHER_DATABASE_URI'] = os.environ['WEATHER_DATABASE_URI']
app.config['SQLALCHEMY_TRACK_MODIFICATIONS'] = False
db = SQLAlchemy(app)

相应的环境变量在我的app.yaml文件中。

我知道SQLAlchemy使用ORM，但在我看到的所有示例中，它们都在客户端和数据库之间创建了一个类作为"缓冲区"，以首先创建表，然后执行CRUD操作。例如

engine = create_engine('sqlite:///student.db', echo=True)
Base = declarative_base()
class Student(Base):
""""""
__tablename__ = "student"
id = Column(Integer, primary_key=True)
username = Column(String)
firstname = Column(String)
lastname = Column(String)
university = Column(String)
#----------------------------------------------------------------------
def __init__(self, username, firstname, lastname, university):
""""""
self.username = username
self.firstname = firstname
self.lastname = lastname
self.university = university
# create tables
Base.metadata.create_all(engine)

我注意到在这种情况下，他们使用的是engine，这似乎与我无关。简而言之，我如何执行前面提到的SQL查询？

谢谢：(

Answer 1

SQLAlchemy使用它的engine类来控制与数据库的交互。首先，您创建一个引擎，指定要如何连接：

db = sqlalchemy.create_engine(
# Equivalent URL:
# mysql+pymysql://<db_user>:<db_pass>@/<db_name>?unix_socket=/cloudsql/<cloud_sql_instance_name>
sqlalchemy.engine.url.URL(
drivername='mysql+pymysql',
username=db_user,
password=db_pass,
database=db_name,
query={
'unix_socket': '/cloudsql/{}'.format(cloud_sql_instance_name)
}
)
}

第二，使用引擎检索到实例的连接并执行操作：

with db.connect() as conn:
recent_votes = conn.execute(
"SELECT candidate, time_cast FROM votes "
"ORDER BY time_cast DESC LIMIT 5"
).fetchall()

这允许SQLAlchemy以更高效的方式管理您的连接。如果您想在应用程序的上下文中看到这些片段，请查看此示例应用程序。