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

Compare commits

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

No commits in common. "b1401a86c8b2d7af84536c15a2df66260da26aeb" and "9badc86e331869efff4e17ee8c9a166c3fd8b1e9" have entirely different histories.
b1401a86c8 ... 9badc86e33

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 PRIMARY KEY NOT NULL, code TEXT 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 (
call TEXT PRIMARY KEY NOT NULL,
name TEXT NOT NULL,
wban INTEGER, wban INTEGER,
call TEXT NOT NULL,
name TEXT NOT NULL,
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,6 +217,7 @@ 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
@ -249,7 +250,6 @@ 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):