Commit 39ff6253 authored by 高雅喆's avatar 高雅喆

update

parent 54bb47f7
......@@ -150,7 +150,9 @@ if __name__ == '__main__':
for i in a:
insert_sql = "insert into user_portrait_tags values({stat_date},{cl_id},{tag_list})"\
.format(stat_date=stat_date, cl_id=i[0], tag_list=json.dumps(i[1]))
cur_jerry_test.execute(insert_sql)
db_jerry_test.commit()
db_jerry_test.close()
# result_last = result_rename.withColumn("stat_date", lit(stat_date))
# result_last.show()
# df = result_last.select("stat_date", "cl_id", concat_ws(',', 'tag_list').alias("tag_list"))
......
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