def insert(self, streamname, value):
if streamname not in self.streams:<EOL><INDENT>raise Exception("<STR_LIT>" % (streamname, ))<EOL><DEDENT>validate(value, self.streams[streamname])<EOL>value = json.dumps(value)<EOL>logging.debug("<STR_LIT>" % (streamname, value))<EOL>c = self.database.cursor()<EOL>c.execute("<STR_LIT>",<EOL>(streamname, time.time(), value))<EOL>
Insert the datapoint into the logger for the given stream name. The logger caches the datapoint
        and eventually synchronizes it with ConnectorDB