Implement error handling for TooManyRequests to solar forecast

Author: felixschndr

Diff for: README.md

@@ -215,8 +215,9 @@ It saves the following data:
 
 - Create bucket: `influx bucket create -org default -token <token> --name default`
 - Delete bucket: `influx bucket delete -org default -token <token> --name default`
-- Retrieve all solar forecast values: `influx query -org default -token <token> 'from(bucket: "default")
-|> range(start: -1d)
+- Retrieve all solar forecast values: `influx query -org default -token <token> 'import "experimental"
+from(bucket: "default")
+|> range(start: 0, stop: experimental.addDuration(d: 2d, to: now()))
 |> filter(fn: (r) => r._measurement == "sun_forecast")
 |> pivot(rowKey:["_time"], columnKey:["_field"], valueColumn:"_value")'`
 - Retrieve all energy prices: `influx query -org default -token <token> 'import "experimental"

Diff for: source/inverter_charge_controller.py

@@ -2,6 +2,7 @@
 from datetime import datetime, timedelta
 
 import pause
+import requests.exceptions
 from abscence_handler import AbsenceHandler
 from aiohttp import ClientError
 from energy_amount import EnergyAmount, EnergyRate
@@ -58,7 +59,10 @@ def start(self) -> None:
                     time_to_sleep_to = now.replace(hour=14, minute=0, second=0, microsecond=0)
                     if now > time_to_sleep_to:
                         time_to_sleep_to += timedelta(days=1)
-                    self.log.info(f"The price minimum has to re-checked --> Waiting until {time_to_sleep_to}...")
+                    self.log.info(
+                        f"The price minimum {next_price_minimum} has to re-checked "
+                        + f"--> Waiting until {time_to_sleep_to}..."
+                    )
                     pause.until(time_to_sleep_to)
                     self.log.info("Waking up since the the price minimum has to re-checked")
                     next_price_minimum = self.tibber_api_handler.get_next_price_minimum(True)
@@ -110,12 +114,19 @@ def _do_iteration(self, current_energy_rate: float) -> EnergyRate:
                 "The price minimum has to be re-checked since it is at the end of a day and the price rates for tomorrow are unavailable"
             )
 
-        expected_power_harvested_till_next_minimum = self.sun_forecast_handler.get_solar_output_in_timeframe(
-            timestamp_now, next_price_minimum.timestamp
-        )
-        self.log.info(
-            f"The expected energy harvested by the sun till the next price minimum is {expected_power_harvested_till_next_minimum}"
-        )
+        try:
+            expected_power_harvested_till_next_minimum = self.sun_forecast_handler.get_solar_output_in_timeframe(
+                timestamp_now, next_price_minimum.timestamp
+            )
+            self.log.info(
+                f"The expected energy harvested by the sun till the next price minimum is {expected_power_harvested_till_next_minimum}"
+            )
+        except requests.exceptions.HTTPError as e:
+            if e.response.status_code != 429:
+                raise e
+
+            self.log.warning("Too many requests to the solar forecast API, using the debug solar output instead")
+            expected_power_harvested_till_next_minimum = self.sun_forecast_handler.get_debug_solar_output()
 
         if self.absence_handler.check_for_current_absence():
             self.log.info(

Diff for: source/sun_forecast_handler.py

@@ -42,14 +42,14 @@ def retrieve_solar_forecast_data(self, rooftop_id: str) -> list[dict]:
     def retrieve_historic_data(self, rooftop_id: str) -> list[dict]:
         return self._retrieve_data_from_api(rooftop_id, "estimated_actuals")
 
-    def _get_debug_solar_output(self) -> EnergyAmount:
+    def get_debug_solar_output(self) -> EnergyAmount:
         """
-        Returns a sample debug value for solar energy output.
+        Returns a sample debug value for solar energy output. This value is also used where the API returns a 429
+        (Too Many Requests) error.
 
         Returns:
             EnergyAmount: A sample energy amount of 10,000 watt-hours.
         """
-        # We use a sample value for debugging the code since the API offers very limited call per day
         self.log.debug("Getting debug estimated solar output of today")
         return EnergyAmount(watt_hours=10000)