rasp

README.md

@@ -2,7 +2,7 @@
 
 https://opensky-network.org/apidoc/python.html
 
-pip install -e "/opensky-api-master/python"
+pip install -e "./opensky-api-master/python"
 
 Idées: 
 - Position des avions en temps réel avec visualisation -> plutôt trajectoire ? point courant + point précédent (+ gros buffer)

horsing_around.py

 from time import sleep
-from pyradios import RadioBrowser
 
-rb = RadioBrowser()
-s1 = rb.search()
-sleep(10)
-s2 = rb.search()
-print(len(s1))
-print(len(s2))
+from opensky_api import OpenSkyApi
 
+api = OpenSkyApi()
+states = api.get_states()
+sleep(10.1)
+states2 = api.get_states()
+
+print(len(states.states))
+print(len(states2.states))
+
+ids = set()
+ids2 = set()
+for s in states.states:
+    ids.add(s.icao24)
+for s in states2.states:
+    ids2.add(s.icao24)
+print(len(ids-ids2) + len(ids2-ids))
+
+'''for s in states.states:
+    print("(%r, %r, %r, %r, %r)" % (s.longitude, s.latitude, s.baro_altitude, s.geo_altitude, s.velocity))
+for s in states2.states:
+    print("(%r, %r, %r, %r, %r)" % (s.longitude, s.latitude, s.baro_altitude, s.geo_altitude, s.velocity))
+'''
 if __name__ == '__main__':
-    for radio1 in s1:
-        radio2 = None
-        for radio in s2:
-            if radio['stationuuid'] == radio1['stationuuid']:
-                radio2 = radio
-                break
-        if radio1 != radio2:
-            print(radio1)
-            print(radio2)
-            '''for key in radio1.keys():
-                if radio1[key] != radio2[key]:
-                    print(key)
-                    print(s1[key])
-                    print(s2[key])
-                    print()'''
+    pass

kafka_launch.sh

+zookeeper-server-start.sh /opt/kafka/config/zookeeper.properties
+kafka-server-start.sh /opt/kafka/config/server.properties
+kafka-server-start.sh /opt/kafka/config/server1.properties

kafka_stop.sh

+kafka-server-stop.sh /opt/kafka/config/server.properties
+kafka-server-stop.sh /opt/kafka/config/server1.properties
+zookeeper-server-stop.sh /opt/kafka/config/zookeeper.properties
\ No newline at end of file

planes.py

-import requests
+from time import sleep
+import json
 
-r = requests.get("{0:s}{1:s}".format(self._api_url, url_post), auth=self._auth, params=params, timeout=15.00)
\ No newline at end of file
+from opensky_api import OpenSkyApi
+from kafka import KafkaProducer
+
+producer = KafkaProducer(bootstrap_servers="pi-node07:9092")
+
+api = OpenSkyApi()
+while 1:
+    states = api.get_states()
+    producer.send("air-traffic", json.dumps(states).encode())
+    print("{} Produced {} air traffic records".format(time.time(), len(states)))
+    sleep(10.01)
+
+
+if __name__ == '__main__':
+    pass

useful-sh.sh

+# create topic
+kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 2 --partitions 10 --topic air-traffic
+
+# delete topics
+delete.topic.enable=true
+kafka-topics.sh --zookeeper localhost:2181 --delete --topic <topic_name>
+
+# reformat
+rm -rf /tmp/zookeeper/
+ls /opt/kafka-data/
+sudo rm -rf /opt/kafka-data/
+sudo mkdir /opt/kafka-data/
+sudo chown -R pi:pi /opt/kafka-data
\ No newline at end of file