Merge pull request #33 from moorepatrick/fix/MAT-1641_Event_Record_Newline

MAT-1641: Add Newline To put_record Data

Author: patrickherring-TRI

beep/utils/events.py

@@ -99,7 +99,7 @@ def put_basic_event(self, module_name, record):
 
         if self.mode == 'test':
             response = self.kinesis.put_record(StreamName=self.stream,
-                                               Data=record,
+                                               Data=record + "\n",
                                                PartitionKey=str(hash('test'))
                                                )
         elif self.mode == 'events_off':
@@ -115,7 +115,7 @@ def put_basic_event(self, module_name, record):
 
         else:
             response = self.kinesis.put_record(StreamName=self.stream,
-                                               Data=record,
+                                               Data=record + "\n",
                                                PartitionKey=str(hash(module_name))
                                                )
         return response
@@ -161,7 +161,7 @@ def put_service_event(self, action, status, data):
 
         if self.mode == 'test':
             response = self.kinesis.put_record(StreamName=self.stream,
-                                               Data=json.dumps(record),
+                                               Data=json.dumps(record) + "\n",
                                                PartitionKey=str(hash('test'))
                                                )
 
@@ -178,7 +178,7 @@ def put_service_event(self, action, status, data):
 
         else:
             response = self.kinesis.put_record(StreamName=self.stream,
-                                               Data=json.dumps(record),
+                                               Data=json.dumps(record) + "\n",
                                                PartitionKey=str(hash(self.service))
                                                )
         return response