def request_pickup(connections, request_id):
env_path = connections.loc[0, 'm_drive']
hip_directory = connections.loc[0, 'hip_directory']
sys.path.append(env_path + '/global_info')
from py_variables import sqlalchemy_cnx_string, ssl_args
engine = sqlalchemy.create_engine(sqlalchemy_cnx_string,
connect_args = ssl_args)
pickup_info_query = (f'''
SELECT
fld40 as record_id,
fld3 as client_name
FROM rmf_tb.rfsocatalogrh
WHERE fld40 = {request_id}''')
pickup_info = pd.read_sql(pickup_info_query, engine)
if len(pickup_info) != 1:
sys.exit("Pickup Request Error")
失败的行位于 pd.read_sql 上
我们的目标是能够像之前一样运行 python 脚本而不会出现任何错误。
我们使用的是Python工具,该工具无需配置。
我们能够在本地设计师上运行工作流程,没有任何问题。
但是工作流程在服务器上失败并附加错误
SQLAlchemy版本:1.3.18 熊猫版本:2.0.3
Connection.exec_driver_sql
在1.4系列中被添加到SQLAlchemy中。
如果您想将 SQLA 1.3.x 与 Pandas 一起使用,您将需要安装 Pandas 1.3(这可能会导致大量依赖管理工作,因为它太旧了。
如果您想使用 Pandas 2.0.x,则需要安装 SQLAlchemy 1.4.16。
请参阅 Pandas 安装文档,其中列出了兼容的依赖项版本(页面右上角有一个版本下拉列表)。