Đa luồng cho Python Django

Question

Một số chức năng sẽ chạy không đồng bộ trên máy chủ web. Gửi email là ví dụ điển hình.

Cách tốt nhất (hoặc đa số nhất) viết một hàm trang trí để chạy hàm không đồng bộ?

thiết lập của tôi là một chung một: Python 2.4.7, Django 1.4, Gunicorn 0.17.2

Ví dụ, đây là một khởi đầu:

from threading import Thread 

def postpone(function): 
    def decorator(*args, **kwargs): 
     t = Thread(target = function, args=args, kwargs=kwargs) 
     t.daemon = True 
     t.start() 
    return decorator 

mong muốn sử dụng:

@postpone 
def foo(): 
    pass #do stuff 

Answer 1

Tôi đã đăng câu hỏi trên 18 tháng trước. Kể từ đó, tôi đã tiếp tục sử dụng triển khai này ở quy mô lớn và trong sản xuất mà không có vấn đề gì.

Decorator định nghĩa:

from threading import Thread 
def postpone(function): 
    def decorator(*args, **kwargs): 
    t = Thread(target = function, args=args, kwargs=kwargs) 
    t.daemon = True 
    t.start() 
    return decorator 

Ví dụ sử dụng:

@postpone 
def foo(): 
    #do stuff 

Theo thời gian, chồng đã được cập nhật và chuyển mà không thất bại.

Nguyên bản là 2.4.7, Django 1.4, Gunicorn 0.17.2, bây giờ là Python 2.4.7, Django 1.9, Waitress 0.8.9.

Nếu bạn đang sử dụng bất kỳ giao dịch cơ sở dữ liệu, Django sẽ tạo ra một kết nối mới và điều này cần phải được tự đóng:

from django.db import connection 

@postpone 
def foo(): 
    #do stuff 
    connection.close() 

Answer 2

Cách phổ biến nhất để xử lý không đồng bộ ở Django là sử dụng Celery và django-celery.

Answer 3

Celery là hàng đợi công việc không đồng bộ/hàng đợi công việc. Nó được tài liệu hóa và hoàn hảo cho những gì bạn cần. Tôi khuyên bạn nên bắt đầu here