У меня есть триггер, настроенный на два сегмента S3, и у каждого есть несколько объектов CSV, созданных одновременно.
Как спроектировать лямбду так, чтобы не возникало исключение копирования Redshift или условие взаимоблокировки, и все файлы копировались в Redshift.
Сценарий - 4 CSV создаются в двух сегментах S3 одновременно, которые запускают несколько экземпляров одной и той же лямбды для копирования CSV в одну и ту же таблицу. Наблюдаемое исключение: "Обнаружено исключение при выполнении команды Redshift Copy: Исключение при чтении из потока. Исключение: в Npg sql .NpgsqlReadBuffer. <> C__DisplayClass31_0. d.MoveNext () --- Конец трассировки стека от предыдущего местоположения, где было сгенерировано исключение --- в Npg sql .NpgsqlConnector. <> c__DisplayClass161_0. d.MoveNext () --- Конец трассировки стека от предыдущего местоположения, где было сгенерировано исключение --- в Npg sql .NpgsqlDataReader.NextResult (логическое асин c, логическое isConsuming) в Npg sql .NpgsqlDataReader.NextResult () в Npg sql .NpgsqlCommand.ExecuteDbDataReader (поведение CommandBehavior, логическое асинхронное c, CancellationToken cancellationToken) в Npg sql .NpgsqlCommand.ExecuteNonQuery (логическое асинхронное cenNokNoGNoGNoGNoG) .ExecuteNonQuery () в CLC_PMCSvRedshift.Function.ExecuteRedshiftCopyCommand (String copy SQL, контекст ILambdaContext) "