Microsoft Azure 数据仓库和 SqlAlchemy

Question

我正在尝试使用 python 的 sqlalchemy 库连接到 Microsoft Azure 数据仓库。并收到以下错误：

 (pyodbc.Error) ('HY000', '[HY000] [Microsoft][ODBC SQL Server Driver][SQL Server]Client driver version is not supported. (46722) (SQLDriverConnect); [HY000] [Microsoft][ODBC SQL Server Driver][SQL Server]Client driver version is not supported. (46722)')

我的 windows 连接代码：

import sqlalchemy
user_name = 'userName'
password = 'password'
uri = 'sqlServerName'
db_name = 'SQLDBName'
db_prefix = 'mssql+pyodbc://'
db_driver = '{SQL Server}'
connection_string = "{db_prefix}{user_name}:{password}@{uri}/{db_name}?Driver={driver}".format(
                db_prefix=db_prefix, user_name=user_name, password=password, uri=uri, db_name=db_name,
                driver=db_driver)
engine = sqlalchemy.engine.create_engine(connection_string, echo=echo, pool_size=20,
                                                          max_overflow=100)
engine.connect()  # throws the error

提前致谢！

Answer 1

根据您的代码，问题似乎是使用了不正确的 Driver={SQL Server}.

在Azure portal上，您可以按照下图的步骤获取连接字符串。

正确的 odbc 驱动程序名称应该是 Driver={ODBC Driver 13 for SQL Server}。同时，请按照 tutorial 为您当前的环境安装 3.1.1 或 pyodbc 的正确版本。

下面是我的测试代码。

import sqlalchemy

connection_string = "mssql+pyodbc://<user>@<server-host>:<password>@<server-host>.database.windows.net:1433/<database>?driver=ODBC+Driver+13+for+SQL+Server"
engine = sqlalchemy.engine.create_engine(connection_string)
engine.connect()

或

import sqlalchemy
import urllib

params = urllib.quote_plus("Driver={ODBC Driver 13 for SQL Server};Server=<server-host>.database.windows.net,1433;Database=<database>;Uid=<user>@<server-host>;Pwd=<password>;Encrypt=yes;TrustServerCertificate=no;Connection Timeout=30;")
engine = sqlalchemy.engine.create_engine("mssql+pyodbc:///?odbc_connect=%s" % params)
engine.connect()

当我运行上述代码时出现异常sqlalchemy.exc.ProgrammingError: (pyodbc.ProgrammingError) ('42000', "[42000] [Microsoft][ODBC Driver 13 for SQL Server][SQL Server]Catalog view 'dm_exec_sessions' is not supported in this version. (104385) (SQLExecDirectW)")，但似乎不影响工作。

而且我仅使用 pyodbc 测试了下面的代码，它运行良好。

import pyodbc
cnxn = pyodbc.connect("Driver={ODBC Driver 13 for SQL Server};Server=<server-host>.database.windows.net,1433;Database=<database>;Uid=<user>@<server-host>;Pwd=<password>;Encrypt=yes;TrustServerCertificate=no;Connection Timeout=30;")
cursor = cnxn.cursor()
cursor.execute("select @@VERSION")
row = cursor.fetchone()
if row:
    print row

输出：

(u'Microsoft Azure SQL Data Warehouse - 10.0.8529.1 Jan 13 2017 22:49:03 Copyright (c) Microsoft Corporation', )

Microsoft Azure 数据仓库和 SqlAlchemy

Microsoft Azure Data warehouse and SqlAlchemy

python

sqlalchemy

data-warehouse

azure

python-2.7