, работающий с данными NMEA, отправленными по URL/IP

Question

У меня есть куча устройств, отправляющих предложения NMEA на URL/ip. , которые выглядят как этот

"$ GPGGA, 200130.0,3447.854659, N, 11014.636735, W, 1,11,0.8,41.4, M, -24.0, М ,, * 53"

я хочу прочитать эти данные, проанализировать его и загрузить ключевые части в базу данных. я знаю, как его разобрать и загрузить в БД, но я полностью потеряю, как «читать»/принимать/получать данные в программу python, чтобы я мог анализировать и загружать.

Моя первая мысль состояла в том, чтобы указать его на страницу Django, а затем Djanog разобрать его и загрузить в базу данных (данные будут доступны с сайта Django), но это предложение NMEA не HTTP-запрос, поэтому Django отклоняет его как " сообщение Синтаксис синтаксического запроса "

Какой лучший (питон) способ читать предложения NMEA, отправленные на URL-адрес/IP?

благодаря

Answer 1

Я предполагаю, что у вас есть некоторое оборудование, которое имеет соединение локальных сетей, и это трубы из строковой NMEA через его соединение локальных сетей. Это, вероятно, по умолчанию имеет некоторые случайные 192.168.0.X IP-адрес и выплевывая данных через порт 12002 или что-то

вы обычно создают сокет для прослушивания этого Incomming данных

server.py

import socket 
host = "" #Localhost 
port = 12002 
PACKET_SIZE=1024 # how many characters to read at a time 
sock = socket.socket(socket.AF_INET,socket.SOCK_STREAM) 
sock.bind((host,port)) 
sock.listen(5) # we should never have more than one client 
def work_thread(client): 
    while True: #continuously read and handle data 
     data = client.recv(PACKET_SIZE) 
     if not data: 
      break # done with this client 
     processData(data) 

while True: 
    client,addr = sock.accept() # your script will block here waiting for a connection 
    t = threading.Thread(target=work_thread,args=(client,)) 
    t.start() 

иногда однако вы должны пинговать устройство, чтобы получить данные

client.py

import socket 
host = "192.168.0.204" #Device IP 
port = 12002 
PACKET_SIZE=1024 # how many characters to read at a time 
sock = socket.socket(socket.AF_INET,socket.SOCK_STREAM) 
sock.connect((host,port)) #connect to the device 
while True: #continuously read and handle data 
    data = sock.recv(PACKET_SIZE) 
    processData(data)