对于我的heroku应用程序，内存一直在增长，我认为这是因为每单位时间发送的消息数量超过了工作人员处理的消息数量。我如何监视在任何给定时间点未处理的消息的数量
from celery.task.control import inspect
从此SO
如果您需要日志记录设施，请查看flower
也许你需要这个：
@celery.task(rate_limit='500/m')
def my_task():
url = "http://www.google.com"
r = requests.get(url)
rate_limit='500/m'可以限制您的任务在一分钟内操作500次。