标签：weight thread get Python value MQTT EMQ total data
Python获取以MQTT协议广播在EMQ服务器已知主题中的数据并写入MySQL数据库中
步骤
这个是我用来看EMQ服务器里面数据的工具，MQTTX，挺好用的哦
首先，我们需要这些库，下载起来也很简单，直接百度安装即可，安装好之后import进来
以主题“weight_pub”为例
这个函数表示正常连接到了EMQ服务器的weight_pub主题，并且会进行回显告诉用户成功连上服务器
接下来在on_message_weight(client, userdata, msg) 函数中处理我们获得到的数据
至此数据获取完成，接下来进行数据库操作
这个函数是为了连接上数据库的
最后在我们的main函数里面开线程获取数据之后处理数据
总代码
#*****代表用户自己的数据
total_data = {'WriteEnable':0, 'weight': 0.00, 'diastolicPressure': 0,
'heartRate': 0, 'systolicPressure':0,
'height':0.00, 'bloodOxygen':0.00, 'BMI':0.00,
'idealWeight':0.00, 'temperature':0.00,'id':1000}
def set_value(name, value):
total_data[name] = value
def get_value(name, defValue=None):
try:
return total_data[name]
except KeyError:
return defValue
#获取体重
def GetWeight(str):
var = ''
cnt = 0
for char in str:
cnt = cnt + 1
if char >= '0' and char <= '9' or char == '.':
var += char
return float(var)
def on_connect_weight(client, userdata, flags, rc):
print("Connected with weight result code: " + str(rc))
def on_message_weight(client, userdata, msg):
var = str(msg.payload)
if(get_value('WriteEnable') == 1):
set_value('weight',(GetWeight(var)))
if(get_value('weight') > 10):
total_data['weight'] -= 2.75
# print ( 'wei :%.2f' % total_data['weight'] ,end=':')
def MQTTWeight():
# config._init()
client_weight = mqtt.Client()
client_weight.on_connect = on_connect_weight
client_weight.on_message = on_message_weight
client_weight.connect('**.**.***.***',****, 600) # 600为keepalive的时间间隔
client_weight.subscribe('weight_pub', qos=0)
client_weight.loop_forever() # 保持连接
def get_conn():
conn = pymysql.connect(host='*****', port=*****, user='*****', passwd='*****', db='*****')
return conn
def updateHandPart():
if(get_value('heartRate') > 0):
conn = get_conn()
cur = conn.cursor()
sql = 'UPDATE bodyhealthmonitor SET heartRate=%s WHERE id = %s';
args = (get_value('heartRate'), total_data['id'])
result = cur.execute(sql,args)
total_data['heartRate'] = 0
# print(result,end=';')
sql = 'UPDATE bodyhealthmonitor SET diastolicPressure=%s WHERE id = %s';
args = (get_value('diastolicPressure'), total_data['id'])
result = cur.execute(sql,args)
total_data['diastolicPressure'] = 0
# print(result,end=';')
sql = 'UPDATE bodyhealthmonitor SET systolicPressure=%s WHERE id = %s';
args = (get_value('systolicPressure'), total_data['id'])
total_data['systolicPressure'] = 0
result = cur.execute(sql,args)
# print(result)
conn.commit()
cur.close()
conn.close()
if __name__ == '__main__':
try:
thread_weight = threading.Thread(target=MQTTWeight)
thread_weight.setDaemon(True)
thread_weight.start()
thread_height = threading.Thread(target=MQTTHeight)
thread_height.setDaemon(True)
thread_height.start()
thread_blood = threading.Thread(target=MQTTBoold)
thread_blood.setDaemon(True)
thread_blood.start()
var = 1
while(var == 1):
time.sleep(1)#延时1s查看数据
if(get_value('WriteEnable') == 1):
update()
total_data['WriteEnable'] = 0
else:
updateHandPart()
except KeyboardInterrupt:
stop_thread(thread_weight)
stop_thread(thread_height)
stop_thread(thread_blood)
print('end')
标签：weight,thread,get,Python,value,MQTT,EMQ,total,data 来源： https://blog.csdn.net/weixin_43454320/article/details/110433815
本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享； 2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关； 3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关； 4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除； 5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。