How can I run synchronous dynamodb request in lambda?

user_8894871 0
Viewed 8256
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;
});

Scan is not waiting to return the output but going to next step. How can we run synchronous call from lambda to dynamodb.

synchronous amazon-web-services lambda
2 Answers

If you really need synchronous scan, you can use one of the ways below:

1. Using Promise resource of JavaScript:

const params = {
    TableName: 'item-table',   
    FilterExpression : "#tagname = :itemId",
    ExpressionAttributeNames: {"#tagname": "itemId"},
    ExpressionAttributeValues: {":itemId": "000001"} };

function scan(params) {
  return new Promise((resolve, reject) => {
    dynamo.scan(params, (err, data) => {
      if (err)
        reject(err);
      else
        resolve(data);
    };
  };
}

async function syncScan() {
  var data;
  try {
    data = await scan(params);
    console.log("Query succeeded.");
  }
  catch (err) {
  console.error("Unable to query. Error:", JSON.stringify(err, null, 2));
  }
        
  return data;
}

syncScan();

2. Using the aws-sdk return objects:

const AWS = require('aws-sdk');
AWS.config.update({ region: 'sa-east-1' });
const docClient = new AWS.DynamoDB.DocumentClient();

async function syncScan() {

  const params = {
    TableName: 'item-table',   
    FilterExpression : "#tagname = :itemId",
    ExpressionAttributeNames: {"#tagname": "itemId"},
    ExpressionAttributeValues: {":itemId": "000001"} 
  };

  const awsRequest = await docClient.scan(params);
  const result = await awsRequest.promise();
  console.log(result.Items); // <<--- Your results are here
}

syncScan();
user_113576450

You don't need to run Synchronously, which is not a good idea. Do a callback from scan and do all other logic at the place you are receiving the 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);
});

For example, you can refactor code like below,

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

user_76669720
Related