Search code examples
node.jsamazon-web-servicesamazon-dynamodbamazon-lex

Promisify is not a function


I am working on lex and I am trying to store user data in DynamoDB while using NodeJS

Here is my code:

'use strict';

const uuidV1 = require('uuid/v1');
const AWS = require('aws-sdk');
const promisify = require('es6-promisify');
const dynamo = new AWS.DynamoDB.DocumentClient();

module.exports.saveBookingToDatabase = function(Arrival_city, Departure_city, Flight_type, Phone_number){
    console.log('saveBookingToDatabase');

    const item = {};
    item.bookingId = uuidV1();
    item.arrivalCity = Arrival_city;
    item.departureCity = Departure_city;
    item.classType = Flight_type;
    item.phone = Phone_number;

    const params = {
        TableName: 'airstallion',
        Item: item
    };



  const putAsync = promisify(dynamo.put, dynamo);

  return putAsync(params).then(() => {
      console.log(`Saving ticket ${JSON.stringify(item)}`);
      return item;
    })
    .catch(error => {
      Promise.reject(error);
    });
  }

When i run the program is returning the following error


Solution

  • Since aws-sdk library supports promise, its not necessary to use es6-promisify library. Using node.js async/await we shall achieve the same use case.

    'use strict';
    
    const uuidV1 = require('uuid/v1');
    const AWS = require('aws-sdk');
    const dynamo = new AWS.DynamoDB.DocumentClient();
    
    module.exports.saveBookingToDatabase = async function(Arrival_city, Departure_city, Flight_type, Phone_number){
        console.log('saveBookingToDatabase');
    
        const item = {};
        item.bookingId = uuidV1();
        item.arrivalCity = Arrival_city;
        item.departureCity = Departure_city;
        item.classType = Flight_type;
        item.phone = Phone_number;
    
        const params = {
            TableName: 'airstallion',
            Item: item
        };
    
        try {
            let result = await dynamo.put(params)
            console.log(`Saving ticket ${JSON.stringify(item)}`);
        return item;  
        } catch(e) {
            throw (e)
        }
    }