Commit 810276c8 authored by litaolemo's avatar litaolemo

update

parent 9ac2ac65
...@@ -169,7 +169,7 @@ huidu_device_id_df.show(1) ...@@ -169,7 +169,7 @@ huidu_device_id_df.show(1)
sql_res = huidu_device_id_df.collect() sql_res = huidu_device_id_df.collect()
# 设备id # 设备id
for device_id in sql_res: for device_id in sql_res:
device_id_dict[device_id] = 1 device_id_dict[device_id.device_id] = 1
# 设备对应画像数量 # 设备对应画像数量
second_demands_tag_count = {} second_demands_tag_count = {}
...@@ -190,7 +190,7 @@ temp_null_count = 0 ...@@ -190,7 +190,7 @@ temp_null_count = 0
# 500: [0, 0, 0], # 500: [0, 0, 0],
# 1000: [0, 0, 0], # 1000: [0, 0, 0],
# } # }
print(device_id_dict) # print(device_id_dict)
for redis_count, device_id in enumerate(device_id_dict): for redis_count, device_id in enumerate(device_id_dict):
# if redis_count >= 50:break # if redis_count >= 50:break
......
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