thingspeak_api.py

#!/usr/bin/env python3
import requests, time, os
from dotenv import load_dotenv
from read_env import read_environment
from openweather import get_from_ow

load_dotenv()

THINGSPEAK_WRITE_API_KEY = os.getenv('RPI_API_KEY')
OWTS_API_KEY= os.getenv('OWTS_API_KEY')
THINGSPEAK_CHANNEL_URL = "https://api.thingspeak.com/update"
THINGSPEAK_PUBLISH_PERIOD = 3600

def send_to_thingspeak(temperature, humidity):
    payload = {
        'api_key': THINGSPEAK_WRITE_API_KEY,
        'field1': temperature,
        'field2': humidity
    }
  
    response = requests.get(THINGSPEAK_CHANNEL_URL, params=payload)

    if response.status_code == 200:
        print("RPI Data sent to ThingSpeak.")
    else:
        print(f"Failed to send data. Status code: {response.status_code}")

def ow_to_thingspeak(owTemp, owHumidity):
    payload = {
        'api_key': OWTS_API_KEY,
        'field1': owTemp,
        'field2': owHumidity
    }
  
    response = requests.get(THINGSPEAK_CHANNEL_URL, params=payload)

    if response.status_code == 200:
        print("OW Data sent to ThingSpeak.")
    else:
        print(f"Failed to send data. Status code: {response.status_code}")
   

def main():
    next_pub = time.monotonic()

    while True:
        now = time.monotonic()
        if now >= next_pub:
            env = read_environment()
            ow = get_from_ow()
            temperature = env["temperature"]
            humidity = env["humidity"]
            owTemp = ow["owTemp"]
            owHumidity = ow["owHumidity"]

            send_to_thingspeak(temperature, humidity)
            ow_to_thingspeak(owTemp, owHumidity)
            next_pub = now + THINGSPEAK_PUBLISH_PERIOD

        time.sleep(0.1)

if __name__ == "__main__":
    main()