Add LoadManager by AlexanderHa98 · Pull Request #3636 · openWB/core

AlexanderHa98 · 2026-07-07T12:39:46Z

Aufbau

GUI

Eingabe der maximalen Bezugsleistung im Fehlerfall
Eingabe des maximal zulässigen Stroms (Ampere) im Fehlerfall
Auswahl der zu verwendenden Ladepunkte

MQTT-Topic

openWB/set/mqtt/loadmanager/set/{id}/loadmanager

Beispiel-Payload

{
  "max_power": 1000,
  "max_current": [6, 6, 6],
  "timestamp": 1783596593.635847
}

Funktionsweise

Lastmanagement

Der Lastmanager berechnet die verbleibend verfügbare Leistung und den maximal zulässigen Strom.

Dabei erfolgt die Begrenzung in folgender Reihenfolge:

Prüfung der Leistungsgrenze (über MQTT vorgegeben max_power).
- Ist die Grenze erreicht oder überschritten, wird die Leistung entsprechend reduziert.
Prüfung der Stromgrenze (über MQTT vorgegeben max_current).
- Ist die Grenze erreicht oder überschritten, wird der Strom entsprechend reduziert.
Sind weder Leistungs- noch Stromgrenze erreicht, wird keine Reduzierung durchgeführt.

Fehlerfall

Wenn der timestamp älter als 60 Sekunden ist:

Es wird eine RuntimeError ausgelöst.
Es werden die konfigurierte maximale Bezugsleistung und die maximalen Amperewerte für den Fehlerfall verwendet.

Copilot

Pull request overview

Adds a new “LoadManager” integration that ingests import-limit data via MQTT as an IO device and applies it as an additional limiting step in the charging loadmanagement pipeline.

Changes:

Introduces a new MQTT-based IO device module for LoadManager analog inputs (max power/current/timestamp).
Adds a new controllable-consumers action (DimmingLoadManager) and wires it into loadmanagement limiting.
Extends MQTT set-topic validation to include the new loadmanager topic.

Reviewed changes

Copilot reviewed 7 out of 8 changed files in this pull request and generated 4 comments.

Show a summary per file

File	Description
packages/modules/io_devices/load_manager/config.py	Defines LoadManager IO device config and analog input mapping.
packages/modules/io_devices/load_manager/api.py	Subscribes to internal MQTT topics and populates `IoState` analog inputs for the LoadManager.
packages/modules/io_devices/load_manager/init.py	Module package initializer for the new IO device.
packages/modules/io_actions/controllable_consumers/load_manager/config.py	Adds configuration/setup types for the new controllable-consumers LoadManager action.
packages/modules/io_actions/controllable_consumers/load_manager/api.py	Implements `DimmingLoadManager` action that provides remaining import power for loadmanagement.
packages/helpermodules/setdata.py	Validates the new `openWB/set/mqtt/loadmanager/...` topic so it is forwarded to internal MQTT.
packages/control/loadmanagement.py	Adds a new `_limit_loadmanager` limiting step in `get_available_currents`.
packages/control/io_device.py	Registers the new IO action type and exposes it via `IoActions.dimming_load_manager()`.

💡 Add Copilot custom instructions for smarter, more guided reviews. Learn how to get started.

+        dimming_power_left, limit = data.data.io_actions.dimming_load_manager({"type": "cp", "id": cp.num})
+        if dimming_power_left is not None:
+            if sum(available_currents)*230 > dimming_power_left:
+                phases = 3-available_currents.count(0)
+                overload_per_phase = (sum(available_currents) - dimming_power_left/230)/phases
+                available_currents = [c - overload_per_phase if c > 0 else 0 for c in available_currents]
+                log.debug(f"Reduzierung der Ströme durch die Dimmung: {available_currents}A")
+        return available_currents, limit


+    def setup(self) -> None:
+        if check_fault_state_io_device(self.config.configuration.io_device):
+            self.import_power_left = self.config.configuration.fixed_import_power
+        else:
+            max_power = data.data.io_states[f"io_states{self.config.configuration.io_device}"
+                                            ].data.get.analog_input[AnalogInputMapping.MAX_POWER.name]
+            self.import_power_left = max_power


        return Path(__file__).resolve().parents[2]/"ramdisk"
