如何使用protobuf二进制文件过滤PUB/SUB？

syntax = "proto3";

message Message {
  string topic = 1;
  bytes data = 2;
}

protoc --python_out=. message.proto

import message_pb2

def filter_messages(messages):
    filtered_messages = []
    for message in messages:
        if message.topic == "topic1":
            filtered_messages.append(message)
    return filtered_messages

# 从消息队列或消息中间件中获取消息
messages = get_messages()

# 反序列化消息
deserialized_messages = []
for message_data in messages:
    message = message_pb2.Message()
    message.ParseFromString(message_data)
    deserialized_messages.append(message)

# 过滤消息
filtered_messages = filter_messages(deserialized_messages)

# 序列化过滤后的消息
serialized_messages = []
for message in filtered_messages:
    serialized_message = message.SerializeToString()
    serialized_messages.append(serialized_message)

# 将过滤后的消息发送到目标队列或中间件
send_messages(serialized_messages)