get a sample of the data

3box · May 22, 2024 · ddbd678 · ddbd678
1 parent 9711d29
commit ddbd678
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/logs-to-tsdb/kinesis-lambda.py b/logs-to-tsdb/kinesis-lambda.py
@@ -5,6 +5,7 @@
 import psycopg2.extras
 from base64 import b64decode
 from datetime import datetime, timezone
+from pprint import pprint
 
 # Database connection parameters
 DB_HOST = os.environ['DB_HOST']
@@ -33,6 +34,7 @@ def handler(event, context):
     batched = []
 
     for record in event['Records']:
+        pprint(record)
         # Decode the Kinesis data
         payload = b64decode(record['kinesis']['data']).decode('utf-8')
         data = json.loads(payload)