1. import { Queue } from 'bullmq';
  3. /**
  4. * Archives task queue content for diagnostics with fixed retry intervals.
  5. * @param {Queue} queue The BullMQ queue to archive.
  6. * @param {number} retryIntervalMs The interval in milliseconds between archive attempts.
  7. */
  8. async function archiveQueueContent(queue, retryIntervalMs) {
  9. let attempts = 0;
  10. const maxAttempts = 5; // Limit the number of retry attempts
  12. while (attempts < maxAttempts) {
  13. try {
  14. // Get all jobs from the queue
  15. const jobs = await queue.getJobs();
  17. if (jobs && jobs.length > 0) {
  18. console.log(`Archiving ${jobs.length} jobs...`);
  20. // Iterate over each job and archive its data
  21. for (const job of jobs) {
  22. try {
  23. // Simulate archiving (replace with your actual archiving logic)
  24. console.log(`Archiving job ${job.id}`);
  25. // Example: Serializing the job data to JSON and saving to a file
  26. // const jobData = JSON.stringify(job.data);
  27. // await fs.promises.writeFile(`archive_${job.id}.json`, jobData);
  28. } catch (error) {
  29. console.error(`Error archiving job ${job.id}:`, error);
  30. }
  31. }
  32. } else {
  33. console.log('Queue is empty.');
  34. }
  36. console.log('Queue archiving complete.');
  37. break; // Exit the retry loop if successful
  38. } catch (error) {
  39. console.error(`Error archiving queue content:`, error);
  40. attempts++;
  42. if (attempts < maxAttempts) {
  43. console.log(`Retrying in ${retryIntervalMs}ms... (Attempt ${attempts}/${maxAttempts})`);
  44. await new Promise(resolve => setTimeout(resolve, retryIntervalMs));
  45. } else {
  46. console.error('Archive failed after multiple attempts.');
  47. }
  48. }
  49. }
  50. }
  52. export default archiveQueueContent;

Add your comment