Commit 7bf9246c authored by 张彦钊's avatar 张彦钊

增加重命名

parent 7a0f87ee
......@@ -21,7 +21,8 @@ def get_data():
db = pymysql.connect(host='10.66.157.22', port=4000, user='root', passwd='3SYz54LS9#^9sBvC', db='jerry_prod')
sql = "select * from esmm_data where stat_date >= '2018-11-20'"
esmm = con_sql(db,sql)
esmm = esmm.rename(columns={1: "device_id"})
esmm = esmm.rename(columns={0:"stat_date",1: "device_id",2:"ucity_id",3:"cid_id",4:"diary_service_id",5:"y",
6:"z",7:"clevel1_id",8:"slevel1_id"})
print("esmm data ok")
print(esmm.head())
db = pymysql.connect(host='10.66.157.22', port=4000, user='root', passwd='3SYz54LS9#^9sBvC', db='eagle')
......@@ -68,7 +69,6 @@ def transform(df,table):
class multiFFMFormatPandas:
def __init__(self):
self.field_index_ = None
self.feature_index_ = None
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment