क्वैरी DynamoDB कुछ भी नहीं

Question

करता है मैं एक लैम्ब्डा समारोह के लिए निम्न कोड है:

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(); 
}; 

मैं एक [उपयोगकर्ता] तालिका है कि इस तरह के रूप में परिभाषित किया गया है है:

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

जब मैं फोन फ़ंक्शन (एडब्ल्यूएस कंसोल या सीएलआई से) मैं लॉग में संदेशों को देख सकता हूं लेकिन getItem() के लिए कॉलबैक कभी नहीं कहा जाता है।

मैंने कोई कॉलबैक के साथ getItem (पैराम्स) करने की कोशिश की, फिर पूर्ण, सफलता और विफलता के लिए कॉलबैक परिभाषित किया लेकिन जब मैं भेजता हूं(), यहां तक ​​कि पूर्ण कॉलबैक भी नहीं कहा जाता है।

मुझे पता है कि कॉल अतुल्यकालिक कर रहे हैं और मुझे लगता है कि हो सकता है, लैम्ब्डा समारोह से पहले क्वेरी किया गया था और इसलिए कॉलबैक कहा जाता है नहीं किया जाएगा परिष्करण गया था, लेकिन, मैं समारोह के अंत में एक सरल बेवकूफ पाश जोड़ और बिना किसी कॉलबैक के कॉल के कॉल को 3 सेकंड के बाद समाप्त कर दिया गया।

मैंने बैचगेटइटम, getItem, listTables और स्कैन के विभिन्न कार्यों के साथ प्रयास किया। नतीजा वही है, कोई त्रुटि नहीं है लेकिन कॉलबैक फ़ंक्शन कभी नहीं कहा जाता है।

मैं शर्त लगा रहा हूं कि अगर मैं लैम्ब्डा का उपयोग किए बिना डायनेमो डीबी पूछता हूं तो मुझे परिणाम मिलेंगे इसलिए मैं वास्तव में सोच रहा हूं कि यहां कुछ भी क्यों नहीं हो रहा है।

मैं फ़ंक्शन के लिए एक भूमिका निभाता हूं और मैंने एक नीति बनाई है जो मुझे डायनेमो डीबी में कार्यक्षमताओं तक पहुंच की अनुमति देगी, लेकिन मुझे कोई फायदा नहीं हुआ।

नीति इस तरह दिखता है:

{ 
    "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": "*" 
     } 
    ] 
} 

मैं सिम्युलेटर में नीति भाग गया और यह काम किया के रूप में मैंने सोचा कि यह होगा। सुझाव?

Answer 1

तो, यह पता चला है कि कोड सही है। समस्या यह है कि डायनेमोड एपीआई उन सभी कॉलबैक का उपयोग करता है और मूल रूप से फ़ंक्शन समाप्त होता है इससे पहले कि डेटा पुनर्प्राप्त किया गया हो।

सबसे तेज़ फिक्स context.succeed() कॉल को निकालना है और डेटा पुनर्प्राप्त किया जाएगा। निश्चित रूप से एसिंक मॉड्यूल का उपयोग करने में मदद मिलेगी और यदि आप इसका उपयोग नहीं करना चाहते हैं, तो बस अपने कॉलबैक में काउंटर या बूलियन जोड़ें और फिर मूल्य बदलने तक प्रतीक्षा करें, यह दर्शाता है कि कॉलबैक को कॉल किया गया है (किस तरह का अगर आप इसके बारे में सोचते हैं तो बेकार है)

Answer 2

मेरे पास कुछ समान समस्याएं थीं और मुझे कई उपयोगी संसाधन नहीं मिला। यहां मैं क्या कर रहा हूं। शायद कोई स्मार्ट हमें बता सकता है कि यह सबसे अच्छा है या नहीं।

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); 
}); 

सारांश में, छोटे कार्य करने के लिए मुख्य कार्य के माध्यम से कॉलबैक की पासबैक होने, आवेदन डायनमो को पूरा करने तक जारी रखने के लिए अनुमति देता है। संदर्भ रखें। द्वितीयक फ़ंक्शन में आगे बढ़ें या वहां अन्य फ़ंक्शन जारी रखें।

Answer 3

कॉलबैक नरक से बचने के लिए, वादा का उपयोग करें। Funfunfunction नामक लड़के द्वारा यूट्यूब पर कुछ सुंदर अच्छे ट्यूटोरियल हैं।

Answer 4

मेरी समस्या यह है कि मेरी लैम्ब्डा एलिस्टी कैश से कनेक्ट करने के लिए वीपीसी में चल रही थी।इससे सार्वजनिक इंटरनेट संसाधनों जैसे डायनेमोडीबी और एपीआई गेटवे को अनिश्चित काल तक लटका दिया जाता है। डायनेमो डीबी तक पहुंचने के लिए मुझे अपने वीपीसी के भीतर एक एनएटी गेटवे स्थापित करना पड़ा।