python - 结果 : Failure Exception: AttributeError: 'Engine' object has no attribute 'execute' Azure Functions

Question

我对 Azure Functions 还很陌生。由于某种原因，此代码在本地运行，但当部署到 Azure Function 时，会出现此错误。

from sqlalchemy import create_engine, event
import textwrap
import base64
import pandas as pd
import logging
import pyodbc

def sql_run_query(data_base,service_date):
    driver = '{ODBC Driver 17 for SQL Server}'
    server_name = **********************************
    database_name = data_base
    server='{server_name},1433'.format(server_name=server_name)
    username = **********************************
    password = **********************************
    connection_string=textwrap.dedent('''Driver={driver};Server={server};Database={database};Uid={username};Pwd={password};Encrypt=yes;TrustServerCertificate=no;Connection Timeout=30;'''.format(driver=driver,server=server,database=database_name,username=username,password=password))
    engine = create_engine('mssql+pyodbc:///?odbc_connect='+connection_string)
    #engine =create_sql_engine(data_base)
    engine.execute('declare @service_date_var as varchar(100) = '+service_date+'delete from [dbo].[performance] where service_date = @service_date_var')
    logging.info(f"query in {data_base} run succesfully")
    print(f"query in {data_base} run succesfully")

结果:失败异常:AttributeError:'Engine'对象没有属性'execute'堆栈:文件“/azure-functions-host/workers/python/3.9/LINUX/X64/azure_functions_worker/dispatcher.py”，第452行，在 _handle__invocation_request call_result = wait self._loop.run_in_executor( File "/usr/local/lib/python3.9/concurrent/futures/thread.py", line 58, in run result = self.fn(*self.args, **self.kwargs)文件“/azure-functions-host/workers/python/3.9/LINUX/X64/azure_functions_worker/dispatcher.py”，第718行，在_run_sync_func中返回ExtensionManager.get_sync_in Vocation_wrapper(上下文，文件“/azure-functions” -host/workers/python/3.9/LINUX/X64/azure_functions_worker/extension.py”，第 215 行，在 _raw_invocation_wrapper result = function(**args) 文件“/home/site/wwwroot/BlobTrigger2/init.py”，第 40 行，在主 sql_run_query('kad_smc',dte) 文件“/home/site/wwwroot/sql_uploader/sql_uploader.py”，第 74 行，在 sql_run_query engine.execute('''

有人可以解释一下这个问题的原因以及可能的解决方法吗？

谢谢!

Answer 1

deprecated SQLAlchemy 2.0 中删除了 engine 的 execute 方法。您需要确保在两个环境中运行相同版本的 SQLAlchemy 并考虑 migrating到 v2.0。