Lambda でトリガーを Kinesis に指定した時、パラメーターは base64 でエンコードされて渡されます。その値を読む Lamba のプログラムです。
lambda_monitor.py
# -*- coding: utf-8 -*-
#
# lambda_monitor.py
#
# Sep/21/2021
#
# --------------------------------------------------------------------
import sys
import base64
import json
# --------------------------------------------------------------------
def lambda_handler(event, context):
sys.stderr.write("*** lambda_handler *** start ***\n")
print("Received event: " + json.dumps(event, indent=2))
sys.stderr.write("*** lambda_handler *** bbb ***\n")
data_in = event["Records"][0]["kinesis"]["data"]
decoded = base64.b64decode(data_in)
str_out = decoded.decode()
print(str_out)
sys.stderr.write("*** lambda_handler *** end ***\n")
#
return "OK"
# --------------------------------------------------------------------