xan/nexrad-archive
xan/nexrad-archive
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Compare commits

base: xan:9badc86e331869efff4e17ee8c9a166c3fd8b1e9
Branches Tags
xan:main
...
compare: xan:b1401a86c8b2d7af84536c15a2df66260da26aeb
Branches Tags
xan:main

2 commits
9badc86e33 ... b1401a86c8

Author SHA1 Message Date
XANTRONIX Industrial
b1401a86c8 Set AFOS message WFO from product/wfo string 2025-02-21 17:17:05 -05:00
XANTRONIX Industrial
902ef26af3 Actually make 'call' primary key for nexrad_radar 2025-02-21 17:16:42 -05:00
2 changed files with 4 additions and 4 deletions
Show stats Expand all files Collapse all files

6
db/nexrad.sql
View file

@ -4,7 +4,7 @@ select InitSpatialMetadata(1);
begin transaction; begin transaction;
create table nexrad_wfo ( create table nexrad_wfo (
code TEXT NOT NULL, code TEXT PRIMARY KEY NOT NULL,
city TEXT NOT NULL, city TEXT NOT NULL,
state TEXT NOT NULL, state TEXT NOT NULL,
address TEXT NOT NULL address TEXT NOT NULL
@ -15,9 +15,9 @@ select
CreateSpatialIndex('nexrad_wfo', 'coord'); CreateSpatialIndex('nexrad_wfo', 'coord');
create table nexrad_radar ( create table nexrad_radar (
wban INTEGER, call TEXT PRIMARY KEY NOT NULL,
call TEXT NOT NULL,
name TEXT NOT NULL, name TEXT NOT NULL,
wban INTEGER,
site_elevation FLOAT NOT NULL, site_elevation FLOAT NOT NULL,
tower_height FLOAT NOT NULL tower_height FLOAT NOT NULL
); );

2
lib/nexrad/afos.py
View file

@ -217,7 +217,6 @@ class AFOSMessageParser():
self.message.vtec_end = vtec.timestamp_end self.message.vtec_end = vtec.timestamp_end
self.message.vtec_type = vtec.typeof self.message.vtec_type = vtec.typeof
self.message.actions = vtec.actions self.message.actions = vtec.actions
self.message.wfo = vtec.wfo
self.message.phenom = vtec.phenom self.message.phenom = vtec.phenom
self.message.sig = vtec.sig self.message.sig = vtec.sig
self.message.etn = vtec.etn self.message.etn = vtec.etn
@ -250,6 +249,7 @@ class AFOSMessageParser():
if match is not None: if match is not None:
self.message.product = match['product'] self.message.product = match['product']
self.message.wfo = match['wfo']
self.state = AFOSMessageParserState.BODY self.state = AFOSMessageParserState.BODY
def parse_body(self, line: str): def parse_body(self, line: str):