Skip to content

Optimize phenomenonTime aggregation in update_datastream_phenomenon_time_from_foi #180

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
Prinxeeee wants to merge 1 commit into
base: main
Choose a base branch
from
Open

Optimize phenomenonTime aggregation in update_datastream_phenomenon_time_from_foi #180

Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
27 changes: 8 additions & 19 deletions api/app/v1/endpoints/delete/functions.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -126,32 +126,21 @@ async def update_datastream_phenomenon_time(
async def update_datastream_phenomenon_time_from_foi(connection, ds_id):
async with connection.transaction():
query = """
WITH first_asc AS (
SELECT "phenomenonTime"
FROM sensorthings."Observation"
WHERE "datastream_id" = $1
ORDER BY "phenomenonTime" ASC
LIMIT 1
),
first_desc AS (
SELECT "phenomenonTime"
WITH bounds AS (
SELECT
MIN(lower("phenomenonTime")) AS new_lower,
MAX(upper("phenomenonTime")) AS new_upper
FROM sensorthings."Observation"
WHERE "datastream_id" = $1
ORDER BY "phenomenonTime" DESC
LIMIT 1
)
UPDATE sensorthings."Datastream"
SET "phenomenonTime" =
SET "phenomenonTime" =
CASE
WHEN (SELECT "phenomenonTime" FROM first_asc) IS NOT NULL
AND (SELECT "phenomenonTime" FROM first_desc) IS NOT NULL
THEN tstzrange(
(SELECT lower("phenomenonTime") FROM first_asc),
(SELECT upper("phenomenonTime") FROM first_desc),
'[]'
)
WHEN bounds.new_lower IS NOT NULL AND bounds.new_upper IS NOT NULL
THEN tstzrange(bounds.new_lower, bounds.new_upper, '[]')
ELSE NULL
END
FROM bounds
WHERE "id" = $1;
"""
await connection.execute(query, ds_id)