将传感器监测到的数据通过树莓派传递给PC,使用树莓派作为客户端,用socket向服务器端(PC)发送数据,通过pymysql将接收的数据插入本地数据库。
硬件准备:
树莓派4B/网线
因为是局域网通信,所以网线要连PC或路由器。如果要通过无线通信,可以搭建一个云服务器,通过调用云服务器实现。
软件
运行程序时,先运行服务端,再运行客户端
服务端(PC)

#!/bin/python
#server.py
import pymysql  
import socket
import time

HOST = '192.168.137.1'
PORT = 8888
ADDR = (HOST, PORT)

mySocket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
mySocket.bind(ADDR)
mySocket.listen(4)

# 打开数据库连接
db = pymysql.connect(
	host = 'localhost'
	port = 3306
	passwd = '123456'
	db = 'skdb'
	charset = 'utf8'
)
cursor = db.cursor()
sqltime = time.strftime('%Y-%m-%d %H:%M:%S', time.localtime(time.time()))

while True:
	conn, addr = mySocket.accept()  #接收客户端连接
	print('IP:%s, Port:%s', addr[0], addr[1])
	while True:
		msg = conn.recv(1024)  # 读消息
		print(msg.decode('utf-8'))  #数据解码
		sql = "INSERT INTO MAGNETISM(MFLAG) VALUES ('%s')" % (msg.decode('utf-8'))
		# sql = "INSERT INTO MAGNETISM(MTIME, MFLAG) VALUES ('%s, %s)" % (sqltime, msg.decode('utf-8'))

		try:
			cursor.execute(sql)  #执行sql语句
			db.commit()  # 提交到数据库执行
		except:
			db.rollback()

		time.sleep(10)

		if msg == "over":
			conn.close()
			mySocket.close()
			db.close()
			exit()

客户端(树莓派)

# client.py
import socket
import time

mySocket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
HOST = 192.168.137.1'
PORT = 8888

try:
	mySocket.connect((HOST, PORT))
except:
	print('connect failed')

while True:
	msg = '9'
	mySocket.send(msg.encode('utf-8'))
	
	time.sleep(10)
	if msg == "over":
		mySocket.close()
		exit()

功能:每隔10s,客户端(树莓派)向服务端(PC)发送模拟数据9,服务端接收到后,将其存入mysql数据库中。

Logo

CSDN联合极客时间,共同打造面向开发者的精品内容学习社区,助力成长!

更多推荐