Commit c5ec5ae3 authored by 张彦钊's avatar 张彦钊

修改str cat函数

parent 2e6fd82b
...@@ -19,12 +19,12 @@ def con_sql(db,sql): ...@@ -19,12 +19,12 @@ def con_sql(db,sql):
def get_data(): def get_data():
db = pymysql.connect(host='10.66.157.22', port=4000, user='root', passwd='3SYz54LS9#^9sBvC', db='jerry_prod') 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'" sql = "select * from esmm_data where stat_date >= '2018-11-20' limit 6"
esmm = con_sql(db,sql) esmm = con_sql(db,sql)
esmm = esmm.rename(columns={0:"stat_date",1: "device_id",2:"ucity_id",3:"cid_id",4:"diary_service_id",5:"y", 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"}) 6:"z",7:"clevel1_id",8:"slevel1_id"})
print("esmm data ok") print("esmm data ok")
esmm["x"] = esmm["y"].str.cat(esmm["z"].values.tolist(), sep=",") esmm["x"] = esmm["stat_date"].str.cat(esmm["ucity_id"], sep=",")
print(esmm.head()) print(esmm.head())
# print(esmm.shape) # print(esmm.shape)
# db = pymysql.connect(host='10.66.157.22', port=4000, user='root', passwd='3SYz54LS9#^9sBvC', db='eagle') # db = pymysql.connect(host='10.66.157.22', port=4000, user='root', passwd='3SYz54LS9#^9sBvC', db='eagle')
......
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