In [16]:
cd /home/iot/repos/SolarDataRESTfulAPI
In [7]:
ls
In [8]:
import pandas as pd
import InfluxDBInterface
import time
from ElasticsearchInterface import ESinterface
import sys
import argparse
In [11]:
sys.path.append("/home/iot/repos/SolarDataRESTfulAPI")
In [12]:
sys.path
Out[12]:
In [17]:
DataLink = InfluxDBInterface.InfluxDBInterface("influxInterfaceCredentials2.json")
In [23]:
DataBase = DataLink.databases["SolarProductionSites"]
In [22]:
DataLink.listdataseries()
Out[22]:
In [29]:
DataBase.GetLastValue("2a31fb24-347b-4924-ab89-5c434771a2ae",[u'Power'])
Out[29]:
In [27]:
DataBase.GetProperties("2a31fb24-347b-4924-ab89-5c434771a2ae")
Out[27]:
In [30]:
ls
In [31]:
import mosquitto
In [32]:
mqtt=mosquitto.Mosquitto("ProductionProducer")
In [33]:
mqtt.loop_start()
In [ ]: