Как вставить при отправке сообщения в SQS через лямбда-функцию - PullRequest
Новая
       8

Как вставить при отправке сообщения в SQS через лямбда-функцию

0 голосов
/ 16 апреля 2020

Я пытаюсь отправить сообщение в очередь SQS, используя лямбду:

Вот мой код: 

var QUEUE_URL = 'https://us-west-2.queue.amazonaws.com/123456789/ntech-event-processing-dev.fifo';
var AWS = require('aws-sdk');
var sqs = new AWS.SQS({region : 'us-west-2'});

exports.handler = function(event, context) {
  var params = {
    MessageBody: JSON.stringify(event),
    QueueUrl: QUEUE_URL
  };
  sqs.sendMessage(params, function(err,data){
    if(err) {
      console.log('error:',"Fail Send Message" + err);
      context.done('error', "ERROR Put SQS");  // ERROR with message
    }else{
      console.log('data:',data.MessageId);
      context.done(null,'');  // SUCCESS 
    }
  });
}

Вот мои тестовые данные (JSON), обратите внимание, у меня есть определил MessageGroupId там. 

{
  "MessageGroupId": "1",
  "key1": "value1",
  "key2": "value2",
  "key3": "value3"
}

Я получаю следующую ошибку: 

2020-04-16T17:40:37.604Z    fa709a07-0bcd-4b17-a48b-341a984aec88    INFO    error: Fail Send MessageMissingParameter: The request must contain the parameter MessageGroupId.
2020-04-16T17:40:37.661Z    fa709a07-0bcd-4b17-a48b-341a984aec88    ERROR   Invoke Error    {"errorType":"Error","errorMessage":"error","stack":["Error: error","    at _homogeneousError (/var/runtime/CallbackContext.js:13:12)","    at postError (/var/runtime/CallbackContext.js:30:54)","    at done (/var/runtime/CallbackContext.js:57:7)","    at Object.done (/var/runtime/CallbackContext.js:105:16)","    at Response.<anonymous> (/var/task/index.js:13:15)","    at Request.<anonymous> (/var/runtime/node_modules/aws-sdk/lib/request.js:364:18)","    at Request.callListeners (/var/runtime/node_modules/aws-sdk/lib/sequential_executor.js:106:20)","    at Request.emit (/var/runtime/node_modules/aws-sdk/lib/sequential_executor.js:78:10)","    at Request.emit (/var/runtime/node_modules/aws-sdk/lib/request.js:683:14)","    at Request.transition (/var/runtime/node_modules/aws-sdk/lib/request.js:22:10)"]}

Я смотрел: Лямбда: Отправить сообщение в SQS AND Лямбда не может отправить сообщение в SQS Но я не нашел ответа.

Любая помощь приветствуется!

1 Ответ

1 голос
/ 16 апреля 2020

Если вы посмотрите документацию SQS , вы увидите, что:

MessageGroupId - этот параметр применяется только к очередям FIFO (первым пришел-первым вышел).

Я предполагаю, что вы случайно создали очередь FIFO в SQS. Так что вам нужен этот дополнительный параметр. Вы можете изменить свой код следующим образом: 

var QUEUE_URL = 'https://us-west-2.queue.amazonaws.com/123456789/ntech-event-processing-dev.fifo';
var AWS = require('aws-sdk');
var sqs = new AWS.SQS({region : 'us-west-2'});

exports.handler = function(event, context) {
  var params = {
    MessageBody: JSON.stringify(event),
    QueueUrl: QUEUE_URL,
    MessageGroupId: "TestGroup"
  };
  sqs.sendMessage(params, function(err,data){
    if(err) {
      console.log('error:',"Fail Send Message" + err);
      context.done('error', "ERROR Put SQS");  // ERROR with message
    }else{
      console.log('data:',data.MessageId);
      context.done(null,'');  // SUCCESS 
    }
  });
}

Это не поможет, если вы вставите свой MessageGroupId в событие, если вы не взяли его. Если вы хотите получить MessageGroupId из события, это может выглядеть так: 

var QUEUE_URL = 'https://us-west-2.queue.amazonaws.com/123456789/ntech-event-processing-dev.fifo';
var AWS = require('aws-sdk');
var sqs = new AWS.SQS({region : 'us-west-2'});

exports.handler = function(event, context) {
  var params = {
    MessageBody: JSON.stringify(event),
    QueueUrl: QUEUE_URL,
    MessageGroupId: event.MessageGroupId
  };
  sqs.sendMessage(params, function(err,data){
    if(err) {
      console.log('error:',"Fail Send Message" + err);
      context.done('error', "ERROR Put SQS");  // ERROR with message
    }else{
      console.log('data:',data.MessageId);
      context.done(null,'');  // SUCCESS 
    }
  });
}

Учебное пособие, которое я считаю полезным, это one .

...