diff --git a/singer_encodings/csv.py b/singer_encodings/csv.py index 4711cea..2dea166 100644 --- a/singer_encodings/csv.py +++ b/singer_encodings/csv.py @@ -19,7 +19,7 @@ def get_row_iterator(iterable, options=None): which can be used to yield CSV rows.""" options = options or {} - file_stream = codecs.iterdecode(iterable, encoding='utf-8') + file_stream = codecs.iterdecode(iterable, encoding=options.get('encoding', 'utf-8')) # Replace any NULL bytes in the line given to the DictReader reader = csv.DictReader((line.replace('\0', '') for line in file_stream), fieldnames=None, restkey=SDC_EXTRA_COLUMN, delimiter=options.get('delimiter', ','))