如何解决保存来自 UDP 流的每第 n 个数据包
我正在解析从无人机发送到 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 func 中的 while 循环都是无限的。我理解这两个错误以及它们发生的原因。我想知道是否有比我现在走的路更好的方法来做到这一点。
谢谢
解决方法
我无法测试,但我会使用 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
这可以使问题。
这段代码目前有效,但我会测试更多。
#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 Latitude: {lat}")
metadata = None
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。