从 UDP 流中保存每第 n 个数据包答案

【问题标题】：Saving every nth packet from a UDP stream从 UDP 流中保存每第 n 个数据包
【发布时间】：2021-05-29 11:56:03
【问题描述】：

我正在解析从无人机发送到 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 循环是无限的，无论是否有新数据。我理解这两个错误以及它们发生的原因。我想知道是否有比我现在走的路更好的方法来做到这一点。

谢谢

【问题讨论】：

有一个很好的规则是把global放在函数的开头。您必须在文件中仅使用一次 - 您不必在 while-loop 中多次使用它
如果你得到 kye 错误，那么你可以使用try/except 来捕捉它或者使用if key in dict: 来运行代码，只有当字典中有键时。如果您有列表，那么您可以使用 if len(list) > index: 在存在时运行代码 list[index]
如果你想在没有新数据时停止写入，那么可以使用一些变量来控制它——比如if new_data is True: ... 或者使用 number 或 date_time 来控制是否有新数据。 If new_number > old_number: ... write data ... ; old_number = new_number
一开始我会使用metadata = None，然后我可以检查if metadata is not None: ... write data ...。当没有新数据时，我会再次设置metadata = None 以停止写入相同的数据。

标签： python udp python-multithreading mpeg2-ts

【解决方案1】：

我无法测试，但我会使用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，这可能会产生问题。

【讨论】：

感谢您的意见。我最终稍微调整了您的代码，并在 printData 函数的末尾设置了 metadata = none。
而不是在 getData 函数中。我还必须恢复 global metadata。
您可以描述答案中的所有更改，然后您可以将其标记为已接受。

【解决方案2】：

此代码目前有效，但我会测试更多。

#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

【讨论】：