clear-redis-queue.js 455 B

12345678910111213141516171819
  1. const Redis = require('ioredis');
  2. const redis = new Redis();
  3. async function clearQueue() {
  4. console.log('清空Redis中的书籍生成队列...');
  5. // 删除所有bull队列相关key
  6. const keys = await redis.keys('bull:book:generation:*');
  7. if (keys.length > 0) {
  8. await redis.del(...keys);
  9. console.log(`✅ 已删除 ${keys.length} 个队列key`);
  10. } else {
  11. console.log('队列已空');
  12. }
  13. await redis.quit();
  14. }
  15. clearQueue();