in src/utils.py [0:0]
def df_from_datacapture(filename, columns):
csv_io = StringIO()
csv_io.writelines(f"{','.join(columns)}\n")
with open(filename, 'r') as f:
lines = f.readlines()
for line in lines:
data = json.loads(line)['captureData']['endpointInput']['data']
csv_io.write(f'{data}\n')
csv_io.seek(0)
return pd.read_csv(csv_io)