code: def serialize(self, root, records):
          
          logging.info("Serializing record")
          logging.debug("Root: {}".format(root))
          logging.debug("Records: {}".format(records))
          if records == {}:
              return '{}'
          if isinstance(records, dict):
              if list(records.keys())[0] == 'errors':
                  logging.warning("Found errors. Moving on".format(records))
                  root = None
              elif '_id' in records:
                  records['id'] = records.pop('_id')
          else:
              records = list(records)
  
              # rename _id to id
              for r in records:
                  if '_id' in r:
                      r['id'] = r.pop('_id')
  
          if root is not None:
              records = {root: records}
          return json.dumps(records, cls=JSONEncoder)
docs: Serialize the payload into JSON