| 12345678910111213141516171819202122232425 |
- from inputs.snap7_connect import SiemensCPU
- from inputs.balluff_html import Balluff
- from database.influxdb import Point, Database
- from datetime import datetime
- import time
- db = Database()
- cpu = SiemensCPU()
- cpu.connect("10.0.10.1", 0, 0)
- cpu.get_connected()
- #print(cpu.synchronize())
- balluff = Balluff()
- while True:
- values = balluff.read()
- points = []
- for meas in values:
- print(meas)
- p = Point("24v").time(meas.timestamp).tag("source", meas.source).tag("channel", meas.channel).field("current", meas.current)
- points.append(p)
- db.write(points)
|
