Energy Monitoring Guide¶

This guide explains how to monitor energy consumption and usage data from Navien NWP500 water heaters.

Overview¶

The NWP500 provides energy monitoring data through real-time status updates via MQTT. All energy-related data is available through the DeviceStatus object returned by the subscribe_device_status() callback.

Real-Time Power Consumption¶

Total Instantaneous Power¶

The most important metric for energy monitoring:

from nwp500 import NavienMqttClient, DeviceStatus

def on_status(status: DeviceStatus):
    # Total power consumption in Watts
    power_watts = status.current_inst_power
    print(f"Current Power: {power_watts} W")

Field: current_inst_power
Type: float
Units: Watts (W)
Description: Total instantaneous power consumption of the entire
unit, including heat pump compressor and electric heating elements.

Component Status¶

Know which heating components are currently active:

def on_status(status: DeviceStatus):
    if status.comp_use:
        print("Heat pump compressor is running")

    if status.heat_upper_use:
        print("Upper electric heater is running")

    if status.heat_lower_use:
        print("Lower electric heater is running")

Fields:

comp_use (bool): Heat pump compressor active
heat_upper_use (bool): Upper electric heating element active
heat_lower_use (bool): Lower electric heating element active

Cumulative Usage Statistics¶

Track total runtime for each heating component:

def on_status(status: DeviceStatus):
    # Convert minutes to hours
    comp_hours = status.comp_running_minute_total / 60
    heater1_hours = status.heater1_running_minute_total / 60
    heater2_hours = status.heater2_running_minute_total / 60

    print(f"Heat Pump Runtime: {comp_hours:.1f} hours")
    print(f"Upper Heater Runtime: {heater1_hours:.1f} hours")
    print(f"Lower Heater Runtime: {heater2_hours:.1f} hours")

Fields:

comp_running_minute_total (int): Total heat pump compressor runtime in minutes
heater1_running_minute_total (int): Total upper electric heater runtime in minutes
heater2_running_minute_total (int): Total lower electric heater runtime in minutes

Historical Energy Usage¶

Request detailed daily energy usage data for specific months:

from nwp500 import NavienMqttClient, EnergyUsageResponse

def on_energy_usage(energy: EnergyUsageResponse):
    print(f"Total Usage: {energy.total.total_usage} Wh")
    print(f"Heat Pump: {energy.total.heat_pump_percentage:.1f}%")
    print(f"Electric: {energy.total.heat_element_percentage:.1f}%")

    # Daily breakdown
    for day in energy.daily:
        print(f"Day {day.day}: {day.total_usage} Wh")

# Subscribe to energy usage responses
await mqtt_client.subscribe_energy_usage(device, on_energy_usage)

# Request energy usage for September 2025
await mqtt_client.request_energy_usage(device, year=2025, months=[9])

# Request multiple months
await mqtt_client.request_energy_usage(device, year=2025, months=[7, 8, 9])

Methods:

request_energy_usage(device, year, months): Request historical data
subscribe_energy_usage(device, callback): Subscribe to energy usage responses

Response Fields:

total.total_usage (int): Total energy consumption in Wh
total.heat_pump_percentage (float): Percentage from heat pump
total.heat_element_percentage (float): Percentage from electric heaters
daily (list): Daily breakdown of usage per day

Energy Capacity¶

Monitor available stored energy:

def on_status(status: DeviceStatus):
    capacity = status.available_energy_capacity
    print(f"Energy Capacity: {capacity}%")

    if capacity < 20:
        print("Low energy - heating may be needed")
    elif capacity > 80:
        print("High energy - tank is hot")

Field: available_energy_capacity
Type: int
Units: Percentage (0-100)
Description: Available energy in the tank as a percentage,
indicating how much hot water is available.

Temperature Monitoring¶

Water Temperature¶

def on_status(status: DeviceStatus):
    # Current water temperature
    current_temp = status.dhw_temperature
    target_temp = status.dhw_temperature_setting

    print(f"Water Temperature: {current_temp}°F (Target: {target_temp}°F)")

Fields:

dhw_temperature (float): Current water temperature
dhw_temperature_setting (int): Target temperature setting
dhw_temperature_min (int): Minimum allowed temperature
dhw_temperature_max (int): Maximum allowed temperature

Component Temperatures¶

Monitor individual heating component temperatures:

def on_status(status: DeviceStatus):
    print(f"Compressor Temp: {status.comp_temp}°F")
    print(f"Upper Tank Temp: {status.dhw_tank_upper_temp}°F")
    print(f"Lower Tank Temp: {status.dhw_tank_lower_temp}°F")
    print(f"Heat Exchanger Out: {status.dhw_heatex_out_temp}°F")

