Source code for pycif.plugins.datastreams.meteos.dummy_csv.fetch

import os
import pandas as pd
import datetime
from .....utils import path
from .make import make




def fetch(ref_dir, ref_file, input_interval, target_dir, tracer=None, **kwargs):
    list_period_dates = \
        pd.date_range(input_interval[0], input_interval[1], freq=tracer.file_freq)
    list_dates = {}
    list_files = {}
    for dd in list_period_dates:
        file = dd.strftime("{}/{}".format(ref_dir, ref_file))
        file_hours = pd.date_range(
            dd, dd + pd.to_timedelta(tracer.file_freq),
            freq=tracer.resolution,
            inclusive="left"
        )
        list_dates[dd] = [[hh, hh + pd.to_timedelta(tracer.resolution)]
                          for hh in file_hours]
        target_file = "{}/{}".format(target_dir, os.path.basename(file))
        list_files[dd] = (len(file_hours) * [target_file])
        if os.path.isfile(file):
            # Fetching
            path.link(file, target_file)

        else:
            make(tracer, target_file, file_hours)

    return list_files, list_dates