From 771bc4c1b027238437ccb43cb3cfd6d716acc538 Mon Sep 17 00:00:00 2001
From: Juan David Vega <jd.vega11@uniandes.edu.co>
Date: Wed, 27 Sep 2017 11:24:46 -0500
Subject: [PATCH] BridgeConsumidorPersistencia finalizado

---
 Experimento1/BridgeKafkaPersistencia.py | 28 +++++++++++++++++++++++++
 1 file changed, 28 insertions(+)
 create mode 100644 Experimento1/BridgeKafkaPersistencia.py

diff --git a/Experimento1/BridgeKafkaPersistencia.py b/Experimento1/BridgeKafkaPersistencia.py
new file mode 100644
index 0000000..ef34277
--- /dev/null
+++ b/Experimento1/BridgeKafkaPersistencia.py
@@ -0,0 +1,28 @@
+import json
+import requests
+from kafka import KafkaConsumer
+ 
+consumer = KafkaConsumer('n1.a1.m1',
+                         group_id='variablesAmbientales',
+                         bootstrap_servers=['localhost:8090'])
+ 
+for message in consumer:
+	json_data = json.loads(message.value.decode('utf-8'))
+	sensetime = json_data['sensetime']
+	value = json_data['variablesAmbientales']
+	ids = value[0]
+	nivelId = ids['nivelId']
+	areaId = ids['areaId']
+	microcontroladorId = ids['microcontroladorId']
+	
+	for i in range(len(value)):
+		url = 'http://localhost:9000/minas/nivel/' + nivelId + '/areas/' + areaId + '/microcontroladores/'+microcontroladorId + '/sensor/'+ (i+1)+'/datos'
+		payload = {
+		'valor': (value[i+1])['data'],
+		'timeStamp':sensetime
+		}
+		
+		response = requests.post(url, data=json.dumps(payload),
+							 headers={'Content-type': 'application/json'})
+		print(message.topic)
+		print("Response Status Code: " + str(response.status_code))
\ No newline at end of file