in src/metering-hourly-job.js [50:63]
await asyncForEach(Object.keys(hashMap), async (hash) => {
const SQSParams = {
MessageBody: JSON.stringify(hashMap[hash]),
MessageGroupId: hash,
QueueUrl,
};
try {
await sqs.sendMessage(SQSParams).promise();
console.log(`Records submitted to queue: ${JSON.stringify(hashMap[hash])}`);
} catch (error) {
console.error(error, error.stack);
}
});