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 = []