Update bq.py
Browse files
bq.py
CHANGED
@@ -10,6 +10,9 @@ def preprocess_csv(file_path):
|
|
10 |
# Define columns to be converted
|
11 |
date_columns = ['Order_Date', 'State_Date', 'Entry_Month']
|
12 |
|
|
|
|
|
|
|
13 |
# Convert specified columns from DD/MM/YY to 'YYYY-MM-DD 00:00:00 UTC'
|
14 |
for column in date_columns:
|
15 |
if column in df.columns:
|
|
|
10 |
# Define columns to be converted
|
11 |
date_columns = ['Order_Date', 'State_Date', 'Entry_Month']
|
12 |
|
13 |
+
if 'bag_id_cn' in df.columns:
|
14 |
+
df['bag_id_cn'] = df['bag_id_cn'].replace({'\..*': ''}, regex=True).astype('Int64')
|
15 |
+
|
16 |
# Convert specified columns from DD/MM/YY to 'YYYY-MM-DD 00:00:00 UTC'
|
17 |
for column in date_columns:
|
18 |
if column in df.columns:
|