changes in server_lifecycle

server_lifecycle.py

@@ -16,15 +16,16 @@
 # print("i am here")
 
 # get dynamic ip
-ip1 = "20.219.73.70"
-ip2 = "20.219.72.194"
+ip1 = "52.172.88.109"
+ip2 = "52.172.89.34"
+ip3 = "52.172.89.22"
 
 def send_message(topic_name, message):
     producer = KafkaProducer(bootstrap_servers=['52.140.57.176:9092'], value_serializer=lambda v: json.dumps(v).encode('utf-8'))
     producer.send(topic_name, message)
 
 no_of_services = len(services)
-for i in range(0, len(services), 2):
+for i in range(0, len(services)-1, 3):
   data1 = {
   "command":"START",
   "service":services[i]
@@ -33,10 +34,24 @@ def send_message(topic_name, message):
   "command":"START",
   "service":services[i+1]
   }
+  data3 = {
+  "command":"START",
+  "service":services[i+2]
+  }
   send_message("service_{}".format(ip1), data1)
   send_message("service_{}".format(ip2), data2)
+  send_message("service_{}".format(ip3), data3)
   print("service_{}".format(ip1))
   print("service_{}".format(ip2))
+  print("service_{}".format(ip3))
   time.sleep(2)
 
+data3 = {
+"command":"START",
+"service":services[len(services)-1]
+}
+send_message("service_{}".format(ip1), data3)
+time.sleep(2)
+
+