Wie kann ich synchrone dynamodb Anfrage in Lambda ausführen?

Question

const params = { 
    TableName: 'item-table', 
    FilterExpression : "#tagname = :itemId", 
    ExpressionAttributeNames: {"#tagname": "itemId"}, 
    ExpressionAttributeValues: {":itemId": "000001"}  
    }; 
var item =""; 
dynamo.scan(params, function(err, data) 
{ 
if (err) { 
    console.error("Unable to query. Error:", JSON.stringify(err, null, 2)); 
    item = err; 
    } else { 
     console.log("Query succeeded."); 
     data.Items.forEach(function(item) { 
      item += item.itemName; 
     }); 
     } 
     return item; 
}); 

Der Scan wartet nicht auf die Ausgabe, sondern auf den nächsten Schritt. Wie können wir einen synchronen Aufruf von Lambda zu Dynamob ausführen?

Answer 1

Sie müssen nicht synchron laufen, was keine gute Idee ist. Sie einen Rückruf von Scan und auch alle anderen Logik an der Stelle Sie den Rückruf erhalten,

const params = { 
 
    TableName: 'item-table', 
 
    FilterExpression : "#tagname = :itemId", 
 
    ExpressionAttributeNames: {"#tagname": "itemId"}, 
 
    ExpressionAttributeValues: {":itemId": "000001"}  
 
    }; 
 
var item =""; 
 
dynamo.scan(params, function(err, data) 
 
{ 
 
    callback(err,data); 
 
});

Zum Beispiel können Sie Code wie unten Refactoring,

scanDynamoDB(function(err,data){ 
 
    if (err) { 
 
     console.error("Unable to query. Error:", JSON.stringify(err, null, 2)); 
 
     item = err; 
 
     } else { 
 
      console.log("Query succeeded."); 
 
      data.Items.forEach(function(item) { 
 
       item += item.itemName; 
 
      }); 
 
     } 
 
}) 
 

 

 

 
function scanDynamoDB(callback) 
 
{ 
 
    const params = { 
 
     TableName: 'item-table', 
 
     FilterExpression : "#tagname = :itemId", 
 
     ExpressionAttributeNames: {"#tagname": "itemId"}, 
 
     ExpressionAttributeValues: {":itemId": "000001"}  
 
      }; 
 
     var item =""; 
 
     dynamo.scan(params, function(err, data) 
 
     { 
 
      callback(err,data); 
 
     }); 
 
}