+
+    def loadmanager_topic(self, msg: mqtt.MQTTMessage):
+        """ Handler für die LoadMananger-Topics


Co-authored-by: Copilot Autofix powered by AI <175728472+Copilot@users.noreply.github.com>

Copilot

Pull request overview

Copilot reviewed 7 out of 8 changed files in this pull request and generated 5 comments.

+        self.name = name
+        self.type = type
+        self.id = id
+        self.configuration = configuration or LoadManagerConfiguration()
+        if input is None:
+            input = init_input()
+        if output is None:
+            output = init_output()
+        super().__init__(name, type, id, configuration or LoadManagerConfiguration(), input=input, output=output)


+        broker = BrokerClient("subscribeMqttLoadmanager",
+                              on_connect, on_message)
+
+    return ConfigurableIo(config=config, component_reader=read, component_writer=lambda: None, initializer=initializer)


        return Path(__file__).resolve().parents[2]/"ramdisk"
+
+    def loadmanager_topic(self, msg: mqtt.MQTTMessage):
+        """ Handler für die LoadMananger-Topics


+        if dimming_power_left is not None:
+            if sum(available_currents)*230 > dimming_power_left:
+                phases = 3-available_currents.count(0)
+                overload_per_phase = (sum(available_currents) - dimming_power_left/230)/phases
+                available_currents = [c - overload_per_phase if c > 0 else 0 for c in available_currents]
+                log.debug(f"Reduzierung der Ströme durch die Dimmung: {available_currents}A")
+        return available_currents, limit


+    def _limit_loadmanager(self,
+                           available_currents: List[float],
+                           cp: Chargepoint) -> Tuple[List[float], LoadmanagementLimit]:
+        dimming_power_left, limit = data.data.io_actions.dimming_load_manager({"type": "cp", "id": cp.num})
+        if dimming_power_left is not None:
+            if sum(available_currents)*230 > dimming_power_left:
+                phases = 3-available_currents.count(0)
+                overload_per_phase = (sum(available_currents) - dimming_power_left/230)/phases
+                available_currents = [c - overload_per_phase if c > 0 else 0 for c in available_currents]
+                log.debug(f"Reduzierung der Ströme durch die Dimmung: {available_currents}A")
+        return available_currents, limit


…8/core into feature_LoadManager

LKuemmel · 2026-07-09T06:14:00Z

+        fixed_import_power = 0
+        for device in self.config.configuration.devices:
+            if device["type"] != "cp":
+                fixed_import_power += 4200
+        log.debug(f"Dimmen per LoadManager: Fest vergebene Mindestleistung: {fixed_import_power}W")
+        if fixed_import_power != self.config.configuration.fixed_import_power:
+            self.config.configuration.fixed_import_power = fixed_import_power
+            Pub().pub(f"openWB/set/io/action/{self.config.id}/config", asdict(self.config))


fixed_import_power gibt es beim Lastmanager nicht

LKuemmel · 2026-07-09T06:14:07Z

+
+    def setup(self) -> None:
+        if check_fault_state_io_device(self.config.configuration.io_device):
+            max_power = self.config.configuration.fixed_import_power


fixed_import_power gibt es beim Lastmanager nicht, sondern "maximale Leistung im Fehlerfall"

LKuemmel

Es kommen auch max_currents rein, die müssen auch berücksichtigt werden ;)
Und bitte noch eine Prüfung des Timestamps im IO-Device einbauen. Wenn der älter als 60s ist, eine Exception werfen.

LKuemmel · 2026-07-09T10:53:38Z

-            self.config.configuration.fixed_import_power = fixed_import_power
-            Pub().pub(f"openWB/set/io/action/{self.config.id}/config", asdict(self.config))
-
+        control_command_log.info("Begrenzung per Lastmanager.")


Einträge im control_command_log braucht man nicht. Bei §14a muss für den Netzbetreiber dokumentiert werden, das und wie viel gedimmt wurde, dafür ist dieses Log da.

LKuemmel · 2026-07-13T12:01:20Z

+            "type": "cp", "id": cp.num})
+
+        if loadmanager_power_left is not None and loadmanager_current_left is not None:
+            if sum(available_currents)*230 > loadmanager_power_left:


Es gab irgendwann mal den Wunsch von der Community, dass das Lastmanagement genauer rechnen soll. Also mit der tatsächlichen Spannung voltages_mean(cp.data.get.voltages) statt 230V

LKuemmel · 2026-07-13T12:04:38Z

+            if timestamp > 1e10:
+                timestamp /= 1000


Suggested change

if timestamp > 1e10:

timestamp /= 1000

Der Timestamp sollte als Unix-Timestamp kommen.

LKuemmel · 2026-07-13T12:05:17Z

+            age_s = timecheck.create_timestamp() - timestamp
+            # < = deaktiviert
+            if age_s < 60:
+                log.warning("Lastmanager-Daten veraltet: age=%.1fs, timestamp=%s", age_s, timestamp)


Suggested change

log.warning("Lastmanager-Daten veraltet: age=%.1fs, timestamp=%s", age_s, timestamp)

Die Exception sollte ohnehin geloggt werden. Dann kann die Warnung weg, sonst ist es doppelt.

LKuemmel · 2026-07-13T12:16:47Z

