A simple parser

metrics.py

import avro.io
import avro.datafile

class Parser:
  def __init__(self):
    self.datum_reader = avro.io.DatumReader()

  def parse(self, message):
    reader = avro.datafile.DataFileReader(message, self.datum_reader)
    for record in reader:
      host = record['host']
      for metric in record['metriclist']:
        yield { time: metric['time'],
                host: host,
                metric_name: metric['metric'],
                value: metric['value'],
                ds_type: metric['metric_type'], }

See "Autometrics: Self-service metrics collection" for more information.