in datahub/models/results.py [0:0]
def parse_content(cls, content, **kwargs):
content = json.loads(to_text(content))
records = []
for item in content['Records']:
data = item['Data']
if isinstance(data, six.string_types):
record = BlobRecord(values=data)
else:
record_schema = kwargs['record_schema']
record = TupleRecord(schema=record_schema, values=data)
if 'Attributes' in item:
record.attributes = item['Attributes']
record.sequence = item['Sequence']
record.system_time = item['SystemTime']
records.append(record)
return cls(content['NextCursor'], content['RecordCount'], content['StartSeq'], records)