У меня есть сценарий использования для вставки нескольких записей каждые 5 минут в поток данных Kinesis. Я буду создавать рабочий процесс, который будет выполняться каждые 5 минут.В этом рабочем процессе будет моя работа по вставке нескольких сообщений ~ 4-5 сообщений. После этого будет выполняться мое задание на обработку и так далее.Я пишу весь мой код на Python.Я использую API put_record или какой-нибудь KPL для реализации?Беспокойство по поводу асинхронного поведения KPL имеет значение для моего варианта использования?Я вижу реализацию KPL в Java, как сделать то же самое в Python?