如何解决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代理。删除它可以解决问题。
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。