美购精排模型

spark/featureEng.py

 import sys
+import os
+
 
-from datetime import date, timedelta,datetime
+from datetime import date, timedelta
 from elasticsearch import Elasticsearch
 from elasticsearch.helpers import scan
 
@@ -17,7 +19,7 @@ from pyspark.ml.feature import StringIndexer, QuantileDiscretizer, MinMaxScaler
 
 from collections import defaultdict
 import json
-import os
+
 sys.path.append(os.path.dirname(os.path.abspath(os.path.dirname(__file__))))
 import utils.connUtils as connUtils