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:
|