change test file

monitor.py

@@ -33,12 +33,12 @@ def gbk_decoder(s):
 def maidian(x):
     try:
         data = x[1]
-        if 'type' in data and 'device' in data and 'params' in data and 'card_content_type' in data['params'] \
-                and data['type'] == 'on_click_card' and data['params']['card_content_type'] == 'diary':
-            # and data["device"]['device_id'] == "E417C286-40A4-42F6-BDA9-AEEBD8FEC3B6"
-            print("get device id")
-            return True
-
+        if 'type' in data and 'device' in data and 'params' in data and 'card_content_type' in data['params']:
+            if data['type'] == 'on_click_card' and data['params']['card_content_type'] == 'diary':
+                # and data["device"]['device_id'] == "E417C286-40A4-42F6-BDA9-AEEBD8FEC3B6"
+                return True
+            else:
+                return False
         else:
             return False
 
@@ -105,7 +105,7 @@ def model(rdd):
 if __name__ == '__main__':
     sc = SparkContext(conf=SparkConf().setMaster("spark://nvwa01:7077").setAppName("dislike_filter").set(
         "spark.io.compression.codec", "lzf"))
-    ssc = StreamingContext(sc, 10)
+    ssc = StreamingContext(sc, 6)
     sc.setLogLevel("WARN")
     kafkaParams = {"metadata.broker.list": "172.16.44.25:9092,172.16.44.31:9092,172.16.44.45:9092",
                    "group.id": "dislike",