Converter capacity

src/cimsparql/data_models.py

@@ -3,9 +3,9 @@
 import datetime as dt
 from typing import Self
 
 import pandera as pa
 from pandera.api.pandas.model_config import BaseConfig
 from pandera.typing import DataFrame, Index, Series
 
 
 class CoercingSchema(pa.DataFrameModel):
@@ -163,6 +163,7 @@
 class ConvertersSchema(NamedResourceSchema):
     alias: Series[str] = pa.Field(nullable=True)
     substation_mrid: Series[str] = pa.Field()
+    pole: Series[str] = pa.Field()
     status: Series[bool] = pa.Field()
     node: Series[str] = pa.Field()
     p: Series[float] = pa.Field()
@@ -176,6 +177,7 @@
     loss2: Series[float] = pa.Field()
     vdcn: Series[float] = pa.Field()
     un: Series[float] = pa.Field()
+    capacity: Series[float] = pa.Field()
 
 
 ConvertersDataFrame = DataFrame[ConvertersSchema]

src/cimsparql/sparql/converters.sparql

@@ -3,27 +3,34 @@ PREFIX cim:<${cim}>
 PREFIX xsd:<${xsd}>
 PREFIX SN:<${SN}>
 PREFIX ALG:<${ALG}>
-select ?mrid ?name ?alias ?p ?q ?substation_mrid ?status ?node ?connectivity_node ?controller ?controller_factor ?pole_loss ?loss0 ?loss1 ?loss2 ?vdcn ?un
+select ?mrid ?name ?alias ?p ?q ?substation_mrid (?pole_mrid as ?pole) ?status ?node ?connectivity_node ?controller ?controller_factor ?pole_loss ?loss0 ?loss1 ?loss2 ?vdcn ?un ?capacity
 where {
   {
     select * where {
       ?_eq_subject <http://entsoe.eu/CIM/EquipmentCore/3/1> ?eq_repo .
       service ?eq_repo {
-        # Extract mrid, name, substation and optionally aliasName of the converter
+        # Extract converter data
         ?converter cim:IdentifiedObject.mRID ?mrid;
-                  cim:IdentifiedObject.name ?name;
-		  ALG:VoltageSourceConverter.DCPole|ALG:DCConverter.DCPole ?pole.
+                   cim:IdentifiedObject.name ?name;
+                   ALG:VoltageSourceConverter.DCPole|ALG:DCConverter.DCPole ?_pole;
+                   ALG:VoltageSourceConverter.DCPole/cim:IdentifiedObject.mRID|ALG:DCConverter.DCPole/cim:IdentifiedObject.mRID ?pole_mrid;
+                   ALG:VoltageSourceConverter.bridgeNominalVoltage|ALG:DCConverter.bridgeNominalVoltage ?ur;
+                   ALG:VoltageSourceConverter.ratedIAC|ALG:DCConverter.currentRating ?ir.
 
-        ?pole ALG:DCPole.DCController/cim:IdentifiedObject.mRID ?controller.
+        ?_pole ALG:DCPole.DCController/cim:IdentifiedObject.mRID ?controller.
 	{
-	  select ?pole (max(xsd:float(str(?controller_factor))) / count(*) as ?controller_factor)
+	  select ?_pole (max(xsd:float(str(?controller_factor))) / count(*) as ?controller_factor)
 	  {
-	    ?converter ALG:VoltageSourceConverter.DCPole|ALG:DCConverter.DCPole ?pole.
-            ?pole ALG:DCPole.participationFactor ?controller_factor.
-	  } group by ?pole
+	    ?converter ALG:VoltageSourceConverter.DCPole|ALG:DCConverter.DCPole ?_pole.
+            ?_pole ALG:DCPole.participationFactor ?controller_factor.
+	  } group by ?_pole
 	}
 
-        optional {?converter cim:IdentifiedObject.aliasName ?alias .}
+        optional{
+          ?converter cim:IdentifiedObject.aliasName ?alias ;
+                     ALG:VoltageSourceConverter.bridges ?bridges
+        }
+
         # Extract properties for the terminals for the converter
         ?terminal cim:Terminal.ConductingEquipment ?converter;
                   cim:Terminal.ConnectivityNode ?con_node;
@@ -39,14 +46,15 @@ where {
           ?converter ALG:VoltageSourceConverter.loss0 ?_loss0;
                      ALG:VoltageSourceConverter.loss1 ?_loss1;
 		     ALG:VoltageSourceConverter.loss2 ?_loss2.
-	  ?pole cim:ConductingEquipment.BaseVoltage/cim:BaseVoltage.nominalVoltage ?_vdcn;
+	  ?_pole cim:ConductingEquipment.BaseVoltage/cim:BaseVoltage.nominalVoltage ?_vdcn;
 	}
-        bind(coalesce(?_analysis_enabled, True) as ?analysis_enabled)
+	bind(coalesce(?_analysis_enabled, True) as ?analysis_enabled)
 	bind(coalesce(?_loss0, 0.0) as ?loss0)
 	bind(coalesce(?_loss1, 0.0) as ?loss1)
 	bind(coalesce(?_loss2, 0.0) as ?loss2)
 	bind(coalesce(?_vdcn, 0.0) as ?vdcn)
-        filter(?analysis_enabled)
+	bind((xsd:float(?ir) * xsd:float(?ur) * xsd:float(coalesce(?bridges, 1))/1000) as ?capacity)
+	filter(?analysis_enabled)
       }
     }
   }