как получить сообщение в aws sqs node js - PullRequest
Новая
       36

как получить сообщение в aws sqs node js

2 голосов
/ 31 января 2020

Я использую sqs в моем Node js проекте. то, что я делаю, это отправка сообщения в SQS и получение его. но когда я получаю, это просто объект ResponseMetadata 

   "ResponseMetadata": {
    "RequestId": "8659872b-10f0-57b6-9d57-d1852aba1a64"
    }

, в ответ объект сообщения отсутствует. что мне делать? У меня есть много возможностей, таких как изменение значений параметров и т. д. c, но ничего не работает.

мой код 

   const AWS = require('aws-sdk');
   AWS.config.update({ accessKeyId: process.env.AWS_ACCESS_KEY_ID, secretAccessKey: process.env.AWS_SECRET_ACCESS_KEY, region: 'eu-west-1' })
   const sqs = new AWS.SQS({apiVersion: '2012-11-05'});

   onst queueUrl = "https://eu-west-1.queue.amazonaws.com/******/test-queue";

отправить сообщение 

     let params = {
            MessageBody: 'Hello world!',
            MessageAttributes: {
                "Title": {
                    DataType: "String",
                    StringValue: "The Whistler"
                },
                "Author": {
                    DataType: "String",
                    StringValue: "John Grisham"
                },
                "WeeksOn": {
                    DataType: "Number",
                    StringValue: "6"
                }
            },
            QueueUrl: queueUrl,
            DelaySeconds: 0
        };

        sqs.sendMessage(params, function (err, data) {
            if (err) {
                res.send(err);
            } else {
                res.send(data);
            }
        });

ответ 

     "ResponseMetadata": {
    "RequestId": "da3af650-2642-5460-86b7-a0fe1f9ced6f"
},
"MD5OfMessageBody": "86fb269d190d2c85f6e0468ceca42a20",
"MD5OfMessageAttributes": "1864106991a54cca8b8c732a1841833a",
"MessageId": "13f228b0-7df1-4a9e-bc2b-48535725955e"

получение сообщения 

       sqs.getQueueUrl('queue-name', function(err, data) {
            if (err) {
                console.log("Error", err);
            } else {
                let params = {
                    AttributeNames: [
                        "SentTimestamp"
                    ],
                    MaxNumberOfMessages: 10,
                    VisibilityTimeout: 20,
                    MessageAttributeNames: ["All"],
                    QueueUrl: data.QueueUrl,
                    WaitTimeSeconds: 0
                };

                sqs.receiveMessage(params, function (err, data) {
                    if (err) {
                        res.send(err);
                    } else {
                        res.send(data);
                    }
                });
            }
        });

Может кто-нибудь помочь? я что-то пропустил? спасибо заранее

Ответы [ 2 ]

2 голосов
/ 31 января 2020

Неправильный вызов getQueueUrl. Вам также нужно обернуть имя очереди в объект, подобный этому 

sqs.getQueueUrl({"QueueName": "queue name"}, function (err, data) {

, также стоит использовать версию обещания вместо обратного вызова. 

const data = sqs.getQueueUrl({"QueueName": "queue name"}).promise();

// Similary receiveMessage
0 голосов
/ 31 января 2020

чувак, проверьте на Google, кстати, это хороший сайт https://docs.aws.amazon.com/sdk-for-javascript/v2/developer-guide/sqs-examples-send-receive-messages.html

...