kopia lustrzana https://github.com/glidernet/ogn-python
Fabian P. Schmidt
rodzic
5a76a33497
commit
6cb9dd7801
|
|
@ -0,0 +1,13 @@
|
|||
#!/usr/bin/env python
|
||||
|
||||
from manager import Manager
|
||||
from ogn.commands import manager as command_manager
|
||||
from ogn.gateway.manage import manager as gateway_manager
|
||||
|
||||
manager = Manager()
|
||||
manager.merge(command_manager)
|
||||
manager.merge(gateway_manager, namespace='gateway')
|
||||
|
||||
|
||||
if __name__ == '__main__':
|
||||
manager.main()
|
||||
|
|
@ -0,0 +1,11 @@
|
|||
from .database import manager as database_manager
|
||||
from .showreceiver import manager as show_receiver_manager
|
||||
from .logbook import manager as logbook_manager
|
||||
|
||||
from manager import Manager
|
||||
|
||||
manager = Manager()
|
||||
|
||||
manager.merge(database_manager, namespace='db')
|
||||
manager.merge(show_receiver_manager, namespace='show.receiver')
|
||||
manager.merge(logbook_manager, namespace='logbook')
|
||||
|
|
@ -0,0 +1,13 @@
|
|||
from ogn.model import Base
|
||||
|
||||
from manager import Manager
|
||||
manager = Manager()
|
||||
|
||||
from ogn.collect.fetchddb import update_ddb_data
|
||||
|
||||
@manager.command
|
||||
def init():
|
||||
"""Initialize the database."""
|
||||
from dbutils import engine
|
||||
Base.metadata.create_all(engine)
|
||||
print("Done.")
|
||||
|
|
@ -0,0 +1,6 @@
|
|||
from sqlalchemy import create_engine
|
||||
from sqlalchemy.orm import sessionmaker
|
||||
engine = create_engine('sqlite:///beacons.db', echo=False)
|
||||
|
||||
Session = sessionmaker(bind=engine)
|
||||
session = Session()
|
||||
|
|
@ -0,0 +1,91 @@
|
|||
# -*- coding: utf-8 -*-
|
||||
|
||||
from datetime import datetime, timedelta
|
||||
|
||||
from sqlalchemy.sql import func, null
|
||||
from sqlalchemy import and_, or_, insert, between
|
||||
from sqlalchemy.sql.expression import case, true, false, label
|
||||
|
||||
from ogn.model import Flarm, AircraftBeacon, TakeoffLanding
|
||||
|
||||
from dbutils import session
|
||||
|
||||
from manager import Manager
|
||||
manager = Manager()
|
||||
|
||||
@manager.command
|
||||
def show(airport_name, latitude, longitude, altitude):
|
||||
"""Show a logbook for <airport_name> located at given position."""
|
||||
latitude = float(latitude)
|
||||
longitude = float(longitude)
|
||||
altitude = float(altitude)
|
||||
# get_logbook('Königsdorf', 47.83, 11.46, 601)
|
||||
latmin = latitude - 0.15
|
||||
latmax = latitude + 0.15
|
||||
lonmin = longitude - 0.15
|
||||
lonmax = longitude + 0.15
|
||||
max_altitude = altitude + 200
|
||||
|
||||
# make a query with current, previous and next "takeoff_landing" event, so we can find complete flights
|
||||
sq = session.query(TakeoffLanding.address,
|
||||
func.lag(TakeoffLanding.address).over(order_by=and_(func.date(TakeoffLanding.timestamp), TakeoffLanding.address, TakeoffLanding.timestamp)).label('address_prev'),
|
||||
func.lead(TakeoffLanding.address).over(order_by=and_(func.date(TakeoffLanding.timestamp), TakeoffLanding.address, TakeoffLanding.timestamp)).label('address_next'),
|
||||
TakeoffLanding.timestamp,
|
||||
func.lag(TakeoffLanding.timestamp).over(order_by=and_(func.date(TakeoffLanding.timestamp), TakeoffLanding.address, TakeoffLanding.timestamp)).label('timestamp_prev'),
|
||||
func.lead(TakeoffLanding.timestamp).over(order_by=and_(func.date(TakeoffLanding.timestamp), TakeoffLanding.address, TakeoffLanding.timestamp)).label('timestamp_next'),
|
||||
TakeoffLanding.track,
|
||||
func.lag(TakeoffLanding.track).over(order_by=and_(func.date(TakeoffLanding.timestamp), TakeoffLanding.address, TakeoffLanding.timestamp)).label('track_prev'),
|
||||
func.lead(TakeoffLanding.track).over(order_by=and_(func.date(TakeoffLanding.timestamp), TakeoffLanding.address, TakeoffLanding.timestamp)).label('track_next'),
|
||||
TakeoffLanding.is_takeoff,
|
||||
func.lag(TakeoffLanding.is_takeoff).over(order_by=and_(func.date(TakeoffLanding.timestamp), TakeoffLanding.address, TakeoffLanding.timestamp)).label('is_takeoff_prev'),
|
||||
func.lead(TakeoffLanding.is_takeoff).over(order_by=and_(func.date(TakeoffLanding.timestamp), TakeoffLanding.address, TakeoffLanding.timestamp)).label('is_takeoff_next')) \
|
||||
.filter(and_(between(TakeoffLanding.latitude, latmin, latmax), between(TakeoffLanding.longitude, lonmin, lonmax))) \
|
||||
.filter(TakeoffLanding.altitude < max_altitude) \
|
||||
.subquery()
|
||||
|
||||
# find complete flights (with takeoff and landing) with duration < 1 day
|
||||
complete_flight_query = session.query(sq.c.timestamp.label('reftime'), sq.c.address.label('address'), sq.c.timestamp.label('takeoff'), sq.c.track.label('takeoff_track'), sq.c.timestamp_next.label('landing'), sq.c.track_next.label('landing_track'), label('duration', sq.c.timestamp_next - sq.c.timestamp)) \
|
||||
.filter(and_(sq.c.is_takeoff == true(), sq.c.is_takeoff_next == false())) \
|
||||
.filter(sq.c.address == sq.c.address_next) \
|
||||
.filter(sq.c.timestamp_next - sq.c.timestamp < timedelta(days=1))
|
||||
|
||||
# split complete flights (with takeoff and landing) with duration > 1 day into one takeoff and one landing
|
||||
split_start_query = session.query(sq.c.timestamp.label('reftime'), sq.c.address.label('address'), sq.c.timestamp.label('takeoff'), sq.c.track.label('takeoff_track'), null().label('landing'), null().label('landing_track'), null().label('duration')) \
|
||||
.filter(and_(sq.c.is_takeoff == true(), sq.c.is_takeoff_next == false())) \
|
||||
.filter(sq.c.address == sq.c.address_next) \
|
||||
.filter(sq.c.timestamp_next - sq.c.timestamp >= timedelta(days=1))
|
||||
|
||||
split_landing_query = session.query(sq.c.timestamp_next.label('reftime'), sq.c.address.label('address'), null().label('takeoff'), null().label('takeoff_track'), sq.c.timestamp_next.label('landing'), sq.c.track_next.label('landing_track'), null().label('duration')) \
|
||||
.filter(and_(sq.c.is_takeoff == true(), sq.c.is_takeoff_next == false())) \
|
||||
.filter(sq.c.address == sq.c.address_next) \
|
||||
.filter(sq.c.timestamp_next - sq.c.timestamp >= timedelta(days=1))
|
||||
|
||||
# find landings without start
|
||||
only_landings_query = session.query(sq.c.timestamp.label('reftime'), sq.c.address.label('address'), null().label('takeoff'), null().label('takeoff_track'), sq.c.timestamp.label('landing'), sq.c.track_next.label('landing_track'), null().label('duration')) \
|
||||
.filter(sq.c.is_takeoff == false()) \
|
||||
.filter(or_(sq.c.address != sq.c.address_prev,
|
||||
sq.c.is_takeoff_prev == false()))
|
||||
|
||||
# find starts without landing
|
||||
only_starts_query = session.query(sq.c.timestamp.label('reftime'), sq.c.address.label('address'), sq.c.timestamp.label('takeoff'), sq.c.track.label('takeoff_track'), null().label('landing'), null().label('landing_track'), null().label('duration')) \
|
||||
.filter(sq.c.is_takeoff == true()) \
|
||||
.filter(or_(sq.c.address != sq.c.address_next,
|
||||
sq.c.is_takeoff_next == true()))
|
||||
|
||||
# unite all
|
||||
union_query = complete_flight_query.union(split_start_query, split_landing_query, only_landings_query, only_starts_query) \
|
||||
.subquery()
|
||||
|
||||
# get aircraft informations and sort all entries by the reference time
|
||||
logbook_query = session.query(union_query.c.reftime, union_query.c.address, union_query.c.takeoff, union_query.c.takeoff_track, union_query.c.landing, union_query.c.landing_track, union_query.c.duration, Flarm.registration, Flarm.aircraft) \
|
||||
.outerjoin(Flarm, union_query.c.address == Flarm.address) \
|
||||
.order_by(union_query.c.reftime)
|
||||
|
||||
print('--- Logbook (' + airport_name + ') ---')
|
||||
none_datetime_replacer = lambda datetime_object: '--:--:--' if datetime_object is None else datetime_object.time()
|
||||
none_track_replacer = lambda track_object: '--' if track_object is None else round(track_object/10.0)
|
||||
none_timedelta_replacer = lambda timedelta_object: '--:--:--' if timedelta_object is None else timedelta_object
|
||||
none_registration_replacer = lambda registration_object, address: '[' + address + ']' if registration_object is None else registration_object
|
||||
none_aircraft_replacer = lambda aircraft_object: '(unknown)' if aircraft_object is None else aircraft_object
|
||||
for [reftime, address, takeoff, takeoff_track, landing, landing_track, duration, registration, aircraft] in logbook_query.all():
|
||||
print('%10s %8s (%2s) %8s (%2s) %8s %8s %s' % (reftime.date(), none_datetime_replacer(takeoff), none_track_replacer(takeoff_track), none_datetime_replacer(landing), none_track_replacer(landing_track), none_timedelta_replacer(duration), none_registration_replacer(registration, address), none_aircraft_replacer(aircraft)))
|
||||
|
|
@ -3,14 +3,19 @@ from datetime import datetime, timedelta
|
|||
from sqlalchemy.sql import func
|
||||
from sqlalchemy import distinct, and_
|
||||
|
||||
from ogn.db import session
|
||||
from ogn.model import ReceiverBeacon
|
||||
|
||||
from dbutils import session
|
||||
|
||||
back_24h = datetime.utcnow() - timedelta(days=1)
|
||||
receiver_messages_per_24h = 24*60 / 5
|
||||
|
||||
from manager import Manager
|
||||
manager = Manager()
|
||||
|
||||
def get_receiver_info():
|
||||
@manager.command
|
||||
def list():
|
||||
"""Show a list of all receivers."""
|
||||
sq = session.query(distinct(ReceiverBeacon.name).label('name'), func.max(ReceiverBeacon.timestamp).label('lastseen'), func.count(ReceiverBeacon.name).label('messages_count')).\
|
||||
filter(ReceiverBeacon.timestamp > back_24h).\
|
||||
group_by(ReceiverBeacon.name).\
|
||||
|
|
@ -25,7 +30,9 @@ def get_receiver_info():
|
|||
print('%9s: %3d%% avail, %s, %s ' % (receiver.name, 100.0*float(messages_count/receiver_messages_per_24h), receiver.version, receiver.platform))
|
||||
|
||||
|
||||
def get_software_stats():
|
||||
@manager.command
|
||||
def software_stats():
|
||||
"""Show some statistics of receiver sotware."""
|
||||
sq = session.query(ReceiverBeacon.name, func.max(ReceiverBeacon.timestamp).label('lastseen')).\
|
||||
filter(ReceiverBeacon.timestamp > back_24h).\
|
||||
group_by(ReceiverBeacon.name).\
|
||||
|
|
@ -41,7 +48,9 @@ def get_software_stats():
|
|||
print('%5s: %s' % (version, count))
|
||||
|
||||
|
||||
def get_hardware_stats():
|
||||
@manager.command
|
||||
def hardware_stats():
|
||||
"""Show some statistics of receiver hardware."""
|
||||
sq = session.query(ReceiverBeacon.name, func.max(ReceiverBeacon.timestamp).label('lastseen')).\
|
||||
filter(ReceiverBeacon.timestamp > back_24h).\
|
||||
group_by(ReceiverBeacon.name).\
|
||||
|
|
@ -55,9 +64,3 @@ def get_hardware_stats():
|
|||
print('\n--- Platforms ---')
|
||||
for [platform, count] in platforms.all():
|
||||
print('%7s: %s' % (platform, count))
|
||||
|
||||
|
||||
if __name__ == '__main__':
|
||||
get_receiver_info()
|
||||
get_software_stats()
|
||||
get_hardware_stats()
|
||||
|
|
@ -3,11 +3,6 @@ from ogn.model import Flarm
|
|||
from ogn.ognutils import get_ddb
|
||||
|
||||
|
||||
def put_into_db(beacon):
|
||||
session.add(beacon)
|
||||
session.commit()
|
||||
|
||||
|
||||
def fill_flarm_db():
|
||||
session.query(Flarm).delete()
|
||||
|
||||
|
|
|
|||
|
|
@ -0,0 +1,70 @@
|
|||
import socket
|
||||
from time import time
|
||||
|
||||
from ogn import settings
|
||||
from ogn.commands.dbutils import session
|
||||
from ogn.aprs_parser import parse_aprs
|
||||
|
||||
from sqlalchemy import create_engine
|
||||
from sqlalchemy.orm import sessionmaker
|
||||
from ogn.model import Base
|
||||
|
||||
MODULE_VERSION = "0.1"
|
||||
|
||||
class ognGateway:
|
||||
def __init__(self):
|
||||
pass
|
||||
|
||||
def connect_db(self):
|
||||
self.session = session
|
||||
|
||||
def connect(self, aprs_user):
|
||||
if len(aprs_user) < 3 or len(aprs_user) > 9:
|
||||
print("aprs_user must be a string of 3-9 characters")
|
||||
# create socket, connect to server, login and make a file object associated with the socket
|
||||
self.sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
|
||||
self.sock.setsockopt(socket.SOL_SOCKET, socket.SO_KEEPALIVE, 1)
|
||||
self.sock.connect((settings.APRS_SERVER_HOST, settings.APRS_SERVER_PORT))
|
||||
|
||||
login = 'user %s pass %s vers ogn-gateway-python %s %s\n' % (aprs_user, settings.APRS_PASSCODE, MODULE_VERSION, settings.APRS_FILTER)
|
||||
self.sock.send(login.encode())
|
||||
self.sock_file = self.sock.makefile('rw')
|
||||
|
||||
|
||||
def run(self):
|
||||
keepalive_time = time()
|
||||
while True:
|
||||
if time()-keepalive_time > 60:
|
||||
self.sock.send("#keepalive".encode())
|
||||
keepalive_time = time()
|
||||
|
||||
# Read packet string from socket
|
||||
try:
|
||||
packet_str = self.sock_file.readline().strip()
|
||||
except socket.error:
|
||||
print('Socket error on readline')
|
||||
continue
|
||||
|
||||
# A zero length line should not be return if keepalives are being sent
|
||||
# A zero length line will only be returned after ~30m if keepalives are not sent
|
||||
if len(packet_str) == 0:
|
||||
print('Read returns zero length string. Failure. Orderly closeout')
|
||||
break
|
||||
|
||||
self.proceed_line(packet_str)
|
||||
# close everything
|
||||
print('Close socket')
|
||||
self.sock.shutdown(0)
|
||||
self.sock.close()
|
||||
|
||||
def proceed_line(self, line):
|
||||
try:
|
||||
beacon = parse_aprs(line)
|
||||
except Exception as e:
|
||||
print('Failed to parse line: %s' % line)
|
||||
print('Reason: %s' % e)
|
||||
return
|
||||
|
||||
if beacon is not None:
|
||||
self.session.add(beacon)
|
||||
self.session.commit()
|
||||
|
|
@ -0,0 +1,19 @@
|
|||
from ogn.gateway import ognGateway
|
||||
|
||||
DB_URI = 'sqlite:///beacons.db'
|
||||
|
||||
from manager import Manager
|
||||
manager = Manager()
|
||||
|
||||
@manager.command
|
||||
def run(aprs_user="anon-dev"):
|
||||
"""Run the aprs client."""
|
||||
gateway = ognGateway()
|
||||
print("Start OGN gateway")
|
||||
gateway.connect_db()
|
||||
gateway.connect(aprs_user)
|
||||
try:
|
||||
gateway.run()
|
||||
except KeyboardInterrupt:
|
||||
pass
|
||||
print("\nOGN gateway Exit")
|
||||
|
|
@ -60,80 +60,3 @@ def compute_takeoff_and_landing():
|
|||
ins = insert(TakeoffLanding).from_select((TakeoffLanding.address, TakeoffLanding.timestamp, TakeoffLanding.latitude, TakeoffLanding.longitude, TakeoffLanding.track, TakeoffLanding.ground_speed, TakeoffLanding.altitude, TakeoffLanding.is_takeoff), takeoff_landing_query)
|
||||
session.execute(ins)
|
||||
session.commit()
|
||||
|
||||
|
||||
def get_logbook(airport_name, latitude, longitude, altitude):
|
||||
latmin = latitude - 0.15
|
||||
latmax = latitude + 0.15
|
||||
lonmin = longitude - 0.15
|
||||
lonmax = longitude + 0.15
|
||||
max_altitude = altitude + 200
|
||||
|
||||
# make a query with current, previous and next "takeoff_landing" event, so we can find complete flights
|
||||
sq = session.query(TakeoffLanding.address,
|
||||
func.lag(TakeoffLanding.address).over(order_by=and_(func.date(TakeoffLanding.timestamp), TakeoffLanding.address, TakeoffLanding.timestamp)).label('address_prev'),
|
||||
func.lead(TakeoffLanding.address).over(order_by=and_(func.date(TakeoffLanding.timestamp), TakeoffLanding.address, TakeoffLanding.timestamp)).label('address_next'),
|
||||
TakeoffLanding.timestamp,
|
||||
func.lag(TakeoffLanding.timestamp).over(order_by=and_(func.date(TakeoffLanding.timestamp), TakeoffLanding.address, TakeoffLanding.timestamp)).label('timestamp_prev'),
|
||||
func.lead(TakeoffLanding.timestamp).over(order_by=and_(func.date(TakeoffLanding.timestamp), TakeoffLanding.address, TakeoffLanding.timestamp)).label('timestamp_next'),
|
||||
TakeoffLanding.track,
|
||||
func.lag(TakeoffLanding.track).over(order_by=and_(func.date(TakeoffLanding.timestamp), TakeoffLanding.address, TakeoffLanding.timestamp)).label('track_prev'),
|
||||
func.lead(TakeoffLanding.track).over(order_by=and_(func.date(TakeoffLanding.timestamp), TakeoffLanding.address, TakeoffLanding.timestamp)).label('track_next'),
|
||||
TakeoffLanding.is_takeoff,
|
||||
func.lag(TakeoffLanding.is_takeoff).over(order_by=and_(func.date(TakeoffLanding.timestamp), TakeoffLanding.address, TakeoffLanding.timestamp)).label('is_takeoff_prev'),
|
||||
func.lead(TakeoffLanding.is_takeoff).over(order_by=and_(func.date(TakeoffLanding.timestamp), TakeoffLanding.address, TakeoffLanding.timestamp)).label('is_takeoff_next')) \
|
||||
.filter(and_(between(TakeoffLanding.latitude, latmin, latmax), between(TakeoffLanding.longitude, lonmin, lonmax))) \
|
||||
.filter(TakeoffLanding.altitude < max_altitude) \
|
||||
.subquery()
|
||||
|
||||
# find complete flights (with takeoff and landing) with duration < 1 day
|
||||
complete_flight_query = session.query(sq.c.timestamp.label('reftime'), sq.c.address.label('address'), sq.c.timestamp.label('takeoff'), sq.c.track.label('takeoff_track'), sq.c.timestamp_next.label('landing'), sq.c.track_next.label('landing_track'), label('duration', sq.c.timestamp_next - sq.c.timestamp)) \
|
||||
.filter(and_(sq.c.is_takeoff == true(), sq.c.is_takeoff_next == false())) \
|
||||
.filter(sq.c.address == sq.c.address_next) \
|
||||
.filter(sq.c.timestamp_next - sq.c.timestamp < timedelta(days=1))
|
||||
|
||||
# split complete flights (with takeoff and landing) with duration > 1 day into one takeoff and one landing
|
||||
split_start_query = session.query(sq.c.timestamp.label('reftime'), sq.c.address.label('address'), sq.c.timestamp.label('takeoff'), sq.c.track.label('takeoff_track'), null().label('landing'), null().label('landing_track'), null().label('duration')) \
|
||||
.filter(and_(sq.c.is_takeoff == true(), sq.c.is_takeoff_next == false())) \
|
||||
.filter(sq.c.address == sq.c.address_next) \
|
||||
.filter(sq.c.timestamp_next - sq.c.timestamp >= timedelta(days=1))
|
||||
|
||||
split_landing_query = session.query(sq.c.timestamp_next.label('reftime'), sq.c.address.label('address'), null().label('takeoff'), null().label('takeoff_track'), sq.c.timestamp_next.label('landing'), sq.c.track_next.label('landing_track'), null().label('duration')) \
|
||||
.filter(and_(sq.c.is_takeoff == true(), sq.c.is_takeoff_next == false())) \
|
||||
.filter(sq.c.address == sq.c.address_next) \
|
||||
.filter(sq.c.timestamp_next - sq.c.timestamp >= timedelta(days=1))
|
||||
|
||||
# find landings without start
|
||||
only_landings_query = session.query(sq.c.timestamp.label('reftime'), sq.c.address.label('address'), null().label('takeoff'), null().label('takeoff_track'), sq.c.timestamp.label('landing'), sq.c.track_next.label('landing_track'), null().label('duration')) \
|
||||
.filter(sq.c.is_takeoff == false()) \
|
||||
.filter(or_(sq.c.address != sq.c.address_prev,
|
||||
sq.c.is_takeoff_prev == false()))
|
||||
|
||||
# find starts without landing
|
||||
only_starts_query = session.query(sq.c.timestamp.label('reftime'), sq.c.address.label('address'), sq.c.timestamp.label('takeoff'), sq.c.track.label('takeoff_track'), null().label('landing'), null().label('landing_track'), null().label('duration')) \
|
||||
.filter(sq.c.is_takeoff == true()) \
|
||||
.filter(or_(sq.c.address != sq.c.address_next,
|
||||
sq.c.is_takeoff_next == true()))
|
||||
|
||||
# unite all
|
||||
union_query = complete_flight_query.union(split_start_query, split_landing_query, only_landings_query, only_starts_query) \
|
||||
.subquery()
|
||||
|
||||
# get aircraft informations and sort all entries by the reference time
|
||||
logbook_query = session.query(union_query.c.reftime, union_query.c.address, union_query.c.takeoff, union_query.c.takeoff_track, union_query.c.landing, union_query.c.landing_track, union_query.c.duration, Flarm.registration, Flarm.aircraft) \
|
||||
.outerjoin(Flarm, union_query.c.address == Flarm.address) \
|
||||
.order_by(union_query.c.reftime)
|
||||
|
||||
print('--- Logbook (' + airport_name + ') ---')
|
||||
none_datetime_replacer = lambda datetime_object: '--:--:--' if datetime_object is None else datetime_object.time()
|
||||
none_track_replacer = lambda track_object: '--' if track_object is None else round(track_object/10.0)
|
||||
none_timedelta_replacer = lambda timedelta_object: '--:--:--' if timedelta_object is None else timedelta_object
|
||||
none_registration_replacer = lambda registration_object, address: '[' + address + ']' if registration_object is None else registration_object
|
||||
none_aircraft_replacer = lambda aircraft_object: '(unknown)' if aircraft_object is None else aircraft_object
|
||||
for [reftime, address, takeoff, takeoff_track, landing, landing_track, duration, registration, aircraft] in logbook_query.all():
|
||||
print('%10s %8s (%2s) %8s (%2s) %8s %8s %s' % (reftime.date(), none_datetime_replacer(takeoff), none_track_replacer(takeoff_track), none_datetime_replacer(landing), none_track_replacer(landing_track), none_timedelta_replacer(duration), none_registration_replacer(registration, address), none_aircraft_replacer(aircraft)))
|
||||
|
||||
if __name__ == '__main__':
|
||||
compute_takeoff_and_landing()
|
||||
get_logbook('Königsdorf', 47.83, 11.46, 601)
|
||||
|
||||
|
|
|
|||
|
|
@ -1,65 +0,0 @@
|
|||
import socket
|
||||
from time import time
|
||||
|
||||
from ogn import db_utils
|
||||
from ogn import settings
|
||||
from ogn.aprs_parser import parse_aprs
|
||||
|
||||
|
||||
def proceed():
|
||||
# create socket, connect to server, login and make a file object associated with the socket
|
||||
sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
|
||||
sock.setsockopt(socket.SOL_SOCKET, socket.SO_KEEPALIVE, 1)
|
||||
sock.connect((settings.APRS_SERVER_HOST, settings.APRS_SERVER_PORT))
|
||||
login = 'user %s pass %s vers PyGrabber 1.0 %s\n' % (settings.APRS_USER, settings.APRS_PASSCODE, settings.APRS_FILTER)
|
||||
sock.send(login.encode())
|
||||
sock_file = sock.makefile('rw')
|
||||
|
||||
keepalive_time = time()
|
||||
|
||||
try:
|
||||
while True:
|
||||
if time()-keepalive_time > 60:
|
||||
sock.send("#keepalive".encode())
|
||||
keepalive_time = time()
|
||||
|
||||
# Read packet string from socket
|
||||
try:
|
||||
packet_str = sock_file.readline().strip()
|
||||
except socket.error:
|
||||
print('Socket error on readline')
|
||||
continue
|
||||
|
||||
# A zero length line should not be return if keepalives are being sent
|
||||
# A zero length line will only be returned after ~30m if keepalives are not sent
|
||||
if len(packet_str) == 0:
|
||||
print('Read returns zero length string. Failure. Orderly closeout')
|
||||
break
|
||||
|
||||
proceed_line(packet_str)
|
||||
finally:
|
||||
# close everything
|
||||
print('Close socket')
|
||||
sock.shutdown(0)
|
||||
sock.close()
|
||||
|
||||
|
||||
def proceed_line(line):
|
||||
try:
|
||||
result = parse_aprs(line)
|
||||
except Exception as e:
|
||||
print('Failed to parse line: %s' % line)
|
||||
print('Reason: %s' % e)
|
||||
return
|
||||
|
||||
if result is not None:
|
||||
db_utils.put_into_db(result)
|
||||
|
||||
if __name__ == '__main__':
|
||||
while True:
|
||||
try:
|
||||
print("Start Python_Test")
|
||||
proceed()
|
||||
print("Python Test Exit")
|
||||
except OSError as e:
|
||||
print("OSError %s" % e)
|
||||
|
|
@ -1,6 +0,0 @@
|
|||
APRS_SERVER_HOST = 'aprs.glidernet.org'
|
||||
APRS_SERVER_PORT = 14580
|
||||
APRS_USER = 'PyGrabber'
|
||||
APRS_PASSCODE = -1 # Read only
|
||||
|
||||
APRS_FILTER = "filter r/+50.0000/+10.0000/5000"
|
||||
|
|
@ -2,3 +2,4 @@ SQLAlchemy==1.0.8
|
|||
nose==1.3.7
|
||||
coveralls==0.4.4
|
||||
geopy==1.11.0
|
||||
manage.py==0.2.10
|
||||
|
|
|
|||
Ładowanie…
Reference in New Issue