javascript - what - task queue node js

Creando un trabajador de apio usando node.js

Question

Al usar el node-celery , podemos habilitar el nodo para enviar trabajos de apio a la cola de tareas. ¿Cómo podemos permitir que el nodo sea un trabajador de apio y consumir la cola?

Answer 1

Para el apio si el punto final es amqp. Checkery Celery.js Github cualquier proceso de nodo comenzó como un consumidor amqp funcionaría bien. Para cualquier otro tipo de self.conf.backend_type puede tener consumidores variados. El siguiente ejemplo es meramente para amqp.

Un ejemplo de ello. El siguiente message puede ser el objeto de tarea Apio.

var amqp = require(''amqp'');
var connection = amqp.createConnection({ host: "localhost", port: 5672 });
connection.on(''ready'', function () {
  connection.queue("my_celery_queue", function(queue){
    queue.bind(''#''); 
    queue.subscribe(function (message) {
      //eat your Celery work here
    })
  })
})