Am消费来自rabbitmq的消息,但消费者似乎接受然后拒绝接受然后拒绝(以相同格式)接受一条消息,然后拒绝下一条消息
[MainProcess]收到消息:RT@Iamsidney:肯尼亚的科学术语[警告/MainProcess]收到并删除了未知消息。错误的目的地?!?正文的全部内容是:正文:"知识的最大敌人不是无知,而是知识的幻觉。\\n\n-斯蒂芬·霍金(133b){content_type:'application/json'content_encoding:'utf-8'delivery_info:{'consumer_tag':'None5','delivery_tag':1,'redived':False,'exchange':'twitterstatus','routing_key':'tweitterstatus'}headers={}}[MainProcess]收到消息:RT@fideliper:一起来![警告/MainProcess]收到并删除了未知消息。错误的目的地?!?消息正文的全部内容是:正文:"哈哈,我所有的都是模因:")"(60b){content_type:'application/json'content_encoding:'utf-8'delivery_info:{'consumer_tag':'None5','delivery_tag':2,'redived':False,'exchange':'twitterstatus','routing_key':'twetterstatus'}headers={}}
使用
celery worker -A app -Q twitterstatus -l info
似乎使用了队列选项,现在使用
celery worker -A app -l info
工作良好