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"
# --------------------------------------------------------------------