change test file

550244a8 · 张彦钊 · 8c7abb46 · 550244a8
Commit 550244a8 authored Aug 16, 2019 by 张彦钊
Hide whitespace changes
Inline Side-by-side

Showing with 2 additions and 1 deletion

monitor.py monitor.py +2 -1

No files found.
--- a/monitor.py
+++ b/monitor.py
@@ -94,7 +94,8 @@ def write_redis(device_id,cid_list):

 def model(rdd):
    try:
-        rdd.filter(lambda x: maidian(x)).map(lambda x:get_data(x))
+        rdd.filter(lambda x: maidian(x))
+            # .map(lambda x:get_data(x))
            #                                  .na.drop().groupByKey())\
            # .map(lambda x:write_redis(x[0],x[1]))
    except Exception as e: