batchWriteItem

gistfile1.txt

            
            params = {
              RequestItems: {},
            };
            params.RequestItems[process.env.BlamG2Table]=[];

            var i=0;          
            
             response.data.forEach(element => {
                  i++;
                  if (element.Fields.blmw_task_type=='Review & Approve' && element.Fields.blmw_task_status == 'approved') 
                    { var dateC=new Date().toString();
                   
                      //console.log(JSON.parse(element));
                      params.RequestItems[process.env.BlamG2Table].push({ PutRequest: {
                                    Item:  {"BlamId": {"S":element.ItemID}, "Source": {"S":"Blam"}, "DateCollected":{ "S": dateC },"Status":{"S":"In"}},
                                    ConditionExpression: "attribute_not_exists(BlamId)"
                                }
                              })
                    }
                    
              });
   
            await dynamo.batchWriteItem(params).promise(); // Add items to the table