Я хочу использовать лямбду (python) для чтения данных из потока данных Kinesis и вывода sh в другой поток данных Kinesis. Я хочу создать расширенный потребитель разветвления для исходного потока, чтобы он мог использоваться лямбда-функцией. Может кто-нибудь, пожалуйста, дайте мне знать, как это можно сделать, или укажите мне какую-то ясную документацию, так как мне не повезло, пытаясь найти простой учебник или способ.