我正在使用队列来延迟我的应用程序中的一些活动,延迟范围从 10 分钟到 2 天。但无论状态如何,所有作业都会在 15 分钟后因网关错误而被删除。我在集群模式下使用弹性缓存 redis。
Below is my queue setup.
const concurrency = 5;
const instantShiftQueue = new Queue('auto-selection',
process.env[process.env.REDIS_URL_ENV_NAME]);
instantShiftQueue.process(concurrency, async (job, done) => {
///Run function here
job.moveToCompleted('done', true);
done();
});