Group optimizer sensors under site device

This commit is contained in:
2026-08-10 11:59:29 +02:00
parent 2085316d1f
commit db93b81e5d
12 changed files with 102 additions and 44 deletions
+19 -15
View File
@@ -2,16 +2,19 @@
Diese Custom Integration liest den lokalen Cache der Diese Custom Integration liest den lokalen Cache der
[SolarEdge Optimizer Data App](https://git.jensneuber.de/jens/solaredge-optimizers) [SolarEdge Optimizer Data App](https://git.jensneuber.de/jens/solaredge-optimizers)
und stellt jeden Leistungsoptimierer als eigenes Home-Assistant-Gerät bereit. und stellt die Messwerte jedes Leistungsoptimierers als Sensoren bereit.
Alle Optimierer werden unter einem gemeinsamen Home-Assistant-Gerät pro
SolarEdge-Site zusammengefasst.
Pro Optimierer werden zwei Sensoren angelegt: Pro Optimierer werden zwei Sensoren angelegt:
- **Tagesenergie** in Wh (`total_increasing`) - **Tagesenergie** in Wh (`total_increasing`)
- **Aktuelle Leistung** in W (`measurement`) - **Aktuelle Leistung** in W (`measurement`)
Die Seriennummer bleibt die stabile Gerätekennung. Optimierer-ID, String-ID, Die Seriennummer bleibt Bestandteil der stabilen Entity-ID. Optimierer-ID,
Wechselrichter-ID und Zeitpunkt der letzten Messung stehen als Attribute zur String-ID, Wechselrichter-ID und Zeitpunkt der letzten Messung stehen als
Verfügung. Attribute zur Verfügung.
## Voraussetzungen ## Voraussetzungen
@@ -22,18 +25,20 @@ Verfügung.
Die SolarEdge-Zugangsdaten bleiben ausschließlich in der App-Konfiguration. Die SolarEdge-Zugangsdaten bleiben ausschließlich in der App-Konfiguration.
Die Integration spricht nur mit der lokalen App-API. Die Integration spricht nur mit der lokalen App-API.
## Installation mit HACS ## Installation
1. In HACS **Integrationen** öffnen. HACS unterstützt keine Gitea-Repositories. Lade deshalb das Archiv der
2. Über das Menü **Benutzerdefinierte Repositories** öffnen. gewünschten Version herunter und entpacke es:
3. `https://git.jensneuber.de/jens/ha-solaredge-optimizers` als Typ
**Integration** hinzufügen.
4. **SolarEdge Optimizers** installieren.
5. Home Assistant neu starten.
Alternativ den Ordner `custom_components/solaredge_optimizers` nach ```text
`/config/custom_components/solaredge_optimizers` kopieren und Home Assistant https://git.jensneuber.de/jens/ha-solaredge-optimizers/archive/v0.2.0.zip
neu starten. ```
Kopiere anschließend den enthaltenen Ordner
`custom_components/solaredge_optimizers` nach
`/config/custom_components/solaredge_optimizers` und starte Home Assistant neu.
Eine Installation über HACS ist erst mit einem öffentlichen GitHub-Mirror
möglich.
## Einrichtung ## Einrichtung
@@ -59,4 +64,3 @@ uv sync
uv run ruff check . uv run ruff check .
uv run pytest uv run pytest
``` ```
@@ -7,16 +7,57 @@ from datetime import timedelta
from homeassistant.config_entries import ConfigEntry from homeassistant.config_entries import ConfigEntry
from homeassistant.const import CONF_URL, Platform from homeassistant.const import CONF_URL, Platform
from homeassistant.core import HomeAssistant from homeassistant.core import HomeAssistant
from homeassistant.helpers import device_registry as dr
from homeassistant.helpers.aiohttp_client import async_get_clientsession from homeassistant.helpers.aiohttp_client import async_get_clientsession
from .api import SolarEdgeOptimizerApiClient from .api import SolarEdgeOptimizerApiClient
from .const import CONF_SCAN_INTERVAL, DEFAULT_SCAN_INTERVAL from .const import (
CONF_SCAN_INTERVAL,
CONFIG_ENTRY_VERSION,
DEFAULT_SCAN_INTERVAL,
DOMAIN,
LOGGER,
)
from .coordinator import SolarEdgeOptimizerCoordinator from .coordinator import SolarEdgeOptimizerCoordinator
PLATFORMS = [Platform.SENSOR] PLATFORMS = [Platform.SENSOR]
type SolarEdgeOptimizerConfigEntry = ConfigEntry[SolarEdgeOptimizerCoordinator] type SolarEdgeOptimizerConfigEntry = ConfigEntry[SolarEdgeOptimizerCoordinator]
async def async_migrate_entry(
hass: HomeAssistant, entry: SolarEdgeOptimizerConfigEntry
) -> bool:
"""Migrate optimizer devices to one site device."""
if entry.version > CONFIG_ENTRY_VERSION:
LOGGER.error(
"Cannot migrate config entry from version %s to %s",
entry.version,
CONFIG_ENTRY_VERSION,
)
return False
if entry.version < 2:
site_id = entry.unique_id
if site_id:
device_registry = dr.async_get(hass)
legacy_prefix = f"{site_id}_"
for device in dr.async_entries_for_config_entry(
device_registry, entry.entry_id
):
if any(
domain == DOMAIN and identifier.startswith(legacy_prefix)
for domain, identifier in device.identifiers
):
device_registry.async_remove_device(device.id)
hass.config_entries.async_update_entry(
entry,
version=CONFIG_ENTRY_VERSION,
)
return True
async def async_setup_entry( async def async_setup_entry(
hass: HomeAssistant, entry: SolarEdgeOptimizerConfigEntry hass: HomeAssistant, entry: SolarEdgeOptimizerConfigEntry
) -> bool: ) -> bool:
@@ -20,6 +20,7 @@ from .api import (
) )
from .const import ( from .const import (
CONF_SCAN_INTERVAL, CONF_SCAN_INTERVAL,
CONFIG_ENTRY_VERSION,
DEFAULT_PORT, DEFAULT_PORT,
DEFAULT_SCAN_INTERVAL, DEFAULT_SCAN_INTERVAL,
DOMAIN, DOMAIN,
@@ -61,7 +62,7 @@ def _schema(defaults: dict[str, Any]) -> vol.Schema:
class SolarEdgeOptimizersConfigFlow(ConfigFlow, domain=DOMAIN): class SolarEdgeOptimizersConfigFlow(ConfigFlow, domain=DOMAIN):
"""Handle a config flow for SolarEdge Optimizers.""" """Handle a config flow for SolarEdge Optimizers."""
VERSION = 1 VERSION = CONFIG_ENTRY_VERSION
def __init__(self) -> None: def __init__(self) -> None:
"""Initialize the flow.""" """Initialize the flow."""
@@ -5,6 +5,7 @@ from datetime import timedelta
DOMAIN = "solaredge_optimizers" DOMAIN = "solaredge_optimizers"
LOGGER = logging.getLogger(__package__) LOGGER = logging.getLogger(__package__)
CONFIG_ENTRY_VERSION = 2
CONF_SCAN_INTERVAL = "scan_interval" CONF_SCAN_INTERVAL = "scan_interval"
DEFAULT_SCAN_INTERVAL = timedelta(minutes=10) DEFAULT_SCAN_INTERVAL = timedelta(minutes=10)
@@ -8,5 +8,5 @@
"iot_class": "local_polling", "iot_class": "local_polling",
"issue_tracker": "https://git.jensneuber.de/jens/ha-solaredge-optimizers/issues", "issue_tracker": "https://git.jensneuber.de/jens/ha-solaredge-optimizers/issues",
"requirements": [], "requirements": [],
"version": "0.1.0" "version": "0.2.0"
} }
@@ -102,6 +102,10 @@ class SolarEdgeOptimizerSensor(
self.entity_description = description self.entity_description = description
self._serial = serial self._serial = serial
self._attr_unique_id = f"{coordinator.data.site_id}_{serial}_{description.key}" self._attr_unique_id = f"{coordinator.data.site_id}_{serial}_{description.key}"
optimizer = coordinator.data.optimizers_by_serial[serial]
self._attr_translation_placeholders = {
"optimizer_id": optimizer.optimizer_id or serial
}
@property @property
def _optimizer(self) -> OptimizerData | None: def _optimizer(self) -> OptimizerData | None:
@@ -121,15 +125,13 @@ class SolarEdgeOptimizerSensor(
@property @property
def device_info(self) -> DeviceInfo: def device_info(self) -> DeviceInfo:
"""Return optimizer device information.""" """Return the shared SolarEdge site device information."""
optimizer = self._optimizer site_id = self.coordinator.data.site_id
optimizer_id = optimizer.optimizer_id if optimizer else None
return DeviceInfo( return DeviceInfo(
identifiers={(DOMAIN, f"{self.coordinator.data.site_id}_{self._serial}")}, identifiers={(DOMAIN, site_id)},
manufacturer="SolarEdge", manufacturer="SolarEdge",
model="Power Optimizer", model="Optimizer Monitoring Site",
name=f"Optimizer {optimizer_id or self._serial}", name=f"SolarEdge Site {site_id}",
serial_number=self._serial,
) )
@property @property
@@ -46,12 +46,11 @@
"entity": { "entity": {
"sensor": { "sensor": {
"daily_energy": { "daily_energy": {
"name": "Daily energy" "name": "{optimizer_id} daily energy"
}, },
"current_power": { "current_power": {
"name": "Current power" "name": "{optimizer_id} current power"
} }
} }
} }
} }
@@ -46,12 +46,11 @@
"entity": { "entity": {
"sensor": { "sensor": {
"daily_energy": { "daily_energy": {
"name": "Tagesenergie" "name": "{optimizer_id} Tagesenergie"
}, },
"current_power": { "current_power": {
"name": "Aktuelle Leistung" "name": "{optimizer_id} aktuelle Leistung"
} }
} }
} }
} }
@@ -46,12 +46,11 @@
"entity": { "entity": {
"sensor": { "sensor": {
"daily_energy": { "daily_energy": {
"name": "Daily energy" "name": "{optimizer_id} daily energy"
}, },
"current_power": { "current_power": {
"name": "Current power" "name": "{optimizer_id} current power"
} }
} }
} }
} }
+1 -1
View File
@@ -1,6 +1,6 @@
[project] [project]
name = "ha-solaredge-optimizers" name = "ha-solaredge-optimizers"
version = "0.1.0" version = "0.2.0"
description = "Home Assistant custom integration for SolarEdge optimizer data" description = "Home Assistant custom integration for SolarEdge optimizer data"
readme = "README.md" readme = "README.md"
requires-python = ">=3.14.2" requires-python = ">=3.14.2"
+20 -8
View File
@@ -25,6 +25,15 @@ async def test_optimizer_sensors(hass: HomeAssistant) -> None:
data={CONF_URL: "http://app:8099", CONF_SCAN_INTERVAL: 600}, data={CONF_URL: "http://app:8099", CONF_SCAN_INTERVAL: 600},
) )
entry.add_to_hass(hass) entry.add_to_hass(hass)
device_registry = dr.async_get(hass)
device_registry.async_get_or_create(
config_entry_id=entry.entry_id,
identifiers={(DOMAIN, "4886699_14F28854-E2")},
manufacturer="SolarEdge",
model="Power Optimizer",
name="Optimizer 1.1.1",
serial_number="14F28854-E2",
)
with patch( with patch(
"custom_components.solaredge_optimizers.api." "custom_components.solaredge_optimizers.api."
@@ -44,13 +53,16 @@ async def test_optimizer_sensors(hass: HomeAssistant) -> None:
power_entity = next( power_entity = next(
entity for entity in entities if entity.unique_id.endswith("_current_power") entity for entity in entities if entity.unique_id.endswith("_current_power")
) )
assert hass.states.get(energy_entity.entity_id).state == "1234.5" energy_state = hass.states.get(energy_entity.entity_id)
assert hass.states.get(power_entity.entity_id).state == "160.7" power_state = hass.states.get(power_entity.entity_id)
assert energy_state.state == "1234.5"
assert power_state.state == "160.7"
assert "1.1.1" in energy_state.name
assert "1.1.1" in power_state.name
device_registry = dr.async_get(hass)
devices = dr.async_entries_for_config_entry(device_registry, entry.entry_id) devices = dr.async_entries_for_config_entry(device_registry, entry.entry_id)
assert len(devices) == 2 assert len(devices) == 1
assert {device.serial_number for device in devices} == { assert devices[0].identifiers == {(DOMAIN, "4886699")}
"14F28854-E2", assert devices[0].name == "SolarEdge Site 4886699"
"14F28855-E2", assert all(entity.device_id == devices[0].id for entity in entities)
} assert entry.version == 2
Generated
+1 -1
View File
@@ -943,7 +943,7 @@ wheels = [
[[package]] [[package]]
name = "ha-solaredge-optimizers" name = "ha-solaredge-optimizers"
version = "0.1.0" version = "0.2.0"
source = { virtual = "." } source = { virtual = "." }
[package.dev-dependencies] [package.dev-dependencies]