TypeError：主体不可迭代-RabbitMQ，芹菜工人NodeJs，

问题描述

我有一个使用pika（python）写入RabbitMQ的系统。内容是一个JSON对象，其中包含需要在后台处理的CSV文件的文件URL。在另一个实例中，我有一个NodeJs客户端，它侦听队列并创建任务，这些任务最终将在适当的位置处理它或使用url作为参数调用另一个NodeJs程序。
为此，我正在使用this celery.node库。问题出在工作端，我可以发布和侦听队列，但是创建任务TypeError: body is not iterable时仍会显示。

这是我的工作人员代码：

const celery = require('celery-node');

const rabbitmq_broker = `amqp://${RABBITMQ_USER}:${RABBITMQ_PASS}@${RABBITMQ_HOST}:${RABBITMQ_PORT}`;

const worker = celery.createWorker(
    rabbitmq_broker,rabbitmq_broker,'some_queue'
);

worker.register("tasks.some-task",(data) => {
    console.log('data:',data);
    return data;
});

worker.start()

我在此github存储库中打开了一个问题，但是，我还没有收到任何反馈。 任何帮助表示感谢，谢谢！

解决方法

已解决：引起此问题的原因是我在听some_queue而不是客户端发布Celery任务的主要RabbiMQ代理。删除它可以解决问题。