Làm thế nào để chia sẻ dữ liệu giữa các yêu cầu trong Tornado Web

Question

Tôi có trường hợp sử dụng sau cho máy chủ của tôi Tornado web:

Khi POST yêu cầu mục có thể được thực hiện cho các máy chủ, các mục mà sẽ không được tiếp tục tồn vào một tập tin hoặc cơ sở dữ liệu . Khi GET yêu cầu một quá trình có thể được bắt đầu hoặc chấm dứt.

Do đó, tôi cần chia sẻ dữ liệu giữa các yêu cầu khác nhau trong triển khai RequestHandler của mình. Cách bình thường để làm như vậy là gì?

Tôi gặp khó khăn khi lưu dữ liệu vào self, ví dụ: self.entry = "...". Trong một yêu cầu khác, dữ liệu không còn hiện diện nữa.

Giải pháp duy nhất làm việc tôi đã tìm thấy là để lưu trữ trong đối tượng áp dụng:

application = web.Application([ 
      (r'.*', MainHandler, 
      ]) 

và

def get(self): 
     # ... 
     self.application.entry = "..." 

Đó có phải là cách thích hợp? Ngoài ra những gì về đồng bộ hóa ở đây, tôi có nghĩa là điều này có nghĩa là truy cập vào dữ liệu được chia sẻ.

Answer 1

Tôi đề nghị như sau: Thay vì một đối tượng truy cập cơ sở dữ liệu thông qua một đối tượng mà các cửa hàng dữ liệu của bạn, ví dụ:

data = DataStore() 

application = web.Application([ 
     (r'.*', MainHandler, dict(data = data), 
     ]) 

với phương pháp RequestHandler khởi sau.

def initialize(self, data): 
    self.data = data 

Bạn phải tạo đối tượng trước và vượt qua đối tượng đó, nếu không nó sẽ được tạo lại mỗi lần yêu cầu được xử lý.

Answer 2

Bạn có thể sử dụng memcached cho mục đích tương tự. Tuy nhiên, bạn sẽ cần phải thiết lập máy chủ memcached.

http://pypi.python.org/pypi/python-memcached/

Answer 3

Application là đối tượng quyền cửa hàng (bán) dữ liệu liên tục. Tuy nhiên, như được đề xuất trên anwser khác, bạn nên xem xét sử dụng một số loại cơ sở dữ liệu để lưu trữ dữ liệu này.

Tuy nhiên, bạn nên lưu ý rằng một phiên (hoặc giao dịch) không hoàn thành đúng (ví dụ bạn nhận được POST nhưng không GET để kích hoạt hành động), bạn nên xóa dữ liệu phiên để không có bộ nhớ rò rỉ máy chủ web.

Từ kinh nghiệm của mình, tôi khuyên bạn nên sử dụng Redis vì nó dễ sử dụng và hỗ trợ key expiration, một cơ chế hữu ích khi bạn cần quản lý dữ liệu phiên.

Answer 4

Các documentation đưa ra một cách để làm điều này:

class MyHandler(RequestHandler): 
    def initialize(self, database): 
     self.database = database 

    def get(self, username): 
     ... 

mydatabase = dict() 

app = Application([ 
    (r'/user/(.*)', MyHandler, dict(database=mydatabase)), 
    ]) 

Sau đó, bạn có thể tiết kiệm đối tượng của bạn mydatabase vào một tập tin.

Nhưng tôi không chắc đây là cách phù hợp để đạt được những gì bạn muốn về việc đồng bộ hóa giữa các yêu cầu.