網(wǎng)站建設(shè)一般多少錢官網(wǎng),成都旅游公司排名前十,免費(fèi)做爰小說網(wǎng)站,網(wǎng)站開發(fā)的教學(xué)網(wǎng)站從報(bào)錯(cuò)截圖來看#xff0c;核心錯(cuò)誤信息是#xff1a; mysql.connector.errors.OperationalError: 1040 (08004): Too many connections 這意味著你的 Python 程序#xff08;具體是在 Streamlit 框架下運(yùn)行#xff09;向 MySQL 數(shù)據(jù)庫發(fā)起了過多的連接請(qǐng)求#xff0c;超出…從報(bào)錯(cuò)截圖來看核心錯(cuò)誤信息是mysql.connector.errors.OperationalError: 1040 (08004): Too many connections這意味著你的 Python 程序具體是在 Streamlit 框架下運(yùn)行向 MySQL 數(shù)據(jù)庫發(fā)起了過多的連接請(qǐng)求超出了數(shù)據(jù)庫允許的最大并發(fā)連接數(shù)默認(rèn)為 151并且之前的連接沒有被及時(shí)關(guān)閉。為什么會(huì)發(fā)生這種情況連接未關(guān)閉Connection Leak代碼中打開了數(shù)據(jù)庫連接connect()但在使用完后沒有調(diào)用conn.close()。Streamlit 的運(yùn)行機(jī)制我注意到報(bào)錯(cuò)路徑中有streamlit。Streamlit 的特點(diǎn)是每當(dāng)用戶與頁面交互點(diǎn)擊按鈕、刷新等時(shí)整個(gè) Python 腳本會(huì)從頭到尾重新運(yùn)行一次?？茨愕拇a位置utilsscm_db.py第 9 行直接執(zhí)行了conn mysql.connector.connect(...)。每次頁面刷新這行代碼就運(yùn)行一次創(chuàng)建一個(gè)新連接。舊連接還在占用資源新連接不斷增加很快就耗盡了 MySQL 的連接池。解決方案方案一使用 Streamlit 的緩存機(jī)制推薦最適合你的場(chǎng)景在 Streamlit 中數(shù)據(jù)庫連接應(yīng)該被緩存確保整個(gè)應(yīng)用只創(chuàng)建一次連接而不是每次刷新都創(chuàng)建。修改utils/scm_db.pyimportmysql.connectorimportstreamlitasst# 你的 Settings 導(dǎo)入# 使用 st.cache_resource 裝飾器確保連接只被創(chuàng)建一次st.cache_resourcedefinit_connection():returnmysql.connector.connect(hostSettings.DB_HOST,userSettings.DB_USER,passwordSettings.DB_PASSWORD,databaseSettings.DB_NAME)# 在其他文件中調(diào)用時(shí)# conn init_connection()注意st.cache_resource是 Streamlit 新版的方法舊版可能叫st.experimental_singleton。方案二確保連接即用即關(guān)標(biāo)準(zhǔn)做法如果你不需要長(zhǎng)連接應(yīng)當(dāng)在查完數(shù)據(jù)后立刻關(guān)閉連接。最好使用try...finally或者上下文管理器。# 修改你的調(diào)用邏輯defget_data():connNonecursorNonetry:connmysql.connector.connect(host...,...)# 建立連接cursorconn.cursor()# 執(zhí)行查詢cursor.execute(SELECT * FROM ...)resultcursor.fetchall()returnresultexceptExceptionase:print(e)finally:# 無論是否報(bào)錯(cuò)這里都會(huì)執(zhí)行確保關(guān)閉連接ifcursor:cursor.close()ifconn:conn.close()方案三臨時(shí)解決重啟服務(wù)為了立刻讓程序能跑起來你需要清除當(dāng)前占滿的“僵尸”連接重啟 MySQL 服務(wù)這會(huì)強(qiáng)制斷開所有現(xiàn)有連接。Windows: 在“服務(wù)”中找到 MySQL 并重啟。Linux:sudo service mysql restart重啟 Streamlit 應(yīng)用關(guān)閉終端里的 Streamlit 進(jìn)程并重新運(yùn)行。方案四增加 MySQL 最大連接數(shù)治標(biāo)不治本如果你的應(yīng)用確實(shí)需要很高并發(fā)通常開發(fā)環(huán)境不需要可以在 MySQL 中修改配置。登錄 MySQL 命令行。執(zhí)行命令查看當(dāng)前限制SHOW VARIABLES LIKE max_connections;臨時(shí)修改限制例如改為 1000SET GLOBAL max_connections 1000;總結(jié)問題出在Streamlit 每次刷新頁面都重新執(zhí)行了連接數(shù)據(jù)庫的代碼且沒有關(guān)閉舊連接。請(qǐng)優(yōu)先采用方案一進(jìn)行代碼優(yōu)化。這是一個(gè)非常好的問題觸及了 SQLAlchemy通常配合 pandas 使用的核心機(jī)制——連接池Connection Pooling。簡(jiǎn)單直接的回答是算一次連接嗎是的它會(huì)占用或者建立一個(gè)與數(shù)據(jù)庫的會(huì)話。如何關(guān)閉你不需要也不能手動(dòng)關(guān)閉它。只要你傳給read_sql的是enginepandas 會(huì)自動(dòng)處理“借出連接”和“歸還連接”的操作。但結(jié)合你之前遇到的Too many connections報(bào)錯(cuò)這里有很深的“坑”請(qǐng)仔細(xì)看下面的分析一、pd.read_sql的內(nèi)部機(jī)制當(dāng)你執(zhí)行如下代碼時(shí)importpandasaspdfromsqlalchemyimportcreate_engine# 假設(shè) engine 已經(jīng)創(chuàng)建好dfpd.read_sql(SELECT * FROM table,engine)Pandas 內(nèi)部其實(shí)做了以下事情向 Engine 申請(qǐng)連接它調(diào)用engine.connect()。連接池機(jī)制如果連接池里有空閑連接Engine 直接把舊連接拿來用速度快MySQL 看來連接數(shù)沒變。如果連接池是空的Engine 會(huì)創(chuàng)建一個(gè)新的物理連接MySQL 的Threads_connected1。執(zhí)行 SQL利用這個(gè)連接讀取數(shù)據(jù)。自動(dòng)關(guān)閉歸還數(shù)據(jù)讀取完畢后Pandas 會(huì)自動(dòng)調(diào)用連接的.close()方法。關(guān)鍵點(diǎn)來了對(duì)于 SQLAlchemy 的 Engine 來說.close()并不代表斷開 TCP 連接而是代表**“把連接還給連接池”。所以在 MySQL 服務(wù)端看來這個(gè)連接依然是連著Sleep**的狀態(tài)等待下一次被復(fù)用。二、 既然自動(dòng)關(guān)閉為什么還會(huì)報(bào)錯(cuò)既然read_sql會(huì)自動(dòng)歸還連接為什么你還會(huì)遇到連接數(shù)過多的報(bào)錯(cuò)罪魁禍?zhǔn)走€是 Streamlit 的刷新機(jī)制。如果你的代碼是這樣寫的在 Streamlit 中# 錯(cuò)誤寫法每次刷新頁面都會(huì)運(yùn)行這幾行enginecreate_engine(mysqlmysqlconnector://user:passhost/db)dfpd.read_sql(SELECT * FROM table,engine)發(fā)生了什么第 1 次刷新創(chuàng)建了Engine對(duì)象_A自帶一個(gè)連接池。read_sql建立了一個(gè)連接Conn_1。用完后Conn_1 回到了Engine對(duì)象_A的池子里。第 2 次刷新腳本重新運(yùn)行創(chuàng)建了Engine對(duì)象_B自帶新的連接池。read_sql建立了一個(gè)連接Conn_2。用完后Conn_2 回到了Engine對(duì)象_B的池子里。問題Engine對(duì)象_A雖然被 Python 變量拋棄了但它建立的 Conn_1 還在 MySQL 那邊掛著直到 Python 進(jìn)行垃圾回收GC或者 MySQL 超時(shí)這個(gè)連接才會(huì)斷。第 1000 次刷新你創(chuàng)建了 1000 個(gè) Engine 對(duì)象MySQL 里掛了 1000 個(gè) Sleep 的連接 ——BOOM! Too many connections.三、 正確的解決方案你要做的不是“手動(dòng)關(guān)閉連接”而是**“防止重復(fù)創(chuàng)建 Engine”。你需要讓整個(gè) Streamlit 應(yīng)用無論刷新多少次全局只使用同一個(gè)** Engine 對(duì)象。寫法 1使用 Streamlit 緩存 Engine強(qiáng)烈推薦修改你的utils/scm_db.py或相關(guān)文件importpandasaspdfromsqlalchemyimportcreate_engineimportstreamlitasst# 使用 st.cache_resource 裝飾器# 這告訴 Streamlit這個(gè)函數(shù)的返回值engine要存起來緩存# 下次再調(diào)用這個(gè)函數(shù)直接返回存起來的那個(gè)不要重新執(zhí)行內(nèi)部代碼。st.cache_resourcedefget_db_engine():# 這里填寫你的連接字符串enginecreate_engine(mysqlmysqlconnector://root:passwordhost:3306/db_name)returnengine# 在主程序中使用defmain():# 獲取唯一的 engine 實(shí)例engineget_db_engine()# 放心讀取由 Engine 自動(dòng)管理連接池dfpd.read_sql(SELECT * FROM my_table,engine)st.dataframe(df)寫法 2如果不使用緩存不推薦如何強(qiáng)制銷毀如果你實(shí)在不想用緩存通常不建議你必須顯式地銷毀 Engine 以斷開物理連接enginecreate_engine(...)try:dfpd.read_sql(sql,engine)finally:# 強(qiáng)制銷毀 Engine這會(huì)切斷池子里所有的物理連接engine.dispose()總結(jié)pd.read_sql(sql, engine)會(huì)自動(dòng)處理連接的開啟和關(guān)閉歸還給池子你不需要手動(dòng)寫conn.close()。你的報(bào)錯(cuò)是因?yàn)橹貜?fù)創(chuàng)建了太多 Engine 對(duì)象每個(gè)對(duì)象后面都拖著一堆空閑連接沒斷開。解決方法使用st.cache_resource緩存create_engine的結(jié)果確保全局只有一個(gè) Engine。