p15679402
/
bigdata
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

.

This commit is contained in:
guange 2019-01-18 15:37:11 +08:00
parent dfdd636754
commit 9f1693029a
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
chapter3/spark.py
View File

@ -92,7 +92,7 @@ def collect_from_type(spark):
for row in df.rdd.collect(): for row in df.rdd.collect():
if row["from_type"]: if row["from_type"]:
data[row["from_type"]] = row["N"] data[row["from_type"]] = row["N"]
mysql_execute("update datas set data = '{}' where `key` = 'from_type'".format( json.dumps(data) )) mysql_execute("update datas set data = '{}' where `key` = 'from_type'".format( json.dumps(data,ensure_ascii=False) ))
if __name__ == "__main__": if __name__ == "__main__":