read sqs and save to file

sqs.mjs

import { SQSClient, ReceiveMessageCommand } from "@aws-sdk/client-sqs";
import { join } from 'node:path'
import { fileURLToPath } from 'node:url'
import { writeFile } from 'node:fs/promises'

const QueueUrl = ""
const client = new SQSClient({ region: "sa-east-1" });

const TARGET_DIR = join(fileURLToPath(new URL('.', import.meta.url)), 'data')

const command = new ReceiveMessageCommand({
    QueueUrl,    
    MaxNumberOfMessages: 10,
    WaitTimeSeconds: 5,
});

while (true) {
    const { Messages } = await client.send(command);

    if (!Messages || Messages.length == 0) {
        console.warn('no more messages')
        break
    }

    console.log(`load new ${Messages.length} messages`)

    const promises = Messages.map(msg => {
        return writeFile(join(TARGET_DIR, `${msg.MessageId}.json`), JSON.stringify(msg, null, 2))
    })

    await Promise.allSettled(promises)
        .then(results => {
            const errors = results.filter(row => row.status === 'rejected')

            if (errors.length > 0) {
                errors.forEach(err => {
                    console.error(err)
                })
            }
        })
}