У меня есть функция, которая отправляет данные в базу данных.Он работает нормально, но я также хотел бы использовать ту же функцию для отправки сообщения, чтобы вызвать другую функцию.
Я пытался одновременно отправить сообщение и сделать запрос на публикацию, но в данный момент работает только запрос на публикацию
Вот как выглядит мой код
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 сообщения, которое я отправил, но я не получаю его.