chạy mã sau khi giao dịch cam kết trong Django

Question

Có cách nào để chạy một số mã sau khi giao dịch cam kết trong Django?

Tôi cần gửi một số thư tới máy chủ thỏmq để xử lý ngoại tuyến, nhưng thư được gửi đến người tiêu dùng trước khi giao dịch Django được cam kết.

Tin nhắn của tôi được gửi trong tín hiệu post_save của mô hình. Những gì tôi đang tìm kiếm là một cơ chế tương tự, sử dụng tín hiệu hoặc cái gì khác, mà sẽ thực thi mã sau khi cam kết (và không làm gì nếu giao dịch thất bại).

Tôi chưa tìm thấy bất kỳ cách chung nào để thực hiện việc đó ở Django. Bạn có bất cứ ý tưởng?

Answer 1

CẬP NHẬT 2: django-transaction-hooks là merged into Django core và được phát hành ở phiên bản Django 1.9.

CẬP NHẬT: django-transaction-hooks giải quyết vấn đề này.

Tôi không tin rằng có một cách sạch sẽ để làm điều này; ít nhất tôi cũng không thể nghĩ ra. Bạn có thể monkeypatch django.db.transaction.commit để gửi tín hiệu tùy chỉnh; không đẹp nhưng tôi nghĩ nó sẽ hoạt động.

Cũng có thể thú vị khi tăng trường hợp sử dụng này lên django-developers mailing list. Các nhà phát triển thường không thích thêm các tín hiệu mới, nhưng bạn có thể có một trường hợp tốt ở đây (và một sự bác bỏ từ một nhà phát triển cốt lõi có thể bao gồm một gợi ý hữu ích về cách giải quyết tình huống của bạn). Bạn có nhiều khả năng để có được phản ứng nếu bạn chờ đợi cho đến khi sau 1.1 đi ra, mặc dù.

Answer 2

Một khả năng sẽ là phân lớp trung gian giao dịch để nó gửi tín hiệu tùy chỉnh trên cam kết. Mã của bạn có thể nghe cho tín hiệu đó, thay vì post_save.

Answer 3

tôi đã thực hiện các tín hiệu giao dịch (post_commit và post_rollback) bởi khỉ vá django: http://gist.github.com/247844

Answer 4

Có một cái nhìn tại django-celery-transactions kiếm một giải pháp cho việc này.

Gần đây tôi đã hoàn thành việc tách ra và tái cấu trúc mã mã tín hiệu cơ bản thành ứng dụng độc lập django-db-signals.

Answer 5

Hy vọng điều này có thể giúp ai đó sử dụng Django 1.9 trở lên. Kể từ 1.9 on_commit khả dụng.

Vì vậy, về cơ bản bạn sẽ được làm việc đó như thế này:

from django.db import transaction 

transaction.on_commit(
    lambda: send_msg_to_rabbitmqp(param1, param2, ...) 
) 

Nếu bạn muốn giữ lại post_save, bạn vẫn có thể sử dụng on_commit:

@receiver(pre_save, sender=MyModel) 
def my_handler(sender, instance, created, **kwargs): 
    transaction.on_commit(
     lambda: send_msg_to_rabbitmqp(instance.id) 
    )