保存来自UDP流的每第n个数据包

Question

我正在解析从无人机发送到UDP端口的MPEG-TS视频流中嵌入的KLV数据，以便在实时地图中使用。我目前每秒收到25个数据包(与视频帧速率相关)，可以保存所有这些数据，但我希望每秒只保存一次数据。每40毫秒就太多了。我尝试使用线程来运行两个函数。一个用于获取数据并写入全局变量，另一个用于每秒读取该变量并打印/保存。

#setup code (UDP socket etc)

#global variable for KLV metadata
metadata = {}

#Function to parse KLV data from UDP Stream using klvdata module
def getData():
    while True:
        data, address = sock.recvfrom(2048)
        for packet in klvdata.StreamParser(data):
            global metadata
            metadata=packet.MetadataList()
           
           
#Prints selected keys at 1 sec intervals. Add more keys as required           
def printData():
     while True:
        global metadata
        time.sleep(1)
        
        long = round(float(metadata[14][3]),6)
        print(f"Sensor Longitude: {long}")
        
        lat = round(float(metadata[13][3]),6)
        print(f"Sensor Latitude: {lat}")



if __name__ == '__main__':
    t1 = Thread(target=getData)
    t1.start()
            
    t2 = Thread(target=printData)
    t2.start()

这件事的结果好坏参半。如果UDP流没有运行，我会得到一个关键错误，因为无论有没有新数据，dict都是空的，printData函数中的while循环是无限的。我理解这两个错误以及它们发生的原因。我想知道的是，有没有比我现在走的这条路更好的方法。

谢谢

Answer 1

到目前为止，这段代码工作正常，但我将测试更多。

#global variable for KLV metadata
metadata = None

#Function to parse KLV data from UDP Stream using klvdata module
def getData():
    global metadata
    while True:
        data, address = sock.recvfrom(2048)
        for packet in klvdata.StreamParser(data):
            metadata=packet.MetadataList()
           
           
           
#Prints selected keys at 1 sec intervals. Add more keys as required           
def printData():
    global metadata
    while True:
        time.sleep(1)
        if metadata is not None:
            long = round(float(metadata[14][3]),6)
            print(f"Sensor Longitude: {long}")
        
            lat = round(float(metadata[13][3]),6)
            print(f"Sensor Latitude: {lat}")

            metadata = None

Answer 2

我不能测试它，但我会使用metadata = None和if metadata is not None:来控制是否有新的数据。

metadata = None

def getData():
    global metadata # need it because you assign value to variable
    
    while True:
        data, address = sock.recvfrom(2048)
        for packet in klvdata.StreamParser(data):
            metadata = packet.MetadataList()            
        # end of data
        metadata = None            
           
def printData():
    #global metadata # no need it when you only read data from variable
    
    while True:
        time.sleep(1)

        if metadata is not None:         
            long = round(float(metadata[14][3]), 6)
            print(f"Sensor Longitude: {long}")
        
            lat = round(float(metadata[13][3]), 6)
            print(f"Sensor Latitude: {lat}")

但我不确定这是否不需要锁定metadata，因为一个进程可能会读取long，lat，而其他进程可能会访问metadata = None，这可能会造成问题。