Quy trình bình thường dài

Question

Tôi phải thực hiện một số công việc dài trong ứng dụng Flask của mình. Và tôi muốn làm điều đó không đồng bộ. Chỉ cần bắt đầu làm việc, và sau đó kiểm tra trạng thái từ javascript.

Tôi đang cố gắng để làm một cái gì đó như:

@app.route('/sync') 
def sync(): 
    p = Process(target=routine, args=('abc',)) 
    p.start() 

    return "Working..." 

Nhưng điều này tạo ra công nhân gunicorn không còn tồn tại.

Làm cách nào để giải quyết? Tôi có nên dùng thứ gì đó như Celery không?

Answer 1

Có nhiều tùy chọn. Bạn có thể phát triển giải pháp của riêng bạn, sử dụng Celery hoặc Twisted (Tôi chắc chắn có nhiều tùy chọn đã được tạo sẵn ở đó nhưng đó là những tùy chọn phổ biến nhất).

Phát triển giải pháp nội bộ của bạn không khó. Bạn có thể sử dụng mô-đun multiprocessing của thư viện chuẩn Python:

• Khi tác vụ đến, bạn chèn hàng vào cơ sở dữ liệu của bạn với id công việc và trạng thái.
• Sau đó, khởi chạy quy trình để thực hiện công việc cập nhật trạng thái hàng khi kết thúc.
• Bạn có thể có một chế độ xem để kiểm tra xem tác vụ đã hoàn tất chưa, điều đó thực sự chỉ kiểm tra trạng thái trong tương ứng.

Tất nhiên bạn phải nghĩ nơi bạn muốn lưu trữ kết quả tính toán và điều xảy ra với lỗi.

Đi với cần tây cũng dễ dàng. Nó sẽ giống như sau. Để xác định một chức năng được thực hiện không đồng bộ:

@celery.task 
def mytask(data): 

    ... do a lot of work ... 

Sau đó, thay vì gọi nhiệm vụ trực tiếp, giống như mytask(data), trong đó sẽ thực hiện nó ngay lập tức, sử dụng delay phương pháp:

result = mytask.delay(mydata) 

Cuối cùng, bạn có thể kiểm tra xem kết quả có sẵn hay không với ready:

result.ready() 

Tuy nhiên, hãy nhớ lại R để sử dụng Celery bạn phải chạy một quy trình công nhân bên ngoài.

Tôi chưa từng nhìn vào Twisted vì vậy tôi không thể nói cho bạn biết nó có phức tạp hơn hay không (nhưng bạn cũng nên làm những gì bạn muốn làm).

Trong mọi trường hợp, bất kỳ giải pháp nào cũng hoạt động tốt với Flask. Để kiểm tra kết quả, không quan trọng ở tất cả nếu bạn sử dụng Javascript. Chỉ cần thực hiện chế độ xem để kiểm tra trạng thái trả về JSON (bạn có thể sử dụng Flask's jsonify).

Answer 2

Tôi sẽ sử dụng một nhà môi giới thư như rabbitmq hoặc activemq. Quy trình bình sẽ thêm công việc vào hàng đợi tin nhắn và một quy trình công nhân chạy dài (hoặc các quy trình của hồ bơi hoặc công nhân) sẽ lấy việc làm ra khỏi hàng đợi để hoàn thành chúng. Quy trình công nhân có thể cập nhật cơ sở dữ liệu để cho phép máy chủ bình để biết trạng thái hiện tại của công việc và chuyển thông tin này cho khách hàng.

Sử dụng cần tây có vẻ là một cách hay để thực hiện việc này.