Cliente IoT

 Finalmente, es momento de juntar todo lo visto anteriormente en un único código para subir los datos de presión y temperatura del sensor a ThingSpeak. El hardware empleado como cliente IoT es una Raspberry Pi 4B y un sensor BMP 180, mostrados a continuación.

El funcionamiento del código es el siguiente. Al ejecutar, se crea un nuevo canal. Las claves API de lectura y escritura se almacenan, y se emplea la de escritura para enviar los datos al canal cada 15s. Se ha programado una excepción para que al presionar la combinación de teclas Ctrl+C, se detenga el programa y se borre el contenido del canal. 

Se ha optado por un tamaño de letra muy pequeño para que el código entre sin cortar, asi que pido disculpas por la inconveniencia. Aun así, el código del cuerpo del mensaje que crea el canal está dividido.

import time
import signal
import sys
import requests
import urllib.parse
import json
import Adafruit_BMP.BMP085 as BMP085


def handler(sig_num, frame):
    uri = 'https://api.thingspeak.com/channels/'+str(channel_id)+'/feeds'
    cabeceras = {'Host': 'api.thingspeak.com', 'Content-Type': 'application/x-www-form-urlencoded'}
    cuerpo = {'api_key': 'XXXXXXXXXXXXXXXX'}
    cuerpo_coded = urllib.parse.urlencode(cuerpo)
    cabeceras['Content-Length'] = str(len(cuerpo_coded))

    respuesta = requests.delete(uri, headers=cabeceras, data=cuerpo_coded)

    descripcion = respuesta.reason

    print('Borrado: ' + descripcion)
    print('\nSignal handler called with signal ' + str(sig_num))
    print('\nExiting gracefully')
    sys.exit(0)


if __name__ == '__main__':
    signal.signal(signal.SIGINT, handler)
    print('Running. Press CTRL-C to exit.')

########################################################################################

    metodo = 'POST'
    uri = 'https://api.thingspeak.com/channels'
    cabeceras = {'Host': 'api.thingspeak.com', 'Content-Type': 'application/x-www-form-urlencoded'}

    cuerpo = {'api_key': 'XXXXXXXXXXXXXXXX', 'name': 'Datos_Clima', 'field1': 'Temperatura (ºC)',  

    'field2': 'Presion (Pa)'}

    cuerpo_coded = urllib.parse.urlencode(cuerpo)
    cabeceras['Content-Length'] = str(len(cuerpo_coded))

    # print(cuerpo_coded)

    respuesta = requests.post(uri, headers=cabeceras, data=cuerpo_coded)

    estatus = respuesta.status_code
    descripcion = respuesta.reason

    print('Canal creado: ' + descripcion)

    contenido_json = respuesta.content
    diccionario_json = json.loads(contenido_json)  # JSON2diccionario
    channel_id = diccionario_json['id']

    for each in diccionario_json['api_keys']:
        if each['write_flag']:
            write_api_key = each['api_key']

        else:
            read_api_key = each['api_key']


############################################################################################

while True:
    
    sensor=BMP085.BMP085()

    temp='{0:0.2f}ºC'.format(sensor.read_temperature())
    print('Temp = '+temp)

    pres='{0:0.2f} Pa'.format(sensor.read_pressure())
    print('Pressure = '+pres)

    metodo='POST'
    uri='https://api.thingspeak.com/update'
    cabeceras={'Host':'api.thingspeak.com', 'Content-Type':'application/x-www-form-urlencoded'}
    cuerpo={'api_key':write_api_key,'field1':temp, 'field2':pres}
    cuerpo_coded=urllib.parse.urlencode(cuerpo)

    cabeceras['Content-Length']=str(len(cuerpo_coded))

    respuesta=requests.post(uri, headers=cabeceras, data=cuerpo_coded)

    estatus=respuesta.status_code
    descripcion=respuesta.reason

    time.sleep(15)
 

A continuación, se muestra la gráfica de presión mostrada en ThingSpeak tras la ejecución del código.