(self)
return msg.format(session_num)
Entry point for the analyzer. Create sessions consisting of a start
        and end event.

        Returns:
            String containing the number of sessions created.
Entry point for the analyzer. Create sessions consisting of a start
        and end event.
Entry point for the analyzer . Create sessions consisting of a start and end event .
def run(self):
        """Entry point for the analyzer. Create sessions consisting of a start
        and end event.

        Returns:
            String containing the number of sessions created.
        """
        return_fields = ['timestamp', 'xml_string', 'event_identifier',
                         'record_number', 'session_id']
        last_login_time = 0
        session_num = 0
        login_events = dict()
        processed = False

        while not processed:
            query_string = self.query_template.format(last_login_time)
            events = self.event_stream(query_string=query_string,
                                       return_fields=return_fields)
            last_login_time, session_num, login_events, processed = \
                self.processSessions(events, session_num, login_events)

        msg = 'Sessionizing completed, number of sessions created: {0:d}'
        return msg.format(session_num)
def run ( self ) : return_fields = [ 'timestamp' , 'xml_string' , 'event_identifier' , 'record_number' , 'session_id' ] last_login_time = 0 session_num = 0 login_events = dict ( ) processed = False while not processed : query_string = self . query_template . format ( last_login_time ) events = self . event_stream ( query_string = query_string , return_fields = return_fields ) last_login_time , session_num , login_events , processed = self . processSessions ( events , session_num , login_events ) msg = 'Sessionizing completed, number of sessions created: {0:d}' return msg . format ( session_num )