部署在Google-App-Engine上的Python應用程序很少引發異常

Question

我已經在Python-App-Engine上部署了一個網站。

由於GAE不保證「保活」，我實現了一個無狀態服務器：

1. 在內部變量的每一個變化，他們會立即存入GQL資料庫。

2. 無論何時啓動進程，所有內部變量都從GQL數據庫加載。

我有很少拋出異常的情況下，我一直沒能追查：

• 客戶端發送一個同步AJAX POST請求。

• 服務器創建會話並在響應中發送唯一的會話ID。

• 客戶端以session-ID作爲參數發送同步AJAX GET請求。

• 服務器在響應中發送一些文本消息。

由於客戶端請求是同步的，整個序列也是同步的。

這裏是我的服務器內的相關映射：

from webapp2 import WSGIApplication 
from Handler import MyRequestHandler 

app = WSGIApplication([ 
    ('/request1' ,MyRequestHandler), # post request 
    ('/request2(.*)',MyRequestHandler), # get request 
]) 

下面是相關請求處理我的服務器中：

from webapp2 import RequestHandler 
from Server import MyServer 

myServer = MyServer() 

class MyRequestHandler(RequestHandler): 
    def post(self): 
     try: 
      if self.request.path.startswith('/request1'): 
       sessionId = myServer.GetNewSessionId() 
       self.SendContent('text/plain',sessionId) 
     except Exception,error: 
      self.SendError(error) 
    def get(self,sessionId): 
     try: 
      if self.request.path.startswith('/request2'): 
       textMessage = myServer.GetMsg(sessionId) 
       self.SendContent('text/plain',textMessage) 
     except Exception,error: 
      self.SendError(error) 
    def SendContent(self,contentType,contentData): 
     self.response.set_status(200) 
     self.response.headers['content-type'] = contentType 
     self.response.headers['cache-control'] = 'no-cache' 
     self.response.write(contentData) 
    def SendError(self,error): 
     self.response.set_status(500) 
     self.response.write(error.message) 

這裏是內部實現的我服務器：

class MyServer(): 
    def __init__(self): 
     self.sessions = SessionsTable.ReadSessions() 
    def GetNewSessionId(self): 
     while True: 
      sessionId = ... # a 16-digit random number 
      if SessionsTable.ReserveSession(sessionId): 
       self.sessions[sessionId] = ... # a text message 
       SessionsTable.WriteSession(self.sessions,sessionId) 
       return sessionId 
    def GetMsg(self,sessionId): 
     return self.sessions[sessionId] 

最後，這裏是我的服務器中的數據的基礎保養：

from google.appengine.ext import db 

class SessionsTable(db.Model): 
    message = db.TextProperty() 
    @staticmethod 
    def ReadSessions(): 
     sessions = {} 
     for session in SessionsTable.all(): 
      sessions[session.key().name()] = session.message 
     return sessions 
    @staticmethod 
    @db.transactional 
    def ReserveSession(sessionId): 
     if not SessionsTable.get_by_key_name(sessionId): 
      SessionsTable(key_name=sessionId,message='').put() 
      return True 
     return False 
    @staticmethod 
    def WriteSession(sessions,sessionId): 
     SessionsTable(key_name=sessionId,message=sessions[sessionId]).put() 
    @staticmethod 
    def EraseSession(sessionId): 
     SessionsTable.get_by_key_name(sessionId).delete() 

例外本身表明使用sessionId鍵sessions詞典的非法訪問。根據我的觀察，只有當服務器在「睡眠」了相當長的時間（如幾天左右）之後啓動此問題開始時描述的客戶機 - 服務器序列時纔會發生。它可能會提供某種線索來解決這個問題的根源，儘管我無法看到它。

我的問題：

1. 有什麼明顯的錯誤與我的設計？

2. 有沒有人在GAE上遇到類似的問題？

3. 有沒有人看到一個明顯的解決方案，甚至可能有助於理解這個問題的調試方法？

感謝

Answer 1

您錯誤地假定所有請求都由同一個實例處理。事實並非如此：與大多數託管環境一樣，GAE不能保證哪個服務器進程能夠處理任何請求。

您的實現正在使用模塊級變量myServer，它是一個具有自己的實例變量的類實例。但是每個服務器進程都有自己的myServer實例，並且它們不在進程之間共享：所以在一個請求中創建的字典條目不一定會存在於第二個進程中。

您需要考慮如何在實例間持久保存這些數據。真的，數據存儲首先是這樣的;如果您擔心開銷，則應該使用memcache進行調查。