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