Я создаю лямбду, которая принимает ввод потока кинезиса на основе экземпляра RDS Aurora Postgres, анализирует изменения в операторах для обновления домена службы упругого поиска AWS. (Это все в VPC, поэтому я не могу использовать пожарный шланг данных, насколько я могу судить). Лямбда довольно прямолинейна, но у меня возникают проблемы с выяснением, как получить измененный ряд. В документации Amazon говорится (https://docs.aws.amazon.com/AmazonRDS/latest/AuroraUserGuide/DBActivityStreams.html#DBActivityStreams.AuditLog.databaseActivityEventList):
События доступа генерируются из команд SQL, таких как CONNECT и SELECT. События изменения генерируются из команд SQL, таких как CREATE и INSERT.
В конце статьи приводятся примеры объектов, возвращаемых для операторов CREATE TABLE и * 1009. * Но мне нужно получить идентификатор соответствующей строки, поэтому я могу получить все атрибуты, связанные сэто для обновления / вставки домена Elastic Search. Кто-нибудь знает, как выглядит этот объект и как я могу получить эту информацию?