Commit 171bcc18 authored by 张彦钊's avatar 张彦钊

change test file

parent 796d5b46
......@@ -96,9 +96,8 @@ def write_redis(device_id,cid_list):
def model(rdd):
try:
rdd.filter(lambda x: maidian(x))
#.map(lambda x:get_data(x)).na.drop().\
#groupByKey().map(lambda x,y:write_redis(x,y))
rdd.filter(lambda x: maidian(x)).map(lambda x:get_data(x)).na.drop().\
groupByKey().map(lambda x,y:write_redis(x,y))
except Exception as e:
print("fail")
print(e)
......
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