Skip to content

Commit 0069bab

Browse files
authored
Update ingest_and_query.py
1 parent 1c37d18 commit 0069bab

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

ingest_and_query.py

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -109,6 +109,8 @@
109109
influx_df = pd.DataFrame(
110110
results, columns=["_field", "_value", "_measurement", "time", "agency", "sku"]
111111
)
112+
113+
# data preprocessing
112114
temp_data = influx_df[["_field", "_value"]]
113115

114116
# remove irrelevant columns

0 commit comments

Comments
 (0)