text 发送消息给SQS

Posted 2021-05-01

const AWS = require('aws-sdk');
const sqs = new AWS.SQS();
const awsAccountId = process.env.AWS_ACCOUNTID;
const sqsQueueName = process.env.SQS_QUEUE_NAME;
const awsRegion = process.env.MY_AWS_REGION;
const queueUrl = `https://sqs.${awsRegion}.amazonaws.com/${awsAccountId}/${sqsQueueName}`;

module.exports = async (event) => {
    const sentParams = {
        MessageBody: "this is message sent",
        QueueUrl: queueUrl,
    };

    sqs.sendMessage(sentParams, function (err, data) {
        if (err) {
            console.log('error:', 'Fail send message' + err);
        } else {
            console.log('data:', data.MessageId);
            return {
                statusCode: 200,
                body: JSON.stringify({
                    message: 'Msg has been sent successfully!',
                    input: event,
                }),
            };
        }
    });
};