def put_record(self, record):
        row = [record.get(field) for field in self.fields.names()]

        self.put(row)
Convenience method that will transform record into a row based on pipe fields.
dataset/ETHPy150Open Stiivi/brewery/brewery/streams.py/SimpleDataPipe.put_record