Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- import requests
- import datetime
- import pickle
- import json
- import time
- import mysql.connector as connector
- db_obj = connector.connect(user='root',password='root',host='127.0.0.1',database='varun')
- adsb_insert = "insert into adsb values(%s,%s,%s,%s,%s,%s,%s,DEFAULT)"
- cur = db_obj.cursor()
- currentDT = datetime.datetime.now()
- print "Started at : "+str(currentDT)
- print "Press CTRL+C to stop"
- count=0
- while(1):
- a=requests.get('http://192.168.137.113:8080/data.json')
- ob=a.json()
- print ob
- if(len(ob)==0):
- print "Empty record"
- time.sleep(2)
- continue
- for i in ob:
- flight=i['flight']
- flight=str(i['flight'])
- track=long(i['track'])
- lon=float(i['lon'])
- altitude=int(i['altitude'])
- hexa=str(i['hex'])
- speed = int(i['speed'])
- lat = float(i['lat'])
- cur.execute(adsb_insert,(flight,track,lon,altitude,hexa,lat,speed))
- db_obj.commit()
- print "inserted "
- count+=1
- time.sleep(.5)
- endDT = datetime.datetime.now()
- print "Ended at : "+str(endDT)
- print "recieved "+count+" entries in "+(endDT-currentDT).total_seconds()
Add Comment
Please, Sign In to add comment