Guest User

adsb_db

a guest
Apr 16th, 2018
48
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
Python 1.05 KB | None | 0 0
  1. import requests
  2. import datetime
  3. import pickle
  4. import json
  5. import time
  6. import mysql.connector as connector
  7. db_obj = connector.connect(user='root',password='root',host='127.0.0.1',database='varun')
  8. adsb_insert = "insert into adsb values(%s,%s,%s,%s,%s,%s,%s,DEFAULT)"
  9. cur = db_obj.cursor()
  10. currentDT = datetime.datetime.now()
  11. print "Started at : "+str(currentDT)
  12. print "Press CTRL+C to stop"
  13. count=0
  14. while(1):
  15.     a=requests.get('http://192.168.137.113:8080/data.json')
  16.     ob=a.json()
  17.     print ob
  18.     if(len(ob)==0):
  19.         print "Empty record"
  20.         time.sleep(2)
  21.         continue
  22.     for i in ob:
  23.         flight=i['flight']
  24.         flight=str(i['flight'])
  25.         track=long(i['track'])
  26.         lon=float(i['lon'])
  27.         altitude=int(i['altitude'])
  28.         hexa=str(i['hex'])
  29.         speed = int(i['speed'])
  30.         lat = float(i['lat'])
  31.         cur.execute(adsb_insert,(flight,track,lon,altitude,hexa,lat,speed))
  32.         db_obj.commit()
  33.         print "inserted "
  34.         count+=1
  35.     time.sleep(.5)
  36. endDT = datetime.datetime.now()
  37. print "Ended at : "+str(endDT)
  38. print "recieved "+count+" entries in "+(endDT-currentDT).total_seconds()
Add Comment
Please, Sign In to add comment