From 775f2f746143196bcdf01c6bc29a0f0fd2dc27dc Mon Sep 17 00:00:00 2001 From: Golda Velez Date: Wed, 22 May 2024 02:48:13 -0700 Subject: [PATCH] do not decode --- logs-to-tsdb/kinesis-lambda.py | 2 ++ 1 file changed, 2 insertions(+) diff --git a/logs-to-tsdb/kinesis-lambda.py b/logs-to-tsdb/kinesis-lambda.py index cb984d7..eb2a77d 100644 --- a/logs-to-tsdb/kinesis-lambda.py +++ b/logs-to-tsdb/kinesis-lambda.py @@ -34,7 +34,9 @@ def handler(event, context): batched = [] + print("NOT decoding data") for record in event['Records']: + payload = record['kinesis']['data'] # it doesn't appear to be encoded # payload = b64decode(record['kinesis']['data']).decode('utf-8')