The Industrial Raspberry Pi Forum

Code: Select all

##################################################################################################
# This Example save the data of sensor values into RevPi using Mysql database.
# The sensor data is get/generated using the modsim  simulator.
# Author-Anil Ramesh Sarode TO@ULEPL
###################################################################################################


import time
import datetime
import mysql.connector
from mysql.connector import Error
from mysql.connector import errorcode
import revpimodio2                         # To read the pins of revPi

revpi = revpimodio2.RevPiModIO(autorefresh=True) # Instance to access to the IOs of the RevPiimport revpimodio2

connection = mysql.connector.connect(host='localhost',
                                     database='sensor',
                                     user='root',
                                     password='UL@123')

ti = time.gmtime()


def dateTime(): #get UNIX time
        secs = time.asctime(ti)
#        secs = secs*1000
        return secs

def tempRead(): #read temperature, return float with 3 decimal places
        degrees = float('{0:.3f}'.format(revpi.io.Input_Word_1.value))
        return degrees

def pressRead():#read pressure, return float with 3 decimal places
        pascals = float('{0:.3f}'.format(revpi.io.Input_Word_2.value/100))
        return pascals

def humidityRead(): #read humidity, return float with 3 decimal places
        humidity = float('{0:.3f}'.format(revpi.io.Input_Word_3.value))
        return humidity


secs = dateTime()
temperature = tempRead()
pressure = pressRead()
humidity = humidityRead()
#ID_number=1


try:
        mySql_insert_query= """INSERT INTO Sensor_Modbus_TCP_Data (datetime,temperature,pressure,humidity) VALUES (%s,%s,%s,%s)"""
        args =(secs, temperature, pressure, humidity)

        cursor = connection.cursor()
#       result = cursor.execute(mySql_Create_Table_Query)
#       print("Sensor_ModbusTCP_Data Table created successfully ")

        cursor.execute(mySql_insert_query,args)
        connection.commit()
        print(cursor.rowcount, "Record inserted successfully into Sensor_ModbusTCP_Data  table")
        cursor.close()

except mysql.connector.Error as error:
#    print("Failed to create table in MySQL: {}".format(error))
     print("Failed to insert record into Sensor_ModbusTCP_Data  table {}".format(error))

finally:
    if (connection.is_connected()):
        cursor.close()
        connection.close()
        print("MySQL connection is closed")

print (secs)
print (temperature)
print (pressure)
print (humidity)