Python df.to_sql导致挂起和挂起

2024-06-16 09:05:27 发布

您现在位置:Python中文网/ 问答频道 /正文

我有一个间歇性的问题,当我尝试向sql表插入数据帧时,它只是挂起并且没有完成。当我使用sp_whoisactive检查时,它显示进程已挂起

这是与插入相关的Python位

        engine_insert = sqlalchemy.create_engine("mssql+pyodbc:///?odbc_connect={}".format(params))
        conn_insert = engine_insert.raw_connection()
        print("Inserting " + str(len(insertDf)) + " to db")
        print(" - Insert to DB")
        
        # Python/SQL hangs here
        insertDf.to_sql(name="RecommendedMembers", con=engine_insert, if_exists="append", schema="EDWanalytics.ML", index=False)
        conn_insert.commit()
        
        # This part never gets reached ... SQL hangs at above
        cursor_insert = conn_insert.cursor()
        query = """
            SET NOCOUNT ON;
            exec EDWAnalytics.ML.pUpdateAccountNumbers;
            exec EDWAnalytics.ML.pUpdateRecommendationHash;
            exec EDWAnalytics.ML.pParseRecommendationFactors;
            exec EDWAnalytics.ML.pUpdateLatestRecommendations;            
            """
        cursor_insert.execute(query)

Tags: to数据sqlconnquerymlcursorengine