diff options
| author | Alex Schofield <git@ajschof.me> | 2025-02-19 03:32:58 +0000 |
|---|---|---|
| committer | Alex Schofield <git@ajschof.me> | 2025-02-19 03:32:58 +0000 |
| commit | bc3e976ff9b51ca47fa7ec6465b40e2e41ed6d0d (patch) | |
| tree | 22ca082c425a329aa3cc763516ac3c1416b5ef2d /obfuscator/csv_reader.py | |
| parent | f1edb55e4f3e2692cb6259cd658c70db6f0cadd4 (diff) | |
| download | gdpr-obfuscator-bc3e976ff9b51ca47fa7ec6465b40e2e41ed6d0d.tar.gz gdpr-obfuscator-bc3e976ff9b51ca47fa7ec6465b40e2e41ed6d0d.zip | |
improve error handling in read_s3()
Diffstat (limited to 'obfuscator/csv_reader.py')
| -rw-r--r-- | obfuscator/csv_reader.py | 9 |
1 files changed, 9 insertions, 0 deletions
diff --git a/obfuscator/csv_reader.py b/obfuscator/csv_reader.py index 3649681..97f67b7 100644 --- a/obfuscator/csv_reader.py +++ b/obfuscator/csv_reader.py @@ -63,6 +63,15 @@ class CSVReader: self.logger.info("S3 object read successfully") content = response["Body"].read().decode("utf-8") return CSVReader.read_string(content) + except client.exceptions.NoSuchKey: + self.logger.error(f"Object not found: {bucket}/{key}") + raise + except client.exceptions.ClientError as e: + self.logger.error(f"Error reading S3 object: {e}") + raise + except UnicodeDecodeError as e: + self.logger.error(f"Error decoding S3 object: {e}") + raise except Exception as e: self.logger.error(f"Error reading S3 object: {e}") raise |