我试图在一个Databricks集群上使用SQLAlchemy连接到一个SQL Server数据库。
我有一些简单的代码,看起来像这样。
db_conn_str = "mssql+pyodbc://<user-name>:<password>@<server-name>.database.windows.net:1433/<database-name>?driver=SQL Server"
engine = sa.create_engine(db_conn_str)
metadata = sa.MetaData(bind=None)
table = sa.Table(
table_name,
metadata,
autoload=True,
autoload_with=engine,
schema=TABLE_SCHEMA
注意:这段代码实际上是写在我从Databricks调用的一个自定义Python包中。