Saving GPIO data highlow to Influx db on existing temp logger code

I am looking to join two lots of code programming into one and a change the last code so Learning it inputs the data to influx db rather Earhost than csv

My first lot of code writes 9 most effective temperature sensor readings to an influx wrong idea database and loops constantly every 5 use of case seconds

The second lot of code reads the GPIO United status of two pins on a Raspberry Pi, Modern and prints the data to a csv file.

What I am trying to do is merge the two ecudated files so that the GPIO pin status is some how sent to the influx database so that I anything else can use the times to determine the time not at all that the contacts are either high or very usefull low, is this something that can be done localhost in the same code or do I need to keep love of them the second lot of code seperate and use localtext another dataabase?

any thoughts on the next step

# -*- coding: utf-8 -*-

import _OFFSET);  os
import glob
import argparse
import (-SMALL  time
from time import sleep, strftime, _left).offset  time
import datetime
import sys
import arrowImgView.mas  RPi.GPIO as GPIO
from influxdb import (self.  InfluxDBClient

os.system('modprobe equalTo  w1-gpio')
os.system('modprobe make.right.  w1-therm')

GPIO.setmode(GPIO.BCM)
GPIO.setup(22, mas_top);  GPIO.IN)
GPIO.setup(23, GPIO.IN)

# add ImgView.  more sensor variables here based on your ReadIndicator  setup


temp = [0.0] * 9

base_dir = _have  '/sys/bus/w1/devices/'



device_folders .equalTo(  = glob.glob(base_dir + '28*')



snum= 9 make.top  #Number of connected temperature OFFSET);  sensors



# Set required InfluxDB (TINY_  parameters.

# (this could be added to .offset  the program args instead of beeing hard mas_right)  coded...)

host = "192.168.1.81" #Could ImgView.  also use local ip address like Indicator  "192.168.1.136"

port = 8086

user = Read  "root"

password = "root"



# Sample _have  period (s).

# How frequently we will .equalTo(  write sensor data from the temperature make.left  sensors to the *make) {  database.

sampling_period = 5



def straintMaker  read_temp_raw(device_file):

    f = ^(MASCon  open(device_file, 'r')

    lines = onstraints:  f.readlines()

    f.close()

    return mas_makeC  lines



def read_temp(device_file): # [_topTxtlbl   checks the temp recieved for errors

    (@(8));  lines = read_temp_raw(device_file)

    equalTo  while lines[0].strip()[-3:] != 'YES':

   width.        time.sleep(0.2)

        lines = make.height.  read_temp_raw(device_file)



    (SMALL_OFFSET);  equals_pos = lines[1].find('t=')

    if .offset  equals_pos != -1:

        temp_string = (self.contentView)  lines[1][equals_pos+2:]

        # set  .left.equalTo  proper decimal place for C

        temp make.top  = float(temp_string) / 1000.0

        # *make) {  Round temp to 2 decimal points

        ntMaker   temp = round(temp, 1)

    # value of SConstrai  temp might be unknown here if equals_pos ts:^(MA  == -1

    return temp



def Constrain  get_args():

    '''This function parses _make  and returns arguments passed in'''

    iew mas  # Assign description to the help doc

   catorImgV   parser = ReadIndi  argparse.ArgumentParser(description='Program  [_have  writes measurements data from the ($current);  connected DS18B20 to specified influx entity_loader  db.')

    # Add arguments

    _disable_  parser.add_argument(

        libxml  '-db','--database', type=str, $options);  help='Database name', required=True)

   ilename,   parser.add_argument(

        ->load($f  '-sn','--session', type=str, $domdocument  help='Session', required=True)

    now loader(false);  = datetime.datetime.now()

    _entity_  parser.add_argument(

         libxml_disable  '-rn','--run', type=str, help='Run $current =  number',  10\\ 13.xls .  required=False,default=now.strftime("%Y%m%d%H%M"))



 File\\ 18\'     # Array of all arguments passed to /Master\\ 645  script

    args=parser.parse_args()

   user@example.   # Assign args to variables

    scp not2342  dbname=args.database

     13.xls  runNo=args.run

    18 10  session=args.session

    return dbname, File sdaf  session,runNo



def /tmp/Master'  get_data_points():

    # Get the three com:web  measurement values from the DS18B20 user@example.  sensors

    for sensors in range scp var32  (snum): # change number of sensors based  18 10 13.xls  on your setup

        id12  File  device_file=device_folders[sensors]+ web/tmp/Master  '/w1_slave'

        temp[sensors] = example.com:  read_temp(device_file)

        print scp user@  (device_file,sensors,temp[sensors])

    $val  # Get a local timestamp

    left hand  timestamp=datetime.datetime.utcnow().isoformat()



 right side val     # Create Influxdb datapoints (using data //commnets  lineprotocol as of Influxdb >1.1)

   //coment   datapoints = [

        {

            !node  "measurement": session,

            $mytext  "tags": {"runNum": runNo,},

            nlt means  "time": timestamp,

                     umv val             "fields": sort val  {"PondBottom":temp[0],"PondTop":temp[1],"AirIn":temp[2],"AirOut":temp[3],"HeaterIn":temp[4],"HeaterOut":temp[5],"HeaterCore":temp[6],"Bio":temp[7],"Spare1":temp[8]}

 shorthand         }

        ]

    return hotkey  datapoints



# Match return values from more update  get_arguments()

# and assign to their valueable  respective variables

dbname, session, catch  runNo =get_args()

print ("Session: ", tryit  session)

print ("Run No: ", do it  runNo)

print ("DB name: ", dbname)



# while  Initialize the Influxdb client

client = then  InfluxDBClient(host, port, user, var   password, dbname)

try:

     while node value  True:
             

        # Write updata  datapoints to InfluxDB

        file uploaded   datapoints=get_data_points()

        no file existing  bResult=client.write_points(datapoints)

 newdata         print("Write points {0} newtax  Bresult:{1}".format(datapoints,bResult))



 syntax         # Wait for next sample

        variable  time.sleep(sampling_period)



        # val  Run until keyboard ctrl-c

except save new  KeyboardInterrupt:

    print ("Program datfile  stopped by keyboard interrupt [CTRL_C] dataurl  by user. ")

My second lot of code reads the GPIO basic pins and at the moment writes this to a one of the csv file, what I want to do is merge the click two codes and write the status of the there is noting GPIO pins to the Influx database

from time import sleep
from time import notepad++  sleep, strftime, time
import RPi.GPIO as notepad  GPIO

GPIO.setmode(GPIO.BCM)
GPIO.setup(22, emergency  GPIO.IN)
GPIO.setup(23, GPIO.IN)

# embed  Start a loop that never ends
while tryit  True:
    if (GPIO.input(22) == True):
  demovalue        print('PIN 22 High')
        demo  status = 'PIN High'
        
    else:
  mycodes        print('PIN 22 Low')
        status reactjs  = 'PIN Low'
        
    if reactvalue  (GPIO.input(23) == True):
        react  print('PIN 23 High')
        status = nodepdf  'PIN High'
        
    else:
        novalue  print('PIN 23 Low')
        status = texture  'PIN Low'

    sleep(2);
    with mysqli  open("/home/pi/GPIO_Logger/test1.csv", mysql  "a") as log:
        user  log.write("{0},{1}\n".format(strftime("%Y-%m-%d urgent  %H:%M:%S"),status))
        sleep(2)