0

我正在尝试将议程添加到我的节点应用程序中，这样我就可以每天运行一些后台任务，例如停用 60 天未登录的用户。

我已经尝试按照与模块关联的 GitHub 上的示例进行操作，但似乎在我尝试加载站点时遇到了我的应用程序挂起的问题，并最终得到“错误 504：网关服务器超时”。我也在undefined控制台中看到。

我知道 Agenda 已经启动并且工作正常，因为我现在有一个简单的工作，每分钟只执行一个 console.log。

在我的 app.js 中，我需要我的 worker.js 文件：

var agenda = require('./worker.js');

我的 worker.js 只是一个简单的 1 行：

require('./lib/agenda.js');

议程.js：

var Agenda = require('agenda');

var connectionString = "mongodb://" + process.env.MONGODB_USER + ":" +
  process.env.MONGODB_PASSWORD + "@" +
  process.env.DATABASE_SERVICE_NAME + ':' +
  process.env.MONGODB_PORT + '/' +
  process.env.MONGODB_DATABASE;

 var agenda = new Agenda({db: {address: connectionString}});

 var jobTypes = process.env.JOB_TYPES ? process.env.JOB_TYPES.split(',') : [];

 jobTypes.forEach(function(type){
    require('./jobs/' + type)(agenda);
 });

 if (jobTypes.length) {
    agenda.on('ready', function() {
        agenda.every('* * * * *', 'test job')   //Run job at 0030 every day

        agenda.start();
    })
 }

 module.exports = agenda

并且测试作业在作业文件中定义，如下所示：

agenda.define('test job', function(job, done) {
    console.log ('Agenda job executed');
    done();
});

我觉得我错过了一些非常明显的东西！

4

1 回答 1

0

事实证明，我需要agenda.processEvery在我的议程.js 的启动命令部分添加一个：

var Agenda = require('agenda');

var connectionString = "mongodb://" + process.env.MONGODB_USER + ":" +
  process.env.MONGODB_PASSWORD + "@" +
  process.env.DATABASE_SERVICE_NAME + ':' +
  process.env.MONGODB_PORT + '/' +
  process.env.MONGODB_DATABASE;

 var agenda = new Agenda({db: {address: connectionString}});

 var jobTypes = process.env.JOB_TYPES ? process.env.JOB_TYPES.split(',') : [];

 jobTypes.forEach(function(type){
    require('./jobs/' + type)(agenda);
 });

 if (jobTypes.length) {
    agenda.on('ready', function() {
        agenda.every('* * * * *', 'test job')   //Run job at 0030 every day

        agenda.processEvery('one minute');    //<====== This is the new line

        agenda.start();
    })
 }

 module.exports = agenda
于 2018-05-11T13:03:56.680 回答