通过读取串口数据,把数据写入MySQL

  • Post author:
  • Post category:mysql


需要了解更多关注:

https://blog.csdn.net/linbossdeboke

qq交流群:651587317

C语言版本参考:

https://blog.csdn.net/wangqingchuan92/article/details/73497354/

一、库安装

python2:  pip  install serial

python3:  pip3  install pyserial

安装完pip list一下 看是否存在这个库

二、读串口数据

import serial

def getportdata(com=””,B=””,readtimeu=””):

u”’  获取串口数据

:param  com    串口号 -安装好串口驱动后设备管理器查看

:param  B    串口波特率-依据设备型号而定

:param  readtimeu    单次数据读取超时时间   单位(s) 不需要关闭也可去掉这个参数

:return  None

:example getportdata(path,’com17′,115200,1150)

”’

ser = serial.Serial(com, B, timeout=100)

timeu=0

while timeu<readtimeu:

#ss= ser.readline().decode(“ISO-8859-1”)  #python2

ss= ser.readline()  #python3

ss=”{}{}{}”.format(str(timeu),”-“,ss.lstrip())

print  ss     #打印串口输出

timeu=timeu+1

ser.close()  #关闭串口

三、python 操作数据库

import MySQLdb  #定义引用数据库的驱动文件  需要pip install pymysql

def setmysql_database(db,data):

u”’  python 操作数据库

:param  db 数据库

:param  data 插入的字符串

:return  None

:example setmysql_database(db,data)

”’

conn=MySQLdb.connect(host=’192.168.2.1′,user=’root’,passwd=’root’,db=’ma’

#连接数据库  host:数据库ip    user:用户名    passwd:密码     db:数据库

cursor=conn.cursor()

sql= “insert into mytable(m_message) values(%s)”   #数据库语句

pgg = data         #data为要插入的字符串

pga = (pgg)

res = cursor.execute(sql,pga)          #操作数据库

print res  #打印操作数据库返回

四、读串口插入数据库

import MySQLdb    #定义引用数据库的驱动文件

import serial  #串口模块

import time

ser = serial.Serial(‘com8’, 115200, timeout=65)  #读串口

while True:

data = ser.readline()

print data    #输出读到的数据

conn=MySQLdb.connect(host=’192.168.2.1′,user=’root’,passwd=’root’,db=’ma’   #连接数据库

cursor=conn.cursor()

sql= “insert into data(m_message) values(%s)”   #插入数据库sql语句

pga = (data) #串口数据

res = cursor.execute(sql,pga)   #执行插入操作

print res    #打印返回

print pgg

print (time.strftime(“%H:%M:%S”))   #打印当前时间



版权声明:本文为linbossdeboke原创文章,遵循 CC 4.0 BY-SA 版权协议,转载请附上原文出处链接和本声明。