为什么芹菜没有处理消息并删除它？

Question

我使用php将消息发送到rabbitmq和一个python使用者来处理它。 这是我所做的。在

这个部分向rabbitmq发送一个json。在

$data = array(
  'id' => 123,
  'url' => 'baidu.com',
);
$msg = new AMQPMessage(json_encode($data));
$channel->basic_publish($msg, $exchange);

这个部分接收消息并处理它（使用芹菜）。在

^{pr2}$

以下是我从控制台得到的信息：

[2014-09-29 15:51:34,564: WARNING/MainProcess] celery@mickey-Thurley ready.
[2014-09-29 15:51:37,395: WARNING/MainProcess] Received and deleted unknown message. Wrong destination?!?

The full contents of the message body was: body: '{"id":123,"url":"baidu.com"}' (28b)
{content_type:None content_encoding:None
  delivery_info:{'redelivered': False, 'routing_key': '', 'exchange': 'celery', 'delivery_tag': 1, 'consumer_tag': '4'} headers={}}

我确信消费者收到了消息，但为什么消息没有被处理？我该怎么办呢？在

Answer 1

芹菜任务不仅仅是数据。你还需要一些东西来告诉工人你实际在调用什么任务，而你的信息中却没有。在

与其自己尝试实现它，您可能应该使用一个Celery PHP实现，比如this one。在