Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- def background_thread(args):
- db = MySQLdb.connect(host=myhost,user=myuser,passwd=mypasswd,db=mydb)
- cursor = db.cursor()
- count = 0
- dataList = []
- serialTemp = ""
- length = 0
- lengthTemp = 0
- sV = ""
- tV = ""
- srlV = ""
- while True:
- if args:
- A = dict(args).get('A')
- sV = dict(args).get('s_value')
- tV = dict(args).get('t_value')
- srlV = dict(args).get('value')
- btnV = dict(args).get('btn_value')
- else:
- A = 1
- srlV = 'null'
- btnV = ""
- #print A
- socketio.sleep(1)
- count += 1
- n = "test"#rSer.readline()
- if "Present" in n:
- length = int(re.search(r'\d+', n.split(": ",1)[1]).group())
- if srlV != serialTemp or length != lengthTemp:
- serialTemp = srlV
- lengthTemp = length
- dataDict = {
- "time": count,
- "speed": sV,
- "throttle": tV,
- "dist": length}
- #ser.write(serialTemp)
- if btnV == "start":
- dataList.append(dataDict)
- print dataDict
- if btnV == "stop" and len(dataList)>0:
- btnV = "null"
- output = str(dataList).replace("[","")
- output = output.replace("]","")
- cursor.execute("INSERT INTO movement (data) VALUES (%s)",[output])
- db.commit()
- del dataList[:]
- socketio.emit('my_response',
- {'data': float(A), 'count': count},
- namespace='/test')
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement