in datasource.py [0:0]
def get(self):
if self.Type == 'ddb' or self.Type == 'sqs':
tmp = {}
tmp['PutRequest'] = {}
tmp['PutRequest']['Item'] = self.Record
return tmp
else:
return self.Record