Get resampled data

documentation/api/change_log.rst

@@ -6,6 +6,11 @@ API change log
 .. note:: The FlexMeasures API follows its own versioning scheme. This is also reflected in the URL, allowing developers to upgrade at their own pace.
 
 
+v3.0-2 | 2022-07-08
+"""""""""""""""""""
+
+- Introduced the "resolution" field to `/sensors/data` (GET) to obtain data in a given resolution.
+
 v3.0-1 | 2022-05-08
 """""""""""""""""""
 

documentation/changelog.rst

@@ -10,6 +10,7 @@ New features
 * Individual sensor charts show available annotations [see `PR #428 <http://www.github.com/FlexMeasures/flexmeasures/pull/428>`_]
 * Collapsible sidepanel (hover/swipe) used for date selection on sensor charts, and various styling improvements [see `PR #447 <http://www.github.com/FlexMeasures/flexmeasures/pull/447>`_]
 * Switched from 12-hour AM/PM to 24-hour clock notation for time series chart axis labels [see `PR #446 <http://www.github.com/FlexMeasures/flexmeasures/pull/446>`_]
+* Get data in a given resolution [see `PR #458 <http://www.github.com/FlexMeasures/flexmeasures/pull/458>`_]
 
 Bugfixes
 -----------

flexmeasures/api/common/schemas/sensor_data.py

@@ -97,6 +97,8 @@ def check_schema_unit_against_sensor_unit(self, data, **kwargs):
 
 class GetSensorDataSchema(SensorDataDescriptionSchema):
 
+    resolution = DurationField(required=False)
+
     # Optional field that can be used for extra validation
     type = fields.Str(
         required=False,
@@ -141,12 +143,14 @@ def dump_bdf(self, sensor_data_description: dict, **kwargs) -> dict:
         - converts to a single deterministic belief per event
         - ensures the response respects the requested time frame
         - converts values to the requested unit
+        - converts values to the requested resolution
         """
         sensor: Sensor = sensor_data_description["sensor"]
         start = sensor_data_description["start"]
         duration = sensor_data_description["duration"]
         end = sensor_data_description["start"] + duration
         unit = sensor_data_description["unit"]
+        resolution = sensor_data_description.get("resolution")
 
         # Post-load configuration of belief timing against message type
         horizons_at_least = sensor_data_description.get("horizon", None)
@@ -169,13 +173,14 @@ def dump_bdf(self, sensor_data_description: dict, **kwargs) -> dict:
                 horizons_at_most=horizons_at_most,
                 beliefs_before=sensor_data_description.get("prior", None),
                 one_deterministic_belief_per_event=True,
+                resolution=resolution,
                 as_json=False,
             )
         )
 
         # Convert to desired time range
         index = pd.date_range(
-            start=start, end=end, freq=sensor.event_resolution, closed="left"
+            start=start, end=end, freq=df.event_resolution, closed="left"
         )
         df = df.reindex(index)
 

flexmeasures/api/common/schemas/tests/test_sensor_data_schema.py

@@ -1,13 +1,38 @@
+from datetime import timedelta
 import pytest
 
 from marshmallow import ValidationError
 
 from flexmeasures.api.common.schemas.sensor_data import (
     SingleValueField,
     PostSensorDataSchema,
+    GetSensorDataSchema,
 )
 
 
+@pytest.mark.parametrize(
+    "deserialization_input, exp_deserialization_output",
+    [
+        (
+            "PT1H",
+            timedelta(hours=1),
+        ),
+        (
+            "PT15M",
+            timedelta(minutes=15),
+        ),
+    ],
+)
+def test_resolution_field_deserialization(
+    deserialization_input,
+    exp_deserialization_output,
+):
+    """Testing straightforward cases"""
+    vf = GetSensorDataSchema._declared_fields["resolution"]
+    deser = vf.deserialize(deserialization_input)
+    assert deser == exp_deserialization_output
+
+
 @pytest.mark.parametrize(
     "deserialization_input, exp_deserialization_output",
     [

flexmeasures/api/dev/sensors.py

@@ -10,7 +10,7 @@
 from flexmeasures.auth.policy import ADMIN_ROLE, ADMIN_READER_ROLE
 from flexmeasures.auth.decorators import permission_required_for_context
 from flexmeasures.data.schemas.sensors import SensorIdField
-from flexmeasures.data.schemas.times import AwareDateTimeField
+from flexmeasures.data.schemas.times import AwareDateTimeField, DurationField
 from flexmeasures.data.models.time_series import Sensor
 from flexmeasures.data.services.annotations import prepare_annotations_for_chart
 
@@ -63,6 +63,7 @@ def get_chart(self, id: int, sensor: Sensor, **kwargs):
             "event_ends_before": AwareDateTimeField(format="iso", required=False),
             "beliefs_after": AwareDateTimeField(format="iso", required=False),
             "beliefs_before": AwareDateTimeField(format="iso", required=False),
+            "resolution": DurationField(required=False),
         },
         location="query",
     )

flexmeasures/api/v3_0/sensors.py

@@ -173,6 +173,7 @@ def get_data(self, response: dict):
                 "sensor": "ea1.2021-01.io.flexmeasures:fm1.1",
                 "start": "2021-06-07T00:00:00+02:00",
                 "duration": "PT1H",
+                "resolution": "PT15M",
                 "unit": "m³/h"
             }
 

flexmeasures/data/models/time_series.py

@@ -292,6 +292,7 @@ def search_beliefs(
         most_recent_events_only: bool = False,
         most_recent_only: bool = None,  # deprecated
         one_deterministic_belief_per_event: bool = False,
+        resolution: Union[str, timedelta] = None,
         as_json: bool = False,
     ) -> Union[tb.BeliefsDataFrame, str]:
         """Search all beliefs about events for this sensor.
@@ -331,6 +332,7 @@ def search_beliefs(
             most_recent_beliefs_only=most_recent_beliefs_only,
             most_recent_events_only=most_recent_events_only,
             one_deterministic_belief_per_event=one_deterministic_belief_per_event,
+            resolution=resolution,
         )
         if as_json:
             df = bdf.reset_index()