I have data which is in protobuf format and im able to parse read,convert to json,dict in python, but i want to convert it to avro. How should i do
import time
import sys
import apache_beam as beam
from apache_beam.options.pipeline_options import PipelineOptions
import csv
import base64
from google.protobuf import timestamp_pb2
from google.protobuf.json_format import MessageToDict
from google.protobuf.json_format import MessageToJson
import io
import logging
from google.cloud import storage
import json
from otherfiles import protobuff_pb2
b64ProtoData = "proto formated data"
b64ProtoData = b64ProtoData.replace('_', '/')
b64ProtoData = b64ProtoData.replace('*', '=')
b64ProtoData = b64ProtoData.replace('-', '+')
finalbunary = base64.b64decode(b64ProtoData)
log = protobuff_pb2.ProcessorLogProto()
log.ParseFromString(finalbunary)
jsonObj = MessageToJson(log)
question from:
https://stackoverflow.com/questions/65599364/protobuf-data-to-avro-in-python 与恶龙缠斗过久,自身亦成为恶龙;凝视深渊过久,深渊将回以凝视…