| 123456789101112131415161718192021222324252627 |
- from inputs.snap7_connect import SiemensCPU
- from database.influxdb import Point, Database
- from datetime import datetime
- import time
- localtz = datetime.now().astimezone().tzinfo
- db = Database()
- cpu = SiemensCPU()
- cpu.connect("10.0.10.1", 0, 0)
- cpu.get_connected()
- print(cpu.synchronize())
- while True:
- values = cpu.read()
- print(values)
- points = []
- for timestamp, value in values:
- date = datetime.fromtimestamp(timestamp, localtz)
- p = Point("24v").time(date).tag("cpu", "siemens").field("current", value)
- points.append(p)
- db.write(points)
- time.sleep(cpu.interval * 0.9)
|
