Source code for recipe_system.cal_service.file_getter

import requests
from requests.exceptions import HTTPError
from requests.exceptions import Timeout
from requests.exceptions import ConnectionError

from gempy.utils import logutils

[docs] class GetterError(Exception): def __init__(self, messages): self.messages = messages
[docs] def requests_getter(url): r = requests.get(url, timeout=10.0) try: r.raise_for_status() yield from r.iter_content(chunk_size=128) except HTTPError as err: raise GetterError(["Could not retrieve {}".format(url), str(err)]) except ConnectionError as err: raise GetterError(["Unable to connect to url {}".format(url), str(err)]) except Timeout as terr: raise GetterError(["Request timed out", str(terr)])
[docs] def plain_file_getter(url): path = url.split('://', 1)[1] try: with open(path, "rb") as source: while True: data = if not data: break yield data except Exception as err: raise GetterError(["Problem accessing to {}".format(url), str(err)])
schema_mapper = { 'http': requests_getter, 'https': requests_getter, 'ftp': requests_getter, 'file': plain_file_getter }
[docs] def get_file_iterator(url): getter = schema_mapper[url.split('://', 1)[0]] return getter(url)