import logging

from logging.handlers import TimedRotatingFileHandler

from apscheduler.schedulers.blocking import BlockingScheduler

logFilePath = 'spark_streaming_opinion.log'

logger = logging.getLogger()

logger.setLevel(logging.INFO)

handler = TimedRotatingFileHandler(logFilePath,

                                   when = 'd',

                                   interval = 1,

                                   backupCount=7)

formatter = logging.Formatter('[%(asctime)s-%(levelname)s - %(message)s]')

handler.setFormatter(formatter)

logger.addHandler(handler)

def testLogRun():

    for i  in range(2):

        logger.debug('This is debug message')

        logger.info('This is info message')

        logger.warning('This is warning message')

if __name__ == '__main__':

    shed = BlockingScheduler()

    shed.add_job(testLogRun, 'cron', hour = '*')

    try:

        shed.start()

    except SystemExit:

        shed.shutdown(wait=False)