def get_source_dataframe()

in lib/analyzer-lambda/analyzer-lambda.py [0:0]


def get_source_dataframe(end_time, frequency):
    time_window_start = pd.to_datetime(end_time - 3600, unit='s')
    time_window_end = pd.to_datetime(end_time, unit='s')
    time_window = pd.date_range(
        start=time_window_start, end=time_window_end, freq=frequency)
    source_df = pd.DataFrame(index=time_window)
    source_df.index.name = 'timestamp'
    return source_df