WIP from mac

Author: Ogban Ugot

latcam

@@ -0,0 +1,10 @@
+210.0, 300.0
+400.0, 600.0
+104.0, 324.0
+204.0, 841.0
+173.0, 526.0
+227.0, 362.0
+119.0, 606.0
+914.0, 423.0
+634.0, 601.0
+743.0, 922.0

notes.txt

@@ -0,0 +1 @@
+python3 producer.py 192.168.0.193:9092 leftarm13

producer.py

@@ -2,18 +2,40 @@
 import numpy as np
 import json
 import sys
+import time
 
 def send_signal():
     print(sys.argv[1])
     print(sys.argv[2])
     producer = KafkaProducer(bootstrap_servers=sys.argv[1])
-    arr = np.random.rand(800)
-    a = arr.tolist() 
-    json_object = json.dumps(a) 
-    # print(json_object)
-    res = producer.send(sys.argv[2], bytes(json_object, 'utf-8'))
-    print(res)
-    print("sucess")
+    ess_list = []
+    with open(sys.argv[3]) as f:
+        lines = [line.rstrip('\n') for line in f]
+    for line in lines:
+        ess = []
+        values = line.split(',')
+        ess.append(float(values[0]))
+        ess.append(float(values[1]))
+        ess_list.append(ess)
+
+    for ess in ess_list: 
+        json_state = json.dumps(ess)
+        data = {
+            "valence":None,
+            "score": None,
+            "state": json_state
+        } 
+        print(json_state)
+        json_object = json.dumps(data).encode("utf-8")
+        res = producer.send(sys.argv[2], json_object)
+        time.sleep(1)
 
 if __name__ == '__main__':
-    send_signal()
+    send_signal()
+
+
+
+
+
+
+    

pub.sh

@@ -0,0 +1,7 @@
+python3 producer.py 192.168.0.193:9092 wheel1 wheel1 &
+
+python3 producer.py 192.168.0.193:9092 wheel2 wheel2 &
+
+python3 producer.py 192.168.0.193:9092 lateral_camera latcam &
+
+wait

wheel1

@@ -0,0 +1,10 @@
+0.212, 0.65
+0.121, 0.3242
+0.4245, 0.89
+0.55, 0.566
+0.775, 0.67
+0.99, 0.39
+0.423, 0.4298
+0.11, 0.87
+0.893, 0.38
+0.3294, 0.940

wheel2

@@ -0,0 +1,10 @@
+9.320, 2.1920
+10.23, 11.602
+90.42, 32.432
+1.392, 3.923
+100.33, 20.2
+129.12, 39.2
+9.312, 8.9
+2.312, 3.18
+49.31, 49.21
+17.42, 16.66