BullMQ addBulk部署至Vercel后任务停滞问题求助

核心原因 #

Vercel Serverless函数的运行特性（单次执行最长300秒、执行完成后立即销毁进程、冷启动机制）与BullMQ Worker的长期运行需求不匹配。Worker进程在Vercel环境下会被提前终止，导致任务状态异常，后续任务无法推进。同时代码中手动调用任务状态变更方法的逻辑，可能引发BullMQ内部状态混乱；加上Vercel环境的网络限制，可能导致GraphQL请求挂起，最终让Worker进入idle状态。

具体解决方案 #

1. 迁移Worker至长期运行环境 #

不要在Vercel Serverless函数中运行BullMQ Worker，改用支持长期进程的平台部署独立的Worker服务。这类平台能维持Worker进程持续运行，保证任务队列正常消费。

2. 简化任务状态处理逻辑 #

移除代码中手动调用job.moveToFailed和job.moveToCompleted的逻辑，BullMQ会自动根据任务函数的执行结果标记状态：

• 函数正常返回 → 任务自动标记为completed
• 函数抛出错误 → 任务自动标记为failed

修改后的updateJob函数示例：

const updateJob = async (job: Job) => {
  const { sku, quantity } = job.data;

  const variant = await getVariant(sku);
  if (!variant) {
    throw new Error(`Variant by SKU: ${sku} not found`);
  }

  await updateVariant(variant, quantity);
  return 'DONE';
};

3. 优化Redis连接配置 #

在Vercel环境下，确保Redis连接使用持久化配置，避免频繁创建/销毁连接导致的异常：

const connection = {
  host: process.env.REDIS_HOST,
  port: parseInt(process.env.REDIS_PORT || '6379'),
  password: process.env.REDIS_PASSWORD,
  keepAlive: 30000, // 保持连接活跃
  maxRetriesPerRequest: 5, // 增加重试次数
};

4. 排查GraphQL请求稳定性 #

在Vercel环境下测试getVariant和updateVariant的执行情况：

• 确认GraphQL接口能被Vercel函数正常访问，无出站网络限制
• 给GraphQL请求添加超时限制，避免请求无限挂起导致任务卡住：

// 示例：给GraphQL请求添加10秒超时
const getVariant = async (sku: string) => {
  const controller = new AbortController();
  const timeoutId = setTimeout(() => controller.abort(), 10000);

  try {
    const response = await fetch(GRAPHQL_ENDPOINT, {
      method: 'POST',
      headers: { 'Content-Type': 'application/json' },
      body: JSON.stringify({ query: `...`, variables: { sku } }),
      signal: controller.signal,
    });
    clearTimeout(timeoutId);
    const data = await response.json();
    return data.data.variant;
  } catch (error) {
    if (error.name === 'AbortError') {
      throw new Error(`GraphQL request for SKU ${sku} timed out`);
    }
    throw error;
  }
};

5. 调整Worker并发设置 #

在Worker配置中明确设置concurrency: 1，避免Vercel环境下资源不足导致的任务阻塞：

const settings = {
  connection,
  removeOnComplete: { count: 1500 },
  removeOnFail: { count: 7500 },
  metrics: { maxDataPoints: MetricsTime.ONE_WEEK },
  concurrency: 1, // 限制并发数
} satisfies WorkerOptions;

内容的提问来源于stack exchange，提问作者Tobias Madsen