aboutsummaryrefslogtreecommitdiffstats
path: root/obfuscator/csv_reader.py
diff options
context:
space:
mode:
authorAlex Schofield <git@ajschof.me>2025-02-18 21:19:51 +0000
committerAlex Schofield <git@ajschof.me>2025-02-18 21:19:51 +0000
commit2c19a941bb3afe4145761c4c6e54880490160aa2 (patch)
tree6ed61e3753deef5b86b919f02e6b3f641a66d0a6 /obfuscator/csv_reader.py
parent878d6e0dfd0ce1bfe00ca0bcadce6dd16749e6d3 (diff)
downloadgdpr-obfuscator-2c19a941bb3afe4145761c4c6e54880490160aa2.tar.gz
gdpr-obfuscator-2c19a941bb3afe4145761c4c6e54880490160aa2.zip
call get_s3_path() in read_s3 and debug log path
Diffstat (limited to 'obfuscator/csv_reader.py')
-rw-r--r--obfuscator/csv_reader.py4
1 files changed, 3 insertions, 1 deletions
diff --git a/obfuscator/csv_reader.py b/obfuscator/csv_reader.py
index eb93609..578b96b 100644
--- a/obfuscator/csv_reader.py
+++ b/obfuscator/csv_reader.py
@@ -2,6 +2,7 @@ import csv
import io
from typing import List, Dict
from obfuscator.logger import get_logger
+from obfuscator.utils import get_s3_path
# Create the logger
logger = get_logger("CSVReader")
@@ -48,7 +49,8 @@ class CSVReader:
and return the data as a list of dictionaries.
"""
# Yet to be implemented.
- return []
+ bucket, key = get_s3_path(path)
+ logger.debug(f"Reading S3 CSV from: {bucket}/{key}")
@staticmethod
def read_string(content: str) -> List[Dict[str, str]]:
git.ajschof.me — hosted by ajschofield — powered by cgit