目录
步骤
modsim32软件配置
代码实现
步骤
-
安装必要的库：确保安装了
pymodbus和pymysql。 -
配置Modbus连接：设置Modbus从站的IP地址、端口（对于TCP）或串行通信参数（对于RTU）。
-
连接MySQL数据库：设置数据库的连接参数，如主机名、用户名、密码和数据库名。
-
读取Modbus寄存器：使用
pymodbus客户端从Modbus从站读取寄存器数据。 -
写入MySQL数据库：将读取的数据插入到MySQL数据库的表中。
-
错误处理：添加错误处理逻辑以处理连接失败、读取错误等。
-
资源管理：确保在结束时关闭Modbus客户端和MySQL连接。
modsim32软件配置
，
Navicat for MySQL
Navicat for MySQL 是一套管理和开发 MySQL 的理想解决方案，Navicat 为数据库管理、开发和维护提供了直观而强大的图形界面，给 MySQL 新手以及专业人士提供了一组全面的工具。Navicat for MySQL 主要功能包括 SQL 创建工具或编辑器、数据模型工具、数据传输、导入或导出、数据或结构同步、报表等
代码实现
from pymodbus.client import ModbusTcpClient as ModbusClient
import pymysql
import time# 定义Modbus TCP从站地址和端口号
address = '127.0.0.1'
port = 502# 定义MySQL数据库连接参数
host = "localhost"
user = "root"
password = "root"
database = "test"# 建立Modbus TCP连接和MySQL数据库连接
client = ModbusClient(address, port=port)
client.connect()
cnx = pymysql.connect(user='root', password='101900', host='localhost', database='pyqt')
cursor = cnx.cursor()
# 创建表格
cursor.execute("DROP TABLE IF EXISTS sensor_data") # 如果存在表则重新创建
createTab = """CREATE TABLE sensor_data( # 创建表id INTEGER PRIMARY KEY AUTO_INCREMENT,TIME CHAR(50),temperature CHAR(50),voltage CHAR(50),current CHAR(50),resistance CHAR(50) )"""
cursor.execute(createTab) # 执行数据库语句while True:localtime = time.asctime(time.localtime(time.time())) # time包操作，打印本地时间local_time = time.strftime("%Y-%m-%d %H:%M:%S", time.localtime()) # 规整本地时间的格式# 读取Modbus TCP从站寄存器中的数据result = client.read_holding_registers(address=0, count=4, unit=1)data = {'TIME': local_time,'temperature': result.registers[0],'voltage': result.registers[1],'current': result.registers[2],'resistance': result.registers[3]}# 将数据写入到MySQL数据库中add_data = ("INSERT INTO sensor_data ""(TIME,temperature, voltage, current, resistance) ""VALUES (%(TIME)s,%(temperature)s, %(voltage)s, %(current)s, %(resistance)s)")cursor.execute(add_data, data)cnx.commit()# 模拟每隔1秒钟读取一次数据time.sleep(1)# 关闭Modbus TCP连接和MySQL数据库连接
client.close()
cursor.close()
cnx.close()
