service model 优化

spark/featureEng2.py

@@ -335,7 +335,7 @@ def itemFeaturesToRedis(samples,itemDF,columns,redisKey):
             conn.set(newKey, v)
             conn.expire(newKey, 60 * 60 * 24 * 7)
 
-    item_static_columns = [col for col in samples.columns if col.endswith("Bucket") or col.endswith("_number")]
+    item_static_columns = [idCol] + [col for col in columns if col.endswith("Bucket") or col.endswith("_number")]
 
     #根据timestamp获取每个user最新的记录
     prefixSamples = samples.groupBy(idCol).agg(F.max("timestamp").alias(timestampCol))