Отправить сообщение в очередь SQS при отправке запроса - PullRequest
0 голосов
/ 04 июня 2019

У меня есть функция, которая отправляет данные в базу данных.Он работает нормально, но я также хотел бы использовать ту же функцию для отправки сообщения, чтобы вызвать другую функцию.

Я пытался одновременно отправить сообщение и сделать запрос на публикацию, но в данный момент работает только запрос на публикацию

Вот как выглядит мой код

const params = {
    "TableName": "sites",
    "Item": {
      userId: event.requestContext.identity.cognitoIdentityId,
      siteId: siteIdFinal,
      ...data,
      createdAt: Date.now()
    }
  };

  const messageParams = {
    MessageBody: 'Waddup fam',
    QueueUrl: ' https://sqs.eu-west-1.amazonaws.com/106845550704/MyQueue'
  };


  try {
    await dynamoDbLib.call("put", params);
    sqs.sendMessage(messageParams, (err, data) => {
      if (err) {
        console.log("Error: "+err);
      } else {
        console.log("Success: "+data.MessageId);
      }
    });

    return success(params.Item);
  } catch (e) {
    console.log(e);
    return failure({ status: false });
  }

Я не получаю никакой ошибки, я просто возвращаю данные, которые были опубликованы.Я думал, что должен получить Id сообщения, которое я отправил, но я не получаю его.

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...