Merge pull request #4 from chrisyeh96/chris

Update nonlinear sim

Author: chrisyeh96

56_bus_pandapower_check.ipynb

@@ -7,13 +7,27 @@
 
 **California Institute of Technology and UC San Diego**
 
+## Getting started
+
+### Install packages
+
+1. Install [miniconda3](https://docs.conda.io/en/latest/miniconda.html).
+2. Install the `voltctrl` conda environment:
+    ```bash
+    conda env update -f env.yml --prune
+    ```
+3. Request a Mosek license ([link](https://www.mosek.com/products/academic-licenses/)). Upon receiving the license file (`mosek.lic`) in an email, create a folder `~/mosek` and copy the license file into that folder.
+
+### Running voltage control experiments
+
+TODO
 
 ## Data Files (in `/data`)
 
 The original data files were provided by the authors of the following paper:
 > Guannan Qu and Na Li. 2020. Optimal Distributed Feedback Voltage Control under Limited Reactive Power. _IEEE Transactions on Power Systems_ 35, 1 (Jan. 2020), 315–331. https://doi.org/10.1109/TPWRS.2019.2931685
 
-The original data files ("orig_data.zip") are attached to the [releases](https://github.com/chrisyeh96/voltctrl/releases/tag/v1.0). These original data files have been processed into the following files, which are the only files relevant for our experiments. See the inspect_matlab_data.ipynb notebook for details.
+The original data files ("orig_data.zip") are attached to the [releases](https://github.com/chrisyeh96/voltctrl/releases/tag/v1.0). These original data files have been processed into the following files, which are the main files relevant for our experiments. See the [inspect_matlab_data.ipynb](notebooks/inspect_data.ipynb) notebook for details.
 
 **PV.mat**
 - contains single key `'actual_PV_profile'`
@@ -57,6 +71,12 @@ The original data files ("orig_data.zip") are attached to the [releases](https:/
     - 'branch': shape [55, 13], type float64
     - 'gen': shape [1, 21], type int16
 
+**nonlinear_voltage_baseline.npy**
+- float64 array, shape [14421, 56]
+- description: balanced AC nonlinear simulation voltages, generated by [nonlinear_no_control.py](nonlinear_no_control.py)
+- each column is the voltage of a bus, with column 0 being bus 0 (the substation)
+- units: p.u. voltage (multiply by 12 to get kV)
+
 See the attachment in [releases](https://github.com/chrisyeh96/voltctrl/releases/tag/v1.0) for Python `.pkl` files containing the results of running the various algorithms. These Pickle files are read by the various Jupyter notebooks for plotting and analysis.
 
 

README.md

@@ -3,14 +3,14 @@
 
 from collections.abc import Callable, Sequence
 import io
+from typing import Any
 
 import cvxpy as cp
 import numpy as np
 from tqdm.auto import tqdm
 
 from network_utils import make_pd_and_pos, np_triangle_norm
-
-Constraint = cp.constraints.constraint.Constraint
+from utils import solve_prob
 
 
 def cp_triangle_norm_sq(x: cp.Expression) -> cp.Expression:
@@ -19,12 +19,12 @@ def cp_triangle_norm_sq(x: cp.Expression) -> cp.Expression:
 
 def project_into_X_set(X_init: np.ndarray, var_X: cp.Variable,
                        log: tqdm | io.TextIOBase | None,
-                       X_set: list[Constraint], X_true: np.ndarray) -> None:
+                       X_set: list[cp.Constraint], X_true: np.ndarray) -> None:
     """Project X_init into 𝒳 if necessary."""
     if log is not None:
         norm = np_triangle_norm(X_init)
         dist = np_triangle_norm(X_init - X_true)
-        log.write(f'X_init: ||X̂||_△ = {norm:.3f}, ||X̂-X||_△ = {dist:.3f}')
+        log.write(f'X_init: ‖X̂‖_△ = {norm:.3f}, ‖X̂-X‖_△ = {dist:.3f}')
 
     var_X.value = X_init  # if var_X.is_psd(), this automatically checks that X_init is PSD
     total_violation = sum(np.sum(constraint.violation()) for constraint in X_set)
@@ -35,19 +35,14 @@ def project_into_X_set(X_init: np.ndarray, var_X: cp.Variable,
             log.write(f'X_init invalid. Violation: {total_violation:.3f}. Projecting into 𝒳.')
         obj = cp.Minimize(cp_triangle_norm_sq(X_init - var_X))
         prob = cp.Problem(objective=obj, constraints=X_set)
-        try:
-            prob.solve(solver=cp.MOSEK)
-        except cp.error.SolverError as e:
-            if log is not None:
-                log.write(str(e))
-            prob.solve(solver=cp.SCS)
+        solve_prob(prob, log=log, name='projecting X_init into 𝒳')
         make_pd_and_pos(var_X.value)
         if log is not None:
             total_violation = sum(np.sum(constraint.violation()) for constraint in X_set)
             norm = np_triangle_norm(var_X.value)
             dist = np_triangle_norm(var_X.value - X_true)
             log.write(f'After projection: X_init violation: {total_violation:.3f}.')
-            log.write(f'                  ||X̂||_△ = {norm:.3f}, ||X̂-X||_△ = {dist:.3f}')
+            log.write(f'                  ‖X̂‖_△ = {norm:.3f}, ‖X̂-X‖_△ = {dist:.3f}')
 
 
 class CBCBase:
@@ -76,7 +71,7 @@ class CBCBase:
             sel.update(t+1)
     """
     def __init__(self, n: int, T: int, X_init: np.ndarray, v: np.ndarray,
-                 gen_X_set: Callable[[cp.Variable], list[Constraint]],
+                 gen_X_set: Callable[[cp.Variable], list[cp.Constraint]],
                  X_true: np.ndarray,
                  obs_nodes: Sequence[int] | None = None,
                  log: tqdm | io.TextIOBase | None = None):
@@ -87,9 +82,9 @@ def __init__(self, n: int, T: int, X_init: np.ndarray, v: np.ndarray,
         - X_init: np.array, shape [n, n], initial guess for X matrix, must be
             PSD and entry-wise >= 0
         - v: np.array, shape [n], initial squared voltage magnitudes
-        - gen_X_set: function, takes an optimization variable (cp.Variable) and returns
-            a list of constraints (cp.Constraint) describing the convex, compact
-            uncertainty set for X
+        - gen_X_set: function, takes an optimization variable (cp.Variable) and
+            returns a list of constraints (cp.Constraint) describing the
+            convex, compact uncertainty set for X
         - X_true: np.array, shape [n, n], true X matrix, optional
         - obs_nodes: list of int, nodes that we can observe voltages for
         - log: object with .write() function, defaults to tqdm
@@ -105,9 +100,10 @@ def __init__(self, n: int, T: int, X_init: np.ndarray, v: np.ndarray,
         # history
         self.v = np.zeros([T, n])  # v[t] = v(t)
         self.v[0] = v
-        self.delta_v = np.zeros([T-1, n])  # delta_v[t] = v(t+1) - v(t)
+        self.Δv = np.zeros([T-1, n])  # Δv[t] = v(t+1) - v(t)
         self.u = np.zeros([T-1, n])  # u[t] = u(t) = q^c(t+1) - q^c(t)
         self.q = np.zeros([T, n])  # q[t] = q^c(t)
+        self.ts_updated: list[int] = []
 
         # define optimization variables
         self.var_X = cp.Variable((n, n), PSD=True)
@@ -136,17 +132,77 @@ def add_obs(self, t: int) -> None:
         """
         assert t >= 1
         self.u[t-1] = self.q[t] - self.q[t-1]
-        self.delta_v[t-1] = self.v[t] - self.v[t-1]
+        self.Δv[t-1] = self.v[t] - self.v[t-1]
 
-    def select(self, t: int) -> np.ndarray:
-        """
-        Args
-        - t: int, current time step
+    def select(self, t: int) -> Any:
+        """Selects a model.
 
         When select() is called, we have seen t observations. That is, we have values for:
           v(0), ...,   v(t)    # recall:   v(t) = vs[t]
         q^c(0), ..., q^c(t)    # recall: q^c(t) = qs[t]
           u(0), ...,   u(t-1)  # recall:   u(t) = us[t]
-         Δv(0), ...,  Δv(t-1)  # recall:  Δv(t) = delta_vs[t]
+         Δv(0), ...,  Δv(t-1)  # recall:  Δv(t) = Δvs[t]
+
+        Args
+        - t: int, current time step
         """
+        raise NotImplementedError
+
+
+class CBCConst(CBCBase):
+    """CBC class that always returns the initial X.
+
+    Does not actually perform any model chasing.
+    """
+    def select(self, t: int) -> np.ndarray:
         return self.X_init
+
+
+class CBCConstWithNoise(CBCBase):
+    """CBC class that always returns the initial X, but learns eta."""
+    def __init__(self, n: int, T: int, X_init: np.ndarray, v: np.ndarray,
+                 gen_X_set: Callable[[cp.Variable], list[cp.Constraint]],
+                 X_true: np.ndarray,
+                 obs_nodes: Sequence[int] | None = None,
+                 log: tqdm | io.TextIOBase | None = None):
+        super().__init__(n=n, T=T, X_init=X_init, v=v, gen_X_set=gen_X_set,
+                         X_true=X_true, obs_nodes=obs_nodes, log=log)
+        self.eta = 0
+
+    def _check_newest_obs(self, t: int) -> tuple[bool, str]:
+        """Checks whether self.eta satisfies the
+        newest observation: (v[t], q[t], u[t-1], Δv[t-1])
+
+        Returns
+        - satisfied: bool, whether self.eta satisfies the newest observation
+        - msg: str, (if not satisfied) describes which constraints are not satisfied,
+            (if satisfied) is empty string ''
+        """
+        X = self.X_init
+
+        obs = self.obs_nodes
+        ŵ = self.Δv[t-1] - self.u[t-1] @ X
+        ŵ_norm = np.max(np.abs(ŵ[obs]))
+
+        if ŵ_norm > self.eta:
+            msg = f'‖ŵ(t)‖∞: {ŵ_norm:.3f}'
+            self.eta = ŵ_norm
+            return False, msg
+        else:
+            return True, ''
+
+    def add_obs(self, t: int) -> None:
+        """
+        Args
+        - t: int, current time step (>=1), v[t] and q[t] have just been updated
+        """
+        # update self.u and self.Δv
+        super().add_obs(t)
+
+        satisfied, msg = self._check_newest_obs(t)
+        if not satisfied:
+            self.ts_updated.append(t)
+            self.log.write(f't = {t:6d}, CBC pre opt: {msg}')
+
+    def select(self, t: int) -> tuple[np.ndarray, float]:
+        return self.X_init, self.eta