9
9
from .util import to_snake_case
10
10
11
11
__title__ = "jao-py"
12
- __version__ = "0.4.9 "
12
+ __version__ = "0.4.10 "
13
13
__author__ = "Frank Boerman"
14
14
__license__ = "MIT"
15
15
@@ -166,6 +166,35 @@ def query_monitoring(self, day: pd.Timestamp) -> List[Dict]:
166
166
return self ._query_base_day (day , 'monitoring' )
167
167
168
168
169
+ class JaoPublicationToolIntraDay (JaoPublicationToolClient ):
170
+ def __init__ (self , version ):
171
+ super ().__init__ ()
172
+ if version == 'a' :
173
+ self .BASEURL = "https://publicationtool.jao.eu/coreID/api/data/IDCCA_"
174
+ elif version == 'b' :
175
+ self .BASEURL = "https://publicationtool.jao.eu/coreID/api/data/IDCCB_"
176
+ else :
177
+ raise NotImplementedError
178
+
179
+ def query_lta (self , d_from : pd .Timestamp , d_to : pd .Timestamp ):
180
+ raise NotImplementedError
181
+
182
+ def query_status (self , d_from : pd .Timestamp , d_to : pd .Timestamp ):
183
+ raise NotImplementedError
184
+
185
+ def query_active_constraints (self , day : pd .Timestamp ):
186
+ raise NotImplementedError
187
+
188
+ def query_alpha_factor (self , d_from : pd .Timestamp , d_to : pd .Timestamp ):
189
+ raise NotImplementedError
190
+
191
+ def query_sidc_atc (self , day : pd .Timestamp ) -> List [Dict ]:
192
+ return self ._query_base_day (day , 'intradayAtc' )
193
+
194
+ def query_sidc_ntc (self , day : pd .Timestamp ) -> List [Dict ]:
195
+ return self ._query_base_day (day , 'intradayNtc' )
196
+
197
+
169
198
class JaoPublicationToolPandasClient (JaoPublicationToolClient ):
170
199
def query_final_domain (self , mtu : pd .Timestamp , presolved : bool = None , cne : str = None ,
171
200
co : str = None ) -> pd .DataFrame :
@@ -248,37 +277,10 @@ def query_monitoring(self, day: pd.Timestamp) -> pd.DataFrame:
248
277
)
249
278
250
279
251
- class JaoPublicationToolPandasIntraDay (JaoPublicationToolPandasClient ):
252
- def __init__ (self , version ):
253
- super ().__init__ ()
254
- if version == 'a' :
255
- self .BASEURL = "https://publicationtool.jao.eu/coreID/api/data/IDCCA_"
256
- elif version == 'b' :
257
- self .BASEURL = "https://publicationtool.jao.eu/coreID/api/data/IDCCB_"
258
- else :
259
- raise NotImplementedError
260
-
261
- def query_lta (self , d_from : pd .Timestamp , d_to : pd .Timestamp ):
262
- raise NotImplementedError
263
-
264
- def query_status (self , d_from : pd .Timestamp , d_to : pd .Timestamp ):
265
- raise NotImplementedError
266
-
267
- def query_active_constraints (self , day : pd .Timestamp ):
268
- raise NotImplementedError
269
-
270
- def query_alpha_factor (self , d_from : pd .Timestamp , d_to : pd .Timestamp ):
271
- raise NotImplementedError
272
-
273
- def query_sidc_atc_raw (self , day : pd .Timestamp ) -> List [Dict ]:
274
- return self ._query_base_day (day , 'intradayAtc' )
275
-
276
- def query_sidc_ntc_raw (self , day : pd .Timestamp ) -> List [Dict ]:
277
- return self ._query_base_day (day , 'intradayNtc' )
278
-
280
+ class JaoPublicationToolPandasIntraDay (JaoPublicationToolIntraDay ):
279
281
def query_sidc_atc (self , day : pd .Timestamp , from_zone : str = None , to_zone : str = None ) -> pd .DataFrame :
280
282
df = parse_base_output (
281
- self . query_sidc_atc_raw (day = day )
283
+ super (). query_sidc_atc (day = day )
282
284
).rename (columns = lambda x : x .lstrip ('border_' ).replace ('_' , '>' ))
283
285
284
286
if from_zone is not None :
@@ -291,7 +293,7 @@ def query_sidc_atc(self, day: pd.Timestamp, from_zone: str = None, to_zone: str
291
293
292
294
def query_sidc_ntc (self , day : pd .Timestamp , from_zone : str = None , to_zone : str = None ) -> pd .DataFrame :
293
295
df = parse_base_output (
294
- self . query_sidc_ntc_raw (day = day )
296
+ super (). query_sidc_ntc (day = day )
295
297
).rename (columns = lambda x : x .lstrip ('border_' ).replace ('_' , '>' ))
296
298
297
299
if from_zone is not None :
0 commit comments