main.py

from BucketLogger import BucketLogger
import pandas as pd
from time import sleep

#Insert bucket credentials
#bucket =
#aws_key_id, secret_key =

RawDataDir = './RawData/'
DecodedFilesDir = './DecodedFiles/'
DecodeMap = "BeaconLocationMap"
Proto = "./locpb.proto"
Data = ['timestamp', 'beaconId' , 'latitude', 'longitude']
WorkingHours = [i for i in range(7,19)]

Logger = BucketLogger(aws_key_id, secret_key, bucket, RawDataDir)

while (True):
    Time = int(Logger.CheckTime())
    if (Time in WorkingHours):
        Logger = BucketLogger(aws_key_id, secret_key, bucket, RawDataDir)
        Logger.DowloadBucket()
        Logger.DelectBucket()
        Logger.DecodeProto(RawDataDir, DecodedFilesDir, DecodeMap, Proto)
        df = pd.DataFrame(columns=Data)
        df = Logger.ParseData(df, Data, DecodedFilesDir)
        Logger.CleanRawData()
        Logger.SendtoDB(df)
    else:
        print ("Outside of Working Hours")
        Logger.DelectBucket()
    sleep(300)