从UDP流中每隔第n个数据包保存一次

Question

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

#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，这可能会产生问题。