蟒蛇+ SQLAlchemy的：調用循環

Question

存儲過程我有一個Python腳本，定期查詢數據（使用SQLAlchemy的0.7.4）MySQL數據庫。它通過運行存儲過程來實現。如果過程返回任何內容，腳本將嘗試處理數據（這部分與數據塊無關），然後使用第二個過程保存結果。

這將睡在一定時間（通常爲一分鐘），並給它的所有又一次，直到停止後。它應該能夠運行數週。

我會經常收到此錯誤：「無法重新連接，直到無效的事務回滾」。我做了使用各種信息的一些變化，我可以找到這一點，我想知道這是否是我想要的達到的一個好辦法：

from sqlalchemy import create_engine, exc 
from sqlalchemy.orm import sessionmaker 
from sqlalchemy import text, func 
import time 

class StoredProcedures(): 
    _engine = None 
    _connection = None 
    _session = None 

    def __init__(self, cs): 
     self._engine = create_engine(cs, encoding='utf-8', echo=False, pool_recycle=600) 
     self._connection = self._engine.connect() 
     Session = sessionmaker(bind=self._engine) 
     self._session = Session() 

    def sp_test_1(self, user_id): 
     t = self._session.begin(subtransactions=True) 

     try: 
      query = 'call sp_get_files(%d)'%user_id 
      result = self._session.execute(query).fetchall() 
      t.close() 
      return result 
     except exc.DBAPIError, e: #Proper way of reconnecting? 
      t.rollback() 
      time.sleep(5) 
      self._connection = self._engine.connect() 
      Session = sessionmaker(bind=self._engine) 
      self._session = Session() 
     except: 
      t.rollback() 

     return None 


cs = "mysql://test:test@127.0.0.1/test_db" 
db_stored_procedures = StoredProcedures(cs) 

while (True): 
    files = db_stored_procedures.sp_test_1(1) 
    if len(files) > 0: 
     print "This is where processing happens" 
     #And this is where the second procedure would be called to store the results 
    time.sleep(15) 

我測試了這一點，但我幾乎只寫了所以我沒有做任何長期的測試。我想先徵求你的意見。

編輯： 我原來使用的連接執行查詢，像這樣（省略大部分的腳本是同上一）：

def sp_test_1(self, user_id): 
    t = self._connection.begin() 

    try: 
     query = 'call sp_get_files(%d)'%user_id 
     result = self._connection.execute(query).fetchall() 
     t.close() 
     return result 
    except exc.DBAPIError, e: 
     #same as above 
    except: 
     t.rollback() 

    return None 

Answer 1

您使用會話接口，which uses a Transaction object internally所以我不認爲你需要做你自己的事務管理。

我沒有看到任何東西太多需要超越簡單：

def sp_test_1(self, user_id): 

    query = 'call sp_get_files(%d)'%user_id 
    result = self._session.execute(query).fetchall() 
    return result 

如果產生相同的例外，如果你發佈完整的堆棧跟蹤將是有益的。例外是朋友而不是對手。 :)