python - celery+rabbitmq非同步任務，佇列訊息一直在增加

Question

celery 配合 rabbitmq 進行非同步任務時，發現 rabbitmq 裡訊息的數量是一直增加的，但是這些訊息其實也已經被 task 處理掉.

查看 rabbimtq 自帶的後台，發現 Queued messages 裡面，ready 和 total 的數量都達到了 5000 多，unacknowledged 的​​值為 0。不過實際在工作的時候，unacknowledged 的​​值會變化的，但是最後會變成0
celery 的配置也沒有特殊的地方，就只設定瞭如下的內容
CELERY_IMPORTS = ('testtasks',)
BROKER_URL = 'amqp://guest:guest@localhost:5672//'
CELERY_RESULT_BACKEND = 'amqp://'

接著看系統的資源，erl 的進程記憶體比較大，大概暫用了 300 多 M
是我這邊 celery 的配置有問題麼？

Answer 1

已經解決了，升級了 rabbitmq 到 3.3 以上版本就可以了。
之前用的是 rabbitmq 3.1 的版本，然後 celery 是 3.1 的版本

---

真正解決問題的方法是，在task裡增加一個ignore_result=True屬性，如下
@app.task(ignore_result=True)