Expose producer component through the microgrid

Signed-off-by: Daniel Zullo <[email protected]>

Author: daniel-zullo-frequenz

src/frequenz/sdk/microgrid/__init__.py

@@ -79,7 +79,7 @@
 similarly the total CHP production in a site can be streamed through
 [`chp_power`][frequenz.sdk.timeseries.logical_meter.LogicalMeter.chp_power].  And total
 producer power is available through
-[`producer_power`][frequenz.sdk.timeseries.logical_meter.LogicalMeter.producer_power].
+[`producer_power`][frequenz.sdk.timeseries.producer.Producer.power].
 
 As is the case with the other methods, if PV Arrays or CHPs are not available in a
 microgrid, the corresponding methods stream zero values.
@@ -130,6 +130,7 @@
     frequency,
     grid,
     logical_meter,
+    producer,
     voltage,
 )
 
@@ -157,5 +158,6 @@ async def initialize(host: str, port: int, resampler_config: ResamplerConfig) ->
     "frequency",
     "logical_meter",
     "metadata",
+    "producer",
     "voltage",
 ]

src/frequenz/sdk/microgrid/_data_pipeline.py

@@ -49,6 +49,7 @@
     from ..timeseries.consumer import Consumer
     from ..timeseries.ev_charger_pool import EVChargerPool
     from ..timeseries.logical_meter import LogicalMeter
+    from ..timeseries.producer import Producer
 
 
 _REQUEST_RECV_BUFFER_SIZE = 500
@@ -120,6 +121,7 @@ def __init__(
 
         self._logical_meter: LogicalMeter | None = None
         self._consumer: Consumer | None = None
+        self._producer: Producer | None = None
         self._grid: Grid | None = None
         self._ev_charger_pools: dict[frozenset[int], EVChargerPool] = {}
         self._battery_pools: dict[frozenset[int], BatteryPoolReferenceStore] = {}
@@ -188,6 +190,23 @@ def consumer(self) -> Consumer:
             )
         return self._consumer
 
+    def producer(self) -> Producer:
+        """Return the producer instance.
+
+        If a Producer instance doesn't exist, a new one is created and returned.
+
+        Returns:
+            A Producer instance.
+        """
+        from ..timeseries.producer import Producer
+
+        if self._producer is None:
+            self._producer = Producer(
+                channel_registry=self._channel_registry,
+                resampler_subscription_sender=self._resampling_request_sender(),
+            )
+        return self._producer
+
     def ev_charger_pool(
         self,
         ev_charger_ids: set[int] | None = None,
@@ -471,6 +490,11 @@ def consumer() -> Consumer:
     return _get().consumer()
 
 
+def producer() -> Producer:
+    """Return the [`Production`][frequenz.sdk.timeseries.producer.Producer] measuring point."""
+    return _get().producer()
+
+
 def ev_charger_pool(ev_charger_ids: set[int] | None = None) -> EVChargerPool:
     """Return the corresponding EVChargerPool instance for the given ids.