From 5518d0c97521f870f3f47881e79d50f45906a112 Mon Sep 17 00:00:00 2001 From: saif Date: Wed, 2 Jul 2025 15:58:28 +0500 Subject: [PATCH] date added --- script.js | 26 +++++++++++++++----------- 1 file changed, 15 insertions(+), 11 deletions(-) diff --git a/script.js b/script.js index f7b309d..668a1fa 100644 --- a/script.js +++ b/script.js @@ -25,13 +25,13 @@ const pool = mysql.createPool({ // All 7 queues with their regions const QUEUES = [ - { url: process.env.SQS_QUEUE_US_URL, region: process.env.AWS_REGION_US_EAST }, - { url: process.env.SQS_QUEUE_CA_URL, region: process.env.AWS_REGION_US_EAST }, - { url: process.env.SQS_QUEUE_UK_URL, region: process.env.AWS_REGION_EU_WEST }, - { url: process.env.SQS_QUEUE_DE_URL, region: process.env.AWS_REGION_EU_WEST }, - { url: process.env.SQS_QUEUE_FR_URL, region: process.env.AWS_REGION_EU_WEST }, - { url: process.env.SQS_QUEUE_IT_URL, region: process.env.AWS_REGION_EU_WEST }, - { url: process.env.SQS_QUEUE_ES_URL, region: process.env.AWS_REGION_EU_WEST }, + { url: process.env.SQS_QUEUE_US_URL, region: process.env.AWS_REGION_US_EAST }, + { url: process.env.SQS_QUEUE_CA_URL, region: process.env.AWS_REGION_US_EAST }, + { url: process.env.SQS_QUEUE_UK_URL, region: process.env.AWS_REGION_EU_WEST }, + { url: process.env.SQS_QUEUE_DE_URL, region: process.env.AWS_REGION_EU_WEST }, + { url: process.env.SQS_QUEUE_FR_URL, region: process.env.AWS_REGION_EU_WEST }, + { url: process.env.SQS_QUEUE_IT_URL, region: process.env.AWS_REGION_EU_WEST }, + { url: process.env.SQS_QUEUE_ES_URL, region: process.env.AWS_REGION_EU_WEST }, ]; const clients = {}; @@ -40,8 +40,10 @@ function getClient(region) { if (!clients[region]) { clients[region] = new SQSClient({ region, - accessKeyId: process.env.AWS_ACCESS_KEY, - secretAccessKey: process.env.AWS_SECRET_KEY, + credentials: { + accessKeyId: process.env.AWS_ACCESS_KEY, + secretAccessKey: process.env.AWS_SECRET_KEY, + }, }); } return clients[region]; @@ -208,7 +210,9 @@ async function processQueue(queue) { } console.log( - `[${queue.region}] ${queue.url} -> processed ${traffics.length} messages` + `[${queue.region}] ${queue.url} -> processed ${traffics.length} messages ${DateTime.now().toFormat( + "yyyy-MM-dd HH:mm:ss" + )}` ); } @@ -227,7 +231,7 @@ async function runLoop() { try { await main(); // wait for current execution to finish } catch (err) { - console.error('Error in main():', err); + console.error("Error in main():", err); } // Wait 5 seconds before running again