def Write()

in datasource.py [0:0]


    def Write(self, item={}):
        
        if item != {}: 
            if self.type == 'ddb':
                self.list.append(item)
            else:
                self.list.append(self.Deli.join(item['row']))

        if (len(self.list) >= self.rsize) or (len(self.list) > 0  and item == {}):
            if self.type == 'ddb':
                response = ddbClient.batch_write_item(RequestItems={ self.dsrc : self.list })
            else:
                self.Output.write(self.crlf + '\n'.join(self.list))
                self.crlf = '\n'
            self.list = []