diff options
| author | lian-manonog <lian.manonog@gmail.com> | 2024-08-21 17:11:57 +0100 |
|---|---|---|
| committer | lian-manonog <lian.manonog@gmail.com> | 2024-08-21 17:11:57 +0100 |
| commit | 5b2b4864eae129e112e70d093eb66498d7de401e (patch) | |
| tree | 1f477f0b6ff1f2f01cab682fd74859d0345d4411 /src/transform_lambda.py | |
| parent | 0c02bd3636ed8815aadf73685c20f8c76a073c99 (diff) | |
| download | de-project-bentley-5b2b4864eae129e112e70d093eb66498d7de401e.tar.gz de-project-bentley-5b2b4864eae129e112e70d093eb66498d7de401e.zip | |
wip: fact_purchase_order schema
Diffstat (limited to 'src/transform_lambda.py')
| -rw-r--r-- | src/transform_lambda.py | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/transform_lambda.py b/src/transform_lambda.py index 9238180..920a24f 100644 --- a/src/transform_lambda.py +++ b/src/transform_lambda.py @@ -1,8 +1,6 @@ import json import boto3 import re -import io -from io import StringIO import pandas as pd @@ -35,3 +33,5 @@ def read_from_s3_subfolder_to_df(tables, bucket, client=boto3.client("s3")): list_of_df = [pd.read_csv(key) for key in list_of_keys] table_dfs[table] = pd.concat(list_of_df) return table_dfs + + |