Мы используем все наши аналитические каналы через API-Gateway> Kinesis Streams> Lambda> FireHose> Redshift Tables.
AWS Lambda - это наш след преобразования, принимает записи потоков Kinesis, изменяет событие аналитики в зависимости от контекста и передает его в FireHouse, чтобы сохранить в Redshift DB.
В этом путешествии мы хотели обновить записи Redshift при определенных условиях (в основном UPSERT (Insert | Update)). есть ли что-нибудь в пожарном шланге, что можно избежать дублирования записей в красном смещении?