-
Notifications
You must be signed in to change notification settings - Fork 0
/
Modbus.py
68 lines (59 loc) · 2.19 KB
/
Modbus.py
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
from pyModbusTCP.client import ModbusClient
from datetime import datetime
from struct import *
import sqlite3
import time
# ---------------------------------------------------------------------------#
# Settings
# ---------------------------------------------------------------------------#
read_interval = 5
# ---------------------------------------------------------------------------#
# pH float 0
# Cond float 2 us/cm
# temp float 4 C
# ---------------------------------------------------------------------------#
data_to_read = [
["pH", "float", 0, "", 0.0],
["cond", "float", 2, "us/cm", 0.0],
]
def unpack_float(low_bytes, high_bytes):
my_pack = pack('>HH', low_bytes, high_bytes)
f = unpack('>f', my_pack)
return f[0]
# ---------------------------------------------------------------------------#
# Modbus client init
# ---------------------------------------------------------------------------#
c = ModbusClient()
if not c.host("localhost"):
print("host error")
if not c.port(502):
print("port error")
while True:
if c.is_open():
for data in data_to_read:
regs = c.read_holding_registers(data[2], 2)
if regs:
f = unpack_float(regs[0], regs[1])
data[4] = f
print(data[0] + ": ", round(f, 2))
else:
print("read error")
# write to database
conn = sqlite3.connect('DATA_SOURCE.db')
cursor = conn.cursor()
now = datetime.now()
record_time = now.strftime('%y-%m-%d %H-%M-%S')
data_to_db = [record_time, data_to_read[0][0], data_to_read[0][4], data_to_read[0][3], data_to_read[1][0],
data_to_read[1][4], data_to_read[1][3]]
cursor.execute(
"insert into DATA_STORE (TIME, data_1, value_1, unit_1, data_2, value_2, unit_2) VALUES(?,?,?,?,?,?,?)",
data_to_db)
cursor.execute(
"insert into DATA_SEND (TIME, data_1, value_1, unit_1, data_2, value_2, unit_2) VALUES(?,?,?,?,?,?,?)",
data_to_db)
cursor.close()
conn.commit()
conn.close()
else:
c.open()
time.sleep(read_interval)