change test file

monitor.py

@@ -126,7 +126,8 @@ def group_redis(device_id,cid_list):
 
 
 def group_write(rdd):
-    rdd.groupByKey().map(lambda x: x[0]).collect()
+    return rdd.groupByKey().map(lambda x: x[0]).collect()
+
 
 
 # Spark-Streaming-Kafka
@@ -143,6 +144,6 @@ kafkaParams = {"metadata.broker.list": "172.16.44.25:9092,172.16.44.31:9092,172.
 stream = KafkaUtils.createDirectStream(ssc, ["gm-maidian-data"], kafkaParams)
 transformstream = stream.transform(lambda x:model(x)).foreachRDD(group_write)
 # transformstream.pprint()
-# print(transformstream)
+print(transformstream)
 ssc.start()
 ssc.awaitTermination()
\ No newline at end of file