admin/wiki
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

auto-sync: 2026-04-19 14:30:01

Browse Source
This commit is contained in:
Stream
2026-04-19 14:30:01 +03:00
parent 81be6ea8c1
commit 1f59504bbb
1 changed files with 5 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
tasks/flightradar24/db/init/002_schema.sql
View File

@@ -16,7 +16,7 @@ CREATE TABLE IF NOT EXISTS fr24.captures (
); );
CREATE TABLE IF NOT EXISTS fr24.raw_packets ( CREATE TABLE IF NOT EXISTS fr24.raw_packets (
raw_packet_id BIGSERIAL PRIMARY KEY, raw_packet_id BIGINT GENERATED ALWAYS AS IDENTITY,
capture_id UUID NOT NULL REFERENCES fr24.captures(capture_id) ON DELETE CASCADE, capture_id UUID NOT NULL REFERENCES fr24.captures(capture_id) ON DELETE CASCADE,
observed_at TIMESTAMPTZ NOT NULL, observed_at TIMESTAMPTZ NOT NULL,
partition_date DATE NOT NULL DEFAULT (CURRENT_DATE), partition_date DATE NOT NULL DEFAULT (CURRENT_DATE),
@@ -28,7 +28,8 @@ CREATE TABLE IF NOT EXISTS fr24.raw_packets (
payload_bytes INTEGER, payload_bytes INTEGER,
decoded_format TEXT, decoded_format TEXT,
message_type TEXT, message_type TEXT,
created_at TIMESTAMPTZ NOT NULL DEFAULT now() created_at TIMESTAMPTZ NOT NULL DEFAULT now(),
PRIMARY KEY (raw_packet_id, partition_date)
) PARTITION BY RANGE (partition_date); ) PARTITION BY RANGE (partition_date);
CREATE TABLE IF NOT EXISTS fr24.raw_packets_default CREATE TABLE IF NOT EXISTS fr24.raw_packets_default
@@ -89,7 +90,8 @@ CREATE TABLE IF NOT EXISTS fr24.track_points (
ground_speed_kt NUMERIC(10,2), ground_speed_kt NUMERIC(10,2),
vertical_rate_fpm NUMERIC(10,2), vertical_rate_fpm NUMERIC(10,2),
heading_deg NUMERIC(10,2), heading_deg NUMERIC(10,2),
source_packet_id BIGINT REFERENCES fr24.raw_packets(raw_packet_id) ON DELETE SET NULL, source_packet_id BIGINT,
source_partition_date DATE,
created_at TIMESTAMPTZ NOT NULL DEFAULT now(), created_at TIMESTAMPTZ NOT NULL DEFAULT now(),
UNIQUE (track_id, point_order) UNIQUE (track_id, point_order)
); );