spacecruft
/
satnogs-db
1
0
Fork 0
Code Releases Activity

Allow decode_data to take arguments

merge-requests/176/head
Nikos Roussos 2017-05-14 15:22:48 +03:00
parent 3102dd0662
commit cd1ac73845
No known key found for this signature in database
GPG Key ID: BADFF1767BA7C8E1
1 changed files with 31 additions and 20 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

51
db/base/management/commands/decode_data.py
View File

@ -6,27 +6,38 @@ from db.base.models import Satellite, Telemetry, DemodData
class Command(BaseCommand):
help = 'Decode Satellite data'
def add_arguments(self, parser):
# Positional arguments
parser.add_argument('satellite_identifiers',
nargs='+',
metavar='<Satellite Identifier>')
def handle(self, *args, **options):
satellites = Satellite.objects.all()
for satellite in satellites:
if satellite.has_telemetry_decoders:
data = DemodData.objects.filter(satellite=satellite).filter(payload_decoded='')
telemetry_decoders = Telemetry.objects.filter(satellite=satellite)
for item in options['satellite_identifiers']:
satellites = Satellite.objects.all()
for satellite in satellites:
if satellite.has_telemetry_decoders:
data = DemodData.objects.filter(satellite=satellite).filter(payload_decoded='')
telemetry_decoders = Telemetry.objects.filter(satellite=satellite)
for obj in data:
for option in telemetry_decoders:
decoder_module = 'db.base.decoders.{0}'.format(option.decoder)
decoder = __import__(decoder_module, fromlist='.')
for obj in data:
for option in telemetry_decoders:
decoder_module = 'db.base.decoders.{0}'.format(option.decoder)
decoder = __import__(decoder_module, fromlist='.')
with open(obj.payload_frame.path) as fp:
frame = fp.read()
with open(obj.payload_frame.path) as fp:
frame = fp.read()
try:
payload_decoded = decoder.decode_payload(frame, obj.data_id,
obj.timestamp)
except:
continue
obj.payload_decoded = payload_decoded
obj.payload_telemetry = option
obj.save()
try:
payload_decoded = decoder.decode_payload(frame, obj.timestamp,
obj.data_id)
except ValueError:
obj.payload_decoded = ''
obj.payload_telemetry = None
obj.save()
continue
else:
obj.payload_decoded = payload_decoded
obj.payload_telemetry = option
obj.save()
break