Update start.py

Engineering-Research-and-Development · Jun 16, 2022 · 0eb3c27 · 0eb3c27
1 parent 30f483a
commit 0eb3c27
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/Test/start.py b/Test/start.py
@@ -14,12 +14,12 @@
 event, ssc = connector.Prime(sc, 5 , StorageLevel.MEMORY_AND_DISK_2)
 
 event = event.flatMap(lambda x: x.entities).map(lambda x: x.attrs['price'].value)
-#response = event.map(lambda x : replier.UnstructuredReplyToBroker('{ "value" :' + str(20) +' }'))
-#response2 = event.map(lambda x: replier.SemistructuredReplyToBroker("20", '{"value" : %%TOREPLACE%% }'))
+response = event.map(lambda x : replier.UnstructuredReplyToBroker('{ "value" :' + str(20) +' }'))
+response2 = event.map(lambda x: replier.SemistructuredReplyToBroker("20", '{"value" : %%TOREPLACE%% }'))
 response3 = event.map(lambda x : replier.ReplyToBroker("20"))
 event.pprint()
-#response.pprint()
-#response2.pprint()
+response.pprint()
+response2.pprint()
 response3.pprint()