修改文件写入路径

tensnsorflow/es/feature.py

@@ -163,7 +163,8 @@ def get_predict(date,value_map):
 
 
 if __name__ == '__main__':
-    path = "/home/gmuser/esmm_data/"
+    # path = "/home/gmuser/esmm_data/"
+    path = "/data/esmm/"
     date,value = get_data()
     get_predict(date, value)
 

tensnsorflow/es/pipeline.sh

@@ -2,7 +2,7 @@
 
 PYTHON_PATH=/home/gaoyazhe/miniconda3/bin/python
 MODEL_PATH=/srv/apps/ffm-baseline/tensnsorflow/es
-DATA_PATH=/home/gmuser/esmm_data
+DATA_PATH=/data/esmm
 
 echo "rm leave tfrecord"
 rm ${DATA_PATH}/tr/*

tensnsorflow/es/to_database.py

@@ -37,7 +37,7 @@ def native_set_join(lst):
 def main():
 
     # native queue
-    df2 = pd.read_csv('/home/gmuser/esmm_data/native.csv')
+    df2 = pd.read_csv('/data/esmm/native.csv')
     df2['cid_id'] = df2['cid_id'].astype(str)
 
     df1 = pd.read_csv("/home/gmuser/esmm_data/native/pred.txt",sep='\t',header=None,names=["ctr","cvr","ctcvr"])