议程无法读取属性 insertOne of undefined

Question

我正在尝试使用议程创建和安排工作。所以我把它分成两个文件，一个文件consumer 创建作业，另一个文件producer 调度作业。

这是消费者文件

const Agenda = require("agenda");
async function run() {
    try {
        const agenda = new Agenda({
            db: {
                address: process.env.MONGODB_URL,
                collection: 'agendaJobs',
                options: {
                    useUnifiedTopology: true
                }
            }
        });

        agenda.define('ticket creation', async (job, done) => {
            const { time } = job.attrs.data;
            console.log(time);
            done();
        });

        agenda.on("ready", function () {
            agenda.start();
            console.log('Agenda Started');
        });
        //await agenda.start();

    } catch (error) {
        console.error(error);
        process.exit(-1);
    }

}

module.exports = {
    run: run
};

生产者文件是

//import { default as Agenda } from 'agenda';
const Agenda = require("agenda");

const jobs = async (job) => {
    try {
        const agenda = new Agenda({
            db: {
                address: process.env.MONGODB_URL,
                collection: 'agendaJobs',
                options: {
                    useUnifiedTopology: true
                }
            }
        });

        const created = await agenda.schedule(job.time, 'ticket creation', {
            time: job.time
        });
        
        return created;
        
    } catch (error) {
        console.error(error);
        process.exit(-1);
    }
};

module.exports = jobs;

这是我使用它的控制器

const jobs = require('./producer');
const { run } = require('./consumer');
run();

app.post('/create/job', async (req, res) => {
    try {
        const { time } = req.body;
        await jobs({
            time: time
        });
        return res.status(200).send({
            success: true,
            message: 'Job created'
        });
    } catch (error) {
        return res.status(error.status).send(error);
    }
});

有什么地方我错了，我知道这连接到数据库

发送到控制器的主体示例

{
    "time": "3 minutes"
}

我使用节点调试器来跟踪错误，它总是在看起来像这样的一行失败，但我不知道是什么原因造成的

yield schedule(this).save()

然后在终端显示错误提示

TypeError: Cannot read property 'insertOne' of undefined

** this 的 props 属性始终未定义

Answer 1

https://github.com/agenda/agenda/issues/335#issuecomment-249154993

        agenda.on("ready", async () => {
             const created = await agenda.schedule(job.time, 'ticket creation', {
                time: job.time
             });
        });