Complete Energy Monitoring Example¶

import asyncio
from nwp500 import NavienAuthClient, NavienAPIClient, NavienMqttClient, DeviceStatus

def calculate_power_cost(power_watts: float, hours: float, cost_per_kwh: float = 0.12) -> float:
    """Calculate energy cost based on power consumption."""
    kwh = (power_watts / 1000) * hours
    return kwh * cost_per_kwh

async def monitor_energy():
    async with NavienAuthClient("email@example.com", "password") as auth_client:
        api_client = NavienAPIClient(auth_client=auth_client)
        device = await api_client.get_first_device()

        # Create MQTT client inside the auth context
        mqtt_client = NavienMqttClient(auth_client)
        await mqtt_client.connect()

        # Energy monitoring callback
        def on_status(status: DeviceStatus):
            print("\n" + "="*50)
            print("ENERGY MONITORING")
            print("="*50)

            # Real-time power
            print(f"\nCurrent Power: {status.current_inst_power} W")

            # Active components
            components = []
            if status.comp_use:
                components.append("Heat Pump")
            if status.heat_upper_use:
                components.append("Upper Heater")
            if status.heat_lower_use:
                components.append("Lower Heater")

            if components:
                print(f"Active: {', '.join(components)}")
            else:
                print("Active: None (Standby)")

            # Cumulative runtime
            print(f"\nCumulative Runtime:")
            print(f"  Heat Pump: {status.comp_running_minute_total / 60:.1f} hours")
            print(f"  Upper Heater: {status.heater1_running_minute_total / 60:.1f} hours")
            print(f"  Lower Heater: {status.heater2_running_minute_total / 60:.1f} hours")

            # Energy capacity and temperature
            print(f"\nEnergy Capacity: {status.available_energy_capacity}%")
            print(f"Water Temp: {status.dhw_temperature}°F "
                  f"(Target: {status.dhw_temperature_setting}°F)")

            # Estimated hourly cost (if running continuously at current power)
            if status.current_inst_power > 0:
                hourly_cost = calculate_power_cost(status.current_inst_power, 1.0)
                print(f"\nEstimated Cost (if sustained): ${hourly_cost:.3f}/hour")

        # Subscribe to device status
        await mqtt_client.subscribe_device_status(device, on_status)

        # Request initial status
        await mqtt_client.request_device_status(device)

        # Monitor for 5 minutes
        print("Monitoring energy consumption for 5 minutes...")
        await asyncio.sleep(300)

        await mqtt_client.disconnect()

if __name__ == "__main__":
    asyncio.run(monitor_energy())

Energy Data Fields Reference¶

Power Consumption¶

Field	Type	Units	Description
`current_inst_power`	float	W	Total instantaneous power consumption
`comp_use`	bool		Heat pump compressor active
`heat_upper_use`	bool		Upper electric heater active
`heat_lower_use`	bool		Lower electric heater active

Cumulative Usage¶

Field	Type	Units	Description
`comp_running_minute_total`	int	minutes	Total heat pump runtime
`heater1_running_minute_total` \| int		minutes	Total upper heater runtime
`heater2_running_minute_total` \| int		minutes	Total lower heater runtime

Energy Capacity¶

Field	Type	Units	Description
`available_energy_capacity`	int	%	Available energy (0-100%)

Temperature¶

Field	Type	Units	Description
`dhw_temperature`	float	°F	Current water temperature
`dhw_temperature_setting`	int	°F	Target temperature setting
`comp_temp`	float	°F	Heat pump compressor temperature
`dhw_tank_upper_temp`	float	°F	Upper tank temperature
`dhw_tank_lower_temp`	float	°F	Lower tank temperature
`dhw_heatex_out_temp`	float	°F	Heat exchanger outlet temperature

Notes¶

All power values are in Watts (W)
All temperatures are in Fahrenheit (°F)
Status updates are sent automatically by the device approximately every few seconds
Cumulative runtime values persist across device power cycles
Energy capacity calculation is based on temperature and usage patterns

Energy Monitoring Guide¶

Overview¶

Real-Time Power Consumption¶

Total Instantaneous Power¶

Component Status¶

Cumulative Usage Statistics¶

Historical Energy Usage¶

Energy Capacity¶

Temperature Monitoring¶

Water Temperature¶

Component Temperatures¶

Complete Energy Monitoring Example¶

Energy Data Fields Reference¶

Power Consumption¶

Cumulative Usage¶

Energy Capacity¶

Temperature¶

Notes¶

See Also¶

nwp500-python

Navigation

Related Topics