Heroku에서 NodeJS 작업자를 다시 시작한 후 대기중인 작업 다시 시작

Question

그래서 매우 간단한 설정을 Heroku에 있습니다. 백그라운드 작업 처리를 위해 RabbitMQ을 사용하고 있습니다. 내 설정은 Heroku 스케줄러 addon을 사용하여 매일 실행되는 노드 스크립트로 구성됩니다. 스크립트는 대기열에 작업을 차례로 추가하고 작업자를 처리하고 별도의 모듈로 위임하여 처리합니다. 내가 인스턴스를 다시 시작하기 전에, Heroku가이 수시로 무작위로 시작하는 SIGTERM 이벤트를받은 후

문제

가 시작됩니다.

인스턴스가 다시 시작된 후 어떤 이유로 작업자가 다시 백업되지 않습니다. heroku ps:scale worker=0 및 heroku ps:scale worker=1을 수동으로 다시 시작할 때만 작업자가 보류중인 작업을 계속 소비합니다. 그이 완료 될 때까지

// worker.js 
var throng = require('throng'); 
var jackrabbit = require('jackrabbit'); 
var logger = require('logfmt'); 
var syncService = require('./syncService'); 

var start = function() { 
    var queue = jackrabbit(process.env.RABBITMQ_BIGWIG_RX_URL || 'amqp://localhost'); 

    logger.log({type: 'msg', msg: 'start', service: 'worker'}); 

    queue 
     .default() 
     .on('drain', onDrain) 
     .queue({name: 'syncUsers'}) 
     .consume(onMessage) 

    function onMessage(data, ack, nack) { 

     var promise; 
     switch (data.type) { 
      case 'updateUser': 
       promise = syncService.updateUser(data.target, data.source); 
       break; 
      case 'createUser': 
       promise = syncService.createUser(data.source); 
       break; 
      case 'deleteUser': 
       promise = syncService.deleteUser(data.target); 
     } 

     promise.then(ack, nack); 
    } 

    function onDrain() { 
     queue.close(); 
     logger.log({type: 'info', msg: 'sync complete', service: 'worker'}); 
    } 

    process.on('SIGTERM', shutdown); 


    function shutdown() { 
     logger.log({type: 'info', msg: 'shutting down'}); 
     queue.close(); 
     process.exit(); 
    } 

}; 


throng({ 
    workers: 1, 
    lifetime: Infinity, 
    grace: 4000 
}, start); 

Answer 1

jackrabbit 객체 takes a callback에 close() 방법은,이 과정을 종료하지 않도록해야합니다 :

function shutdown() { 
    logger.log({type: 'info', msg: 'shutting down'}); 
    queue.close(function (e) { 
     process.exit(e ? 1 : 0); 
    }); 
}