fix dynomodb ecsrole

 Committer: nkumar

Author: nkumar

src/producer_dd.js

@@ -4,16 +4,14 @@
 const config = require('config')
 const pg = require('pg')
 const logger = require('./common/logger')
-//const pushToKafka = require('./services/pushToKafka')
 const pushToDynamoDb = require('./services/pushToDynamoDb')
 const pgOptions = config.get('POSTGRES')
 const pgConnectionString = `postgresql://${pgOptions.user}:${pgOptions.password}@${pgOptions.host}:${pgOptions.port}/${pgOptions.database}`
 const pgClient = new pg.Client(pgConnectionString)
 const auditTrail = require('./services/auditTrail');
 const express = require('express')
 const app = express()
-const port = 3100
-//console.log(`pgConnectionString value = ${pgConnectionString}`)
+const port = 3000
 var pl_processid;
 var pl_randonseq = 'err-'+(new Date()).getTime().toString(36) + Math.random().toString(36).slice(2);
 async function setupPgClient () {
@@ -37,7 +35,7 @@ async function setupPgClient () {
 	var pl_payload = JSON.stringify(payload.payload)	   
    const validTopicAndOriginator = (pgOptions.triggerTopics.includes(payload.topic)) && (pgOptions.triggerOriginators.includes(payload.originator)) // Check if valid topic and originator
         if (validTopicAndOriginator) {
-        logger.debug(`Producer DynamoDb : ${pl_seqid} ${pl_processid} ${pl_table} ${pl_uniquecolumn} ${pl_operation} ${payload.timestamp}`);
+        logger.info(`Producer DynamoDb : ${pl_seqid} ${pl_processid} ${pl_table} ${pl_uniquecolumn} ${pl_operation} ${payload.timestamp}`);
 	await pushToDynamoDb(payload)
 	} else {
           logger.debug('Ignoring message with incorrect topic or originator')

src/services/pushToDynamoDb.js

@@ -3,8 +3,8 @@ const logger = require('../common/logger')
 const _ = require('lodash')
 var AWS = require("aws-sdk");
 async function pushToDynamoDb(payload) {
-  try { console.log('----Inside DynomoDB code -------');
-          console.log(payload)
+  try { console.log('----Push To DynomoDB  -------');
+        //  console.log(payload)
 	   p_dd_payloadseqid = payload.payload.payloadseqid;
 	    var params = {
 	    TableName: 'test_pg_ifx_payload_sync',
@@ -20,14 +20,14 @@ async function pushToDynamoDb(payload) {
   		}
 	  var docClient = new AWS.DynamoDB.DocumentClient({region: 'us-east-1'});
 	  docClient.put(params, function(err, data) {
-    	if (err) console.log(err);
-    	else console.log(data);
+    	if (err) logger.error(err);
+    	else logger.info(data);
   	});
 
   } catch (e) {
-          console.log(e)
+          logger.error(`Error at PushToDynamoDB "${e}"`)
   }
 }
 
-console.log("hello from DD")
+console.log("--from DyanomoDb==")
 module.exports = pushToDynamoDb