Comment pensez-vous de la structure séquentielle AWS appels de service au sein de lambda donné à toutes les communications sont asynchrones?

Je ne sais pas Lambda, mais vous devriez regarder dans le noeud async bibliothèque comme un moyen de séquence asynchrone fonctions.

async a rendu ma vie beaucoup plus facile et mon code beaucoup plus ordonnée sans la profonde imbrication problème que vous avez mentionné dans votre question.

Asynchrone classique code peut ressembler à:

async.waterfall([
function doTheFirstThing(callback) {
db.somecollection.find({}).toArray(callback);
},
function useresult(dbFindResult, callback) {
do some other stuff  (could be synch or async)
etc etc etc
callback(null);
],
function (err) {
//this last function runs anytime any callback has an error, or if no error
//then when the last function in the array above invokes callback.
if (err) { sendForTheCodeDoctor(); }
});

Ont un look à la async doco sur le lien ci-dessus. Il y a beaucoup de fonctions utiles pour la série, parallèle, chute d'eau, et beaucoup plus. Async est activement maintenu et semble très fiable.

bonne chance!

Réponse courte:

Utilisation Async /Await — et Appeler le service AWS (SNS par exemple), avec un .promesse() extension de dire aws sdk pour l'utilisation de la promesse-identifiés version de cette fonction de service au lieu de l'appel de retour en fonction de la version.

Puisque vous voulez exécuter dans un ordre spécifique, vous pouvez utiliser Async /Await en supposant que la fonction parent, vous appelez de est elle-même async.

Par exemple:

let snsResult = await sns.publish({
Message: snsPayload,
MessageStructure: 'json',
TargetArn: endPointArn
}, async function (err, data) {
if (err) {
console.log("SNS Push Failed:");
console.log(err.stack);
return;
}
console.log('SNS push suceeded: ' + data);
return data;
}).promise();

La partie importante est le .promesse() sur la fin. Plein de docs sur l'utilisation d'aws sdk dans un async /promesse fonction peut être trouvé ici: https://docs.aws.amazon.com/sdk-for-javascript/v2/developer-guide/using-promises.html

Afin d'exécuter un autre aws sdk tâche de même ajouter l'attendent et l' .promesse() extension de cette fonction (en supposant que c'est disponible).

Pour toute personne qui s'exécute dans ce fil et est actuellement à la recherche de simplement pousser les promesses d'un tableau et d'attendre que TOUT le tableau à la fin (sans égard à la promesse qui s'exécute en premier) je me suis retrouvé avec quelque chose comme ceci:

let snsPromises = [] //declare array to hold promises
let snsResult = await sns.publish({
Message: snsPayload,
MessageStructure: 'json',
TargetArn: endPointArn
}, async function (err, data) {
if (err) {
console.log("Search Push Failed:");
console.log(err.stack);
return;
}
console.log('Search push suceeded: ' + data);
return data;
}).promise();
snsPromises.push(snsResult)
await Promise.all(snsPromises)

Espère que ça aide quelqu'un au hasard tombe sur cette via google comme je l'ai fait!

Viens de voir ce vieux fil. Notez que les futures versions de JS va améliorer tout ça. Jetez un oeil à la ES2017 async/await syntaxe qui rationalise un async imbriquée rappel désordre dans un récipient propre de synchronisation comme le code.
Il y a maintenant quelques polyfills que peut vous apporter cette fonctionnalité sur ES2016 syntaxe.

Comme un dernier PTI - AWS Lambda prend désormais en charge .Net De Base qui fournit cette énergie propre async syntaxe de la boîte.

Par défaut Javascript est asynchrone.

Donc tout ce que vous avez à faire, c'est de ne pas utiliser ces bibliothèques, vous pouvez, mais il y a des moyens simples pour résoudre ce problème. Dans ce code, j'ai envoyé l'e-mail, avec les données que vient de l'événement, mais si vous voulez, vous avez juste besoin d'ajouter plus de fonctions à l'intérieur des fonctions.

Ce qui est important, c'est l'endroit où votre contexte.done(); va, il va, à la fin de votre fonction Lambda. Vous avez besoin de le mettre dans le fin de la dernière fonction.

var AWS = require('aws-sdk');    
AWS.config.credentials = { "accessKeyId": "AAAA","secretAccessKey": "BBBB"};
AWS.config.region = 'us-east-1';
var ses = new AWS.SES({apiVersion: '2010-12-01'});
exports.handler = function(event, context) {
console.log(event.nome);
console.log(event.email);
console.log(event.mensagem);
nome = event.nome;
email = event.email;
mensagem = event.mensagem;
var to = ['[email protected]'];
var from = '[email protected]';
//Send email
mensagem = ""+nome+"||"+email+"||"+mensagem+"";
console.log(mensagem);
ses.sendEmail( { 
Source: from, 
Destination: { ToAddresses: to },
Message: {
Subject: {
Data: 'Form contact our Site'
},
Body: {
Text: {
Data: mensagem,
}
}
}
},
function(err, data) {
if (err) {
console.log("ERROR="+err, err.stack); 
context.done();
} else {
console.log("EMAIL SENT="+data);
context.done();
}
});
}