Блог

Я хочу использовать сообщения pub / sub из темы (GCP cloud pub / sub), а затем каким-то образом загружать в базу данных.

Я решил создать облачную функцию с триггером pub / sub, связанным с темой, из которой я хочу получать сообщения. Данные отправляются в формате protobuf.

При написании нескольких строк кода на python я могу декодировать сообщение с помощью моего файла .proto и анализировать сообщение с помощью ParseFromString

 import person_pb2 #This is the file generated from my .proto file with the format of the data

from google.cloud import pubsub_v1
subscriber = pubsub_v1.SubscriberClient()

    def callback(message):
        person = person_pb2.List()
        person.ParseFromString(message.data)
        print(person)
    
    future = subscriber.subscribe(f'projects/my_project/subscriptions/test-sub', callback)
    try:
        future.result()
    except KeyboardInterrupt:
        future.cancel()
 

Ниже приведена функция, выполняемая в моей облачной функции. В настоящее время он работает, но, как вы можете видеть, я не использую person_pb2, созданный из моего файла .proto.

 def decode_pubsub(event, context):

    import base64

    print(f'message id: {context.event_id}, timestamp: {context.timestamp}')
    data = event['data']
    decoded_data = base64.b64decode(data).decode('utf-8')
    print(decoded_data)
 

Итак, теперь к вопросу:

В первом сценарии тип сообщения <класс ‘байты’> Я декодирую с помощью ParseFromString Во втором сценарии тип сообщения <class ‘str’> Я декодирую с помощью Base64

Нет ли необходимости использовать файл .proto для декодирования сообщения в облачной функции?