Làm thế nào để vô hiệu hóa bộ nhớ cache SQLAlchemy?

Question

Tôi gặp sự cố bộ nhớ cache khi tôi sử dụng sqlalchemy. Tôi sử dụng sqlalchemy chèn dữ liệu vào cơ sở dữ liệu mysql. Tôi có quá trình ứng dụng khác dữ liệu này sau đó cập nhật dữ liệu này trực tiếp. Nhưng sqlalchemy của tôi luôn có dữ liệu cũ hơn là dữ liệu cập nhật .. Tôi nghĩ rằng sqlalchemy đã lưu trong bộ nhớ cache yêu cầu của tôi .. vậy .. Làm thế nào để vô hiệu hóa nó?

Answer 1

Nguyên nhân thông thường cho mọi người nghĩ rằng có một "bộ nhớ cache" lúc chơi, ngoài bản đồ nhận dạng SQLAlchemy thông thường là cục bộ cho giao dịch, là họ đang quan sát ảnh hưởng của việc cô lập giao dịch. SQLAlchemy của phiên làm việc theo mặc định trong một chế độ giao dịch, có nghĩa là nó chờ đợi cho đến khi session.commit() được gọi là để duy trì dữ liệu vào cơ sở dữ liệu. Trong thời gian này, các giao dịch khác đang diễn ra ở nơi khác sẽ không thấy dữ liệu này.

Tuy nhiên, do tính chất cô lập của các giao dịch, có thêm một twist. Các giao dịch khác đang diễn ra sẽ không chỉ không thấy dữ liệu giao dịch của bạn cho đến khi nó được cam kết, họ cũng không thể thấy nó trong một số trường hợp cho đến khi họ cam kết hoặc quay lại cũng (đó là hiệu ứng tương tự mà bạn đóng() đây). Một giao dịch có mức độ trung bình là cách ly sẽ giữ trạng thái đã tải cho đến thời điểm này và giữ cho bạn cùng một trạng thái cục bộ cho giao dịch ngay cả khi dữ liệu thực đã thay đổi - được gọi là lần đọc trong giao dịch này cách ly.

http://en.wikipedia.org/wiki/Isolation_%28database_systems%29

Answer 2

Như tôi đã biết SQLAlchemy does not store caches, vì vậy bạn cần xem kết quả logging.

Answer 3

Đầu tiên, không có bộ nhớ cache cho SQLAlchemy. Dựa trên phương pháp của bạn để tìm nạp dữ liệu từ DB, bạn nên thực hiện một số kiểm tra sau khi cơ sở dữ liệu được cập nhật bởi những người khác, xem liệu bạn có thể lấy dữ liệu mới hay không.

(1) use connection: 
connection = engine.connect() 
result = connection.execute("select username from users") 
for row in result: 
    print "username:", row['username'] 
connection.close() 
(2) use Engine ... 
(3) use MegaData... 

xin folowing bước trong: http://docs.sqlalchemy.org/en/latest/core/connections.html

Một lý do khác có thể là MySQL DB của bạn không được cập nhật thường xuyên. Khởi động lại dịch vụ MySQL và có một kiểm tra.

Answer 4

Ngoài ra để zzzeek câu trả lời xuất sắc,

Tôi đã có một vấn đề tương tự. Tôi giải quyết vấn đề bằng cách sử dụng các phiên họp ngắn.

with closing(new_session()) as sess: 
    # do your stuff 

Tôi đã sử dụng phiên mới cho mỗi tác vụ, nhóm tác vụ hoặc yêu cầu (trong trường hợp ứng dụng web). Điều đó giải quyết vấn đề "bộ nhớ đệm" cho tôi.

Tài liệu này đã rất hữu ích cho tôi:

When do I construct a Session, when do I commit it, and when do I close it

Answer 5

Vấn đề này đã được thực sự bực bội đối với tôi, nhưng cuối cùng tôi đã tìm nó ra.

Tôi có một ứng dụng Flask/SQLAlchemy chạy cùng với một trang web PHP cũ hơn. Trang PHP sẽ ghi vào cơ sở dữ liệu và SQLAlchemy sẽ không nhận thức được bất kỳ thay đổi nào.

Tôi đã thử cài đặt phiên làm việc autoflush = True không thành công Tôi đã thử db_session.flush(), db_session.expire_all() và db_session.commit() trước khi truy vấn và KHÔNG làm việc. Vẫn hiển thị dữ liệu cũ.

Cuối cùng tôi đi qua phần này của tài liệu SQLAlchemy: http://docs.sqlalchemy.org/en/latest/dialects/postgresql.html#transaction-isolation-level

Thiết lập isolation_level làm việc tuyệt vời. Bây giờ ứng dụng Flask của tôi là "nói chuyện" với ứng dụng PHP. Dưới đây là các mã:

engine = create_engine(
       "postgresql+pg8000://scott:tiger@localhost/test", 
       isolation_level="READ UNCOMMITTED" 
      ) 

Khi động cơ SQLAlchemy được bắt đầu với "ĐỌC uncommited" isolation_level nó sẽ thực hiện "bẩn lần đọc" có nghĩa là nó sẽ đọc thay đổi uncommited trực tiếp từ cơ sở dữ liệu.

Hope this helps

---

Dưới đây là một giải pháp lịch sự có thể có của AaronD trong các ý kiến ​​

from flask.ext.sqlalchemy import SQLAlchemy 

class UnlockedAlchemy(SQLAlchemy): 
    def apply_driver_hacks(self, app, info, options): 
     if "isolation_level" not in options: 
      options["isolation_level"] = "READ COMMITTED" 
    return super(UnlockedAlchemy, self).apply_driver_hacks(app, info, options) 

Answer 6

này đã xảy ra trong ứng dụng Flask của tôi, và giải pháp của tôi đã hết hạn tất cả các đối tượng trong phiên sau mỗi yêu cầu.

from flask.signals import request_finished 
def expire_session(sender, response, **extra): 
    app.db.session.expire_all() 
request_finished.connect(expire_session, flask_app) 

Làm việc như một sự quyến rũ.