Cần tây - Hoàn thành nhiệm vụ nhưng không bao giờ trở lại dẫn

Question

Tôi vừa mới cài đặt cần tây và đang cố gắng để làm theo hướng dẫn:

Tôi có một tập tin gọi là tasks.py với đoạn mã sau:

from celery import Celery 

app = Celery('tasks', backend='amqp', broker='amqp://') 

@app.task 
def add(x, y): 
    return x + y 

tôi cài đặt RabitMQ (Tôi đã không cấu hình với nó kể từ khi hướng dẫn đã không đề cập đến bất cứ điều gì của loại đó).

tôi chạy máy chủ lao động cần tây như sau:

celery -A tasks worker --loglevel=info 

Dường như để khởi động bình thường (ở đây là kết quả: http://i.imgur.com/qnoNCzJ.png)

Sau đó, tôi chạy một kịch bản như sau:

from tasks import add 
from time import sleep 

result = add.delay(2,2) 

while not result.ready(): 
    sleep(10) 

Khi tôi kiểm tra result.ready() Tôi luôn nhận được Sai (vì vậy vòng lặp while ở trên chạy mãi mãi). Tuy nhiên, trên nhật ký Celery, mọi thứ có vẻ tốt đẹp:

[2014-10-30 00:58:46,673: INFO/MainProcess] Received task: tasks.add[2bc4ceba-1319-49ce-962d-1ed0a424a2ce] 
[2014-10-30 00:58:46,674: INFO/MainProcess] Task tasks.add[2bc4ceba-1319-49ce-962d-1ed0a424a2ce] succeeded in 0.000999927520752s: 4 

Vì vậy, nhiệm vụ đã được lưu trữ và thành công. Tuy nhiên, result.ready() vẫn là Sai. Bất kỳ cái nhìn sâu sắc nào về lý do tại sao điều này có thể là? Tôi đang sử dụng Windows 7 và đang sử dụng RabbitMQ. Cảm ơn trước.

Answer 1

Cần tây cần phải bật phụ trợ kết quả. Xem

http://celery.readthedocs.org/en/latest/configuration.html#celery-result-backend

Xem thêm http://celery.readthedocs.org/en/latest/getting-started/first-steps-with-celery.html#calling-the-task.

Answer 2

Được rồi, tôi đã thiết lập một VM rõ ràng với cần tây tươi cài đặt, thiết lập các tập tin sau đây:

tasks.py:

from celery import Celery 

app = Celery('tasks', backend='amqp', broker='amqp://') 

@app.task 
def add(x, y): 
    return x + y 

Và runme.py

from tasks import add 
import time 

result = add.delay(1,2) 
while not result.ready(): 
    time.sleep(1) 

print(result.get()) 

Sau đó, tôi thiết lập cần tây với:

celery -A tasks worker --loglevel=info 

Và sau đó tôi chạy runme.py mang đến cho dự kiến ​​kết quả:

[puciek@somewhere tmp]# python3.3 runme.py 
3 

Vì vậy, rõ ràng vấn đề này nằm trong thiết lập của bạn, rất có thể ở đâu đó trong cài đặt thỏ mq, vì vậy tôi khuyên bạn nên cài đặt lại nó với phiên bản ổn định mới nhất từ ​​các nguồn , đó là những gì tôi đang sử dụng, và như bạn thấy - nó hoạt động tốt.

Cập nhật:

Trên thực tế, vấn đề của bạn có thể là tầm thường như tưởng tượng - bạn có chắc rằng bạn đang sử dụng cùng một phiên bản dành cho cần tây chạy, và chạy tiêu dùng của bạn? Tôi chỉ quản lý để tái sản xuất nó, nơi tôi đã chạy cần tây trên Python3.3, và sau đó chạy runme.py với phiên bản 2.7. Kết quả là như bạn đã mô tả.

Answer 3

nên giải quyết vấn đề của bạn

ignore_result=False