Блог

В настоящее время я углубляюсь в очереди и нашел пакет bull. Поэтому я установил его и попытался сделать некоторые основные вещи с очередью с их документацией.

Однако я вообще не получаю никаких выходных данных.. события вообще не запускаются, и я также не получаю журнал обработки очереди. Что я сделал не так? Я также уже просмотрел документацию и проверил все, что они предоставили в учебнике. По-прежнему нет выхода.

 (() => {
    const steamapi = require('steamapi');
    const steam = new steamapi('api_token');
    
    const Queue = require('bull');
    const reportQueue = new Queue('Resolving Profiles');    

    //Adding new profile to queue
    reportQueue.add({ profile: '_g9' });

    //Processing the queue
    reportQueue.process( (job, done) => {
        console.log(`Job: ${job.data}`);

        steam.resolve(job.data.profile).then(id => {
            console.log(id);
        });

        done();
    });

    //On finish event
    reportQueue.on('completed', (job, result) => {
        console.log(`Job: ${job}`);
        console.log(`Result: ${result}`);
    });

    //Progress
    reportQueue.on('progress', (job, progress) => {
        console.log(`Job progress with result ${job} ${progress}`);
    });
})();