UIND
/
marketing-SQS-RDS-script
4
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

date added

main
saif 2025-07-02 15:58:28 +05:00
parent 8f629b2089
commit 5518d0c975
1 changed files with 15 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
script.js
View File

@ -25,13 +25,13 @@ const pool = mysql.createPool({
// All 7 queues with their regions // All 7 queues with their regions
const QUEUES = [ const QUEUES = [
{ url: process.env.SQS_QUEUE_US_URL, region: process.env.AWS_REGION_US_EAST }, { 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_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_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_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_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_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_ES_URL, region: process.env.AWS_REGION_EU_WEST },
]; ];
const clients = {}; const clients = {};
@ -40,8 +40,10 @@ function getClient(region) {
if (!clients[region]) { if (!clients[region]) {
clients[region] = new SQSClient({ clients[region] = new SQSClient({
region, region,
accessKeyId: process.env.AWS_ACCESS_KEY, credentials: {
secretAccessKey: process.env.AWS_SECRET_KEY, accessKeyId: process.env.AWS_ACCESS_KEY,
secretAccessKey: process.env.AWS_SECRET_KEY,
},
}); });
} }
return clients[region]; return clients[region];
@ -208,7 +210,9 @@ async function processQueue(queue) {
} }
console.log( 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 { try {
await main(); // wait for current execution to finish await main(); // wait for current execution to finish
} catch (err) { } catch (err) {
console.error('Error in main():', err); console.error("Error in main():", err);
} }
// Wait 5 seconds before running again // Wait 5 seconds before running again