Querying DynamoDB mit Lambda tut nichts

Question

Ich habe den folgenden Code für eine Lambda-Funktion:

console.log('Loading function'); 
var aws = require('aws-sdk'); 
var ddb = new aws.DynamoDB(); 

function getUser(userid) { 
    var q = ddb.getItem({ 
     TableName: "Users", 
     Key: { 
      userID: { S: userid } } 
     }, function(err, data) { 
      if (err) { 
       console.log(err); 
       return err; 
      } 
      else { 
       console.log(data); 
      } 
    }); 
    console.log(q); 
} 


exports.handler = function(event, context) { 
    console.log('Received event'); 
    getUser('user1'); 
    console.log("called DynamoDB"); 
    context.succeed(); 
}; 

Ich habe eine [Benutzer] Tabelle, die als solche definiert:

{ 
    "cognitoID": { "S": "token" }, 
    "email": { "S": "user1@domain.com" }, 
    "password": { "S": "somepassword" }, 
    "tos_aggreement": { "BOOL": true }, 
    "userID": { "S": "user1" } 
} 

als ich den Anruf Funktion (von der AWS-Konsole oder der CLI) Ich kann die Nachrichten in den Protokollen sehen, aber der Rückruf für die getItem() wird nie aufgerufen.

Ich habe versucht mit getItem (params) ohne Rückruf, dann die Rückrufe für vollständig, Erfolg und Misserfolg definiert, aber wenn ich die send(), wird auch die komplette Rückruf nicht aufgerufen.

Ich weiß, dass die Aufrufe asynchron sind und ich dachte, dass vielleicht die Lambda-Funktion beendet wurde, bevor die Abfrage durchgeführt wurde und daher der Callback nicht aufgerufen würde, aber ich fügte eine einfache dumme Schleife am Ende der Funktion und der Anruf endete nach 3 Sekunden, ohne dass die Rückrufe überhaupt angerufen wurden.

Ich habe versucht mit verschiedenen Funktionen BatchGetItem, GetItem, ListTables und Scan. Das Ergebnis ist das gleiche, kein Fehler, aber die Callback-Funktion wird nie aufgerufen.

Ich wette, wenn ich DynamoDB abfrage, ohne Lambda zu verwenden, wird es mir die Ergebnisse bringen, also frage ich mich wirklich, warum hier nichts passiert.

Ich erstelle eine Rolle für die Funktion und ich habe eine Richtlinie erstellt, die den Zugriff auf die Funktionalitäten in dynamoDB erlaubt, die ich brauche, aber ohne Erfolg.

Die Politik sieht wie folgt aus:

{ 
    "Version": "2012-10-17", 
    "Statement": [ 
     { 
      "Effect": "Allow", 
      "Action": [ 
       "lambda:InvokeFunction" 
      ], 
      "Resource": "arn:aws:lambda:*:*:*" 
     }, 
     { 
      "Effect": "Allow", 
      "Action": [ 
       "dynamodb:GetItem", 
       "dynamodb:BatchGetItem", 
       "dynamodb:Scan", 
       "dynamodb:PutItem", 
       "dynamodb:Query", 
       "dynamodb:GetRecords", 
       "dynamodb:ListTables" 
      ], 
      "Resource": "arn:aws:dynamodb:*:*:*" 
     }, 
     { 
      "Action": [ 
       "logs:*" 
      ], 
      "Effect": "Allow", 
      "Resource": "*" 
     } 
    ] 
} 

ich die Politik im Simulator lief und es funktionierte, wie ich dachte, es würde. Vorschläge?

Answer 1

So stellt sich heraus, dass der Code korrekt ist. Das Problem ist, dass die Dynamodb-API alle diese Rückrufe verwendet und die Funktion endet, BEVOR die Daten abgerufen wurden.

Die schnellste Lösung ist das Entfernen des context.succeed() Anrufs und die Daten werden abgerufen. Natürlich würde die Verwendung des asynchronen Moduls helfen, und wenn Sie das nicht verwenden möchten, fügen Sie einfach einen Zähler oder einen booleschen Wert zu Ihrem Callback hinzu und warten Sie dann, bis sich der Wert geändert hat, um anzuzeigen, dass der Callback aufgerufen wurde (welche Art von saugt, wenn Sie daran denken)

Answer 2

Ich hatte einige ähnliche Probleme und fand nicht viele hilfreiche Ressourcen. Hier ist, was ich getan habe. Wahrscheinlich kann uns jemand schlauer sagen, ob das bestest ist.

function getHighScores(callback) { 
    var params = { 
     TableName : 'sessions', 
     ScanFilter: {"score":{"AttributeValueList":[{"N":"0"}], "ComparisonOperator":"GT"}}, 
    }; 
    var dynamo = new AWS.DynamoDB(); 
    dynamo.scan(params, function(err, data) { 
     if (err) { 
      console.log (err) 
      callback(err); 
     } else { 
      callback(data.Items); 
      console.log(data.Items); 
     } 
    }); 
} 



getHighScores(function (data) { 
    console.log(data); 
    context.succeed(data); 
}); 

Zusammengefasst die Rücksende der Rückruf durch die Hauptfunktion der kleineren Funktion ermöglicht die Anwendung, bis die Vollendung des Dynamo fortzusetzen. Behalten Sie context.succeed in der sekundären Funktion bei oder setzen Sie andere Funktionen dort fort.

Answer 3

Um die Callback-Hölle zu vermeiden, verwenden Sie Promises. Es gibt einige ziemlich gute Tutorials auf youtube von einem Typen namens funfunfunction.

Answer 4

Mein Problem ist, dass mein Lambda in einer VPC lief, um sich mit ElastiCache zu verbinden.Dies führt dazu, dass alle Abfragen an öffentliche Internetressourcen wie DynamoDB und API Gateway auf unbestimmte Zeit unterbrochen werden. Ich musste in meiner VPC ein NAT-Gateway einrichten, um auf DynamoDB zugreifen zu können.