+        io_state.digital_input = getattr(io_state, "digital_input", None) or {}
+        io_state.digital_output = getattr(io_state, "digital_output", None) or {}
+
+        if received_topics.get("openWB/mqtt/loadmanager/set/loadmanager"):


Für die eindeutige Zuordnung wäre es gut, wenn noch die ID vom IO-Gerät im Topic ist. Dann ist es auch kein Problem, wenn mehrere Lastmanager konfiguriert werden -> openWB/mqtt/loadmanager/1/set/loadmanager
Das müsste dann auch noch in der setdata angepasst werden.

AlexanderHa98 added 3 commits July 7, 2026 14:37

Add LoadManager

0be35bc

Remove unused thread-variable

94a8aa7

Remove unused thread-variable

3e42a9a

AlexanderHa98 requested review from LKuemmel and Copilot July 7, 2026 12:57

Copilot started reviewing on behalf of AlexanderHa98 July 7, 2026 12:57 View session

Copilot AI reviewed Jul 7, 2026

View reviewed changes

Potential fix for pull request finding

a44eebe

Co-authored-by: Copilot Autofix powered by AI <175728472+Copilot@users.noreply.github.com>

AlexanderHa98 requested a review from Copilot July 7, 2026 13:26

Copilot started reviewing on behalf of AlexanderHa98 July 7, 2026 13:27 View session

Copilot AI reviewed Jul 7, 2026

View reviewed changes

AlexanderHa98 added 2 commits July 7, 2026 15:41

Add Copilot suggestion

89c6be7

Merge branch 'feature_LoadManager' of https://github.com/AlexanderHa9…

c6e6061

…8/core into feature_LoadManager

LKuemmel requested changes Jul 9, 2026

View reviewed changes

AlexanderHa98 added this to the 2.3.0 milestone Jul 9, 2026

Add requested changes

2ef39ed

LKuemmel requested changes Jul 9, 2026

View reviewed changes

AlexanderHa98 added 4 commits July 9, 2026 13:47

Add max_current und Timestamp check

498fb9b

Update Loadmanager

a2eb941

Fix timestamp error-handling

c1cc1b5

Fix row-length

e990e5d

LKuemmel requested changes Jul 13, 2026

View reviewed changes

Add id to MQTT-msg

7e32982

LKuemmel approved these changes Jul 14, 2026

View reviewed changes

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

Uh oh!

Add LoadManager#3636

Add LoadManager#3636
AlexanderHa98 wants to merge 12 commits into
openWB:masterfrom
AlexanderHa98:feature_LoadManager

AlexanderHa98 commented Jul 7, 2026 •

edited

Loading

Uh oh!

Copilot AI left a comment

Uh oh!

Uh oh!

Copilot AI left a comment

Uh oh!

Uh oh!

LKuemmel Jul 9, 2026

Uh oh!

LKuemmel Jul 9, 2026

Uh oh!

LKuemmel left a comment

Uh oh!

LKuemmel Jul 9, 2026

Uh oh!

LKuemmel Jul 13, 2026

Uh oh!

LKuemmel Jul 13, 2026

Uh oh!

LKuemmel Jul 13, 2026

Uh oh!

LKuemmel Jul 13, 2026

Uh oh!

Reviewers

Assignees

Labels

Projects

Milestone

Development

Uh oh!

3 participants

Uh oh!

Conversation

AlexanderHa98 commented Jul 7, 2026 • edited Loading Uh oh! There was an error while loading. Please reload this page.

Uh oh!

Aufbau

GUI

MQTT-Topic

Beispiel-Payload

Funktionsweise

Lastmanagement

Fehlerfall

Uh oh!

Copilot AI left a comment

Choose a reason for hiding this comment

Pull request overview

Reviewed changes

Uh oh!

Uh oh!

Copilot AI left a comment

Choose a reason for hiding this comment

Pull request overview

Uh oh!

Uh oh!

LKuemmel Jul 9, 2026

Choose a reason for hiding this comment

Uh oh!

LKuemmel Jul 9, 2026

Choose a reason for hiding this comment

Uh oh!

LKuemmel left a comment

Choose a reason for hiding this comment

Uh oh!

LKuemmel Jul 9, 2026

Choose a reason for hiding this comment

Uh oh!

LKuemmel Jul 13, 2026

Choose a reason for hiding this comment

Uh oh!

LKuemmel Jul 13, 2026

Choose a reason for hiding this comment

Uh oh!

LKuemmel Jul 13, 2026

Choose a reason for hiding this comment

Uh oh!

LKuemmel Jul 13, 2026

Choose a reason for hiding this comment

Uh oh!

Reviewers

Assignees

Labels

Projects

Milestone

Development

Uh oh!

3 participants

AlexanderHa98 commented Jul 7, 2026 •

edited

Loading