Merge pull request #1870 from hroff-1902/dataprovider-history-2
minor: data/history slight cleanup/imrovement
This commit is contained in:
		| @@ -63,12 +63,8 @@ def load_tickerdata_file( | |||||||
|     Load a pair from file, either .json.gz or .json |     Load a pair from file, either .json.gz or .json | ||||||
|     :return tickerlist or None if unsuccesful |     :return tickerlist or None if unsuccesful | ||||||
|     """ |     """ | ||||||
|     path = make_testdata_path(datadir) |     filename = pair_data_filename(datadir, pair, ticker_interval) | ||||||
|     pair_s = pair.replace('/', '_') |     pairdata = misc.file_load_json(filename) | ||||||
|     file = path.joinpath(f'{pair_s}-{ticker_interval}.json') |  | ||||||
|  |  | ||||||
|     pairdata = misc.file_load_json(file) |  | ||||||
|  |  | ||||||
|     if not pairdata: |     if not pairdata: | ||||||
|         return None |         return None | ||||||
|  |  | ||||||
| @@ -147,6 +143,13 @@ def make_testdata_path(datadir: Optional[Path]) -> Path: | |||||||
|     return datadir or (Path(__file__).parent.parent / "tests" / "testdata").resolve() |     return datadir or (Path(__file__).parent.parent / "tests" / "testdata").resolve() | ||||||
|  |  | ||||||
|  |  | ||||||
|  | def pair_data_filename(datadir: Optional[Path], pair: str, ticker_interval: str) -> Path: | ||||||
|  |     path = make_testdata_path(datadir) | ||||||
|  |     pair_s = pair.replace("/", "_") | ||||||
|  |     filename = path.joinpath(f'{pair_s}-{ticker_interval}.json') | ||||||
|  |     return filename | ||||||
|  |  | ||||||
|  |  | ||||||
| def load_cached_data_for_updating(filename: Path, ticker_interval: str, | def load_cached_data_for_updating(filename: Path, ticker_interval: str, | ||||||
|                                   timerange: Optional[TimeRange]) -> Tuple[List[Any], |                                   timerange: Optional[TimeRange]) -> Tuple[List[Any], | ||||||
|                                                                            Optional[int]]: |                                                                            Optional[int]]: | ||||||
| @@ -209,9 +212,7 @@ def download_pair_history(datadir: Optional[Path], | |||||||
|         ) |         ) | ||||||
|  |  | ||||||
|     try: |     try: | ||||||
|         path = make_testdata_path(datadir) |         filename = pair_data_filename(datadir, pair, ticker_interval) | ||||||
|         filepair = pair.replace("/", "_") |  | ||||||
|         filename = path.joinpath(f'{filepair}-{ticker_interval}.json') |  | ||||||
|  |  | ||||||
|         logger.info( |         logger.info( | ||||||
|             f'Download history data for pair: "{pair}", interval: {ticker_interval} ' |             f'Download history data for pair: "{pair}", interval: {ticker_interval} ' | ||||||
| @@ -236,8 +237,9 @@ def download_pair_history(datadir: Optional[Path], | |||||||
|         misc.file_dump_json(filename, data) |         misc.file_dump_json(filename, data) | ||||||
|         return True |         return True | ||||||
|  |  | ||||||
|     except Exception: |     except Exception as e: | ||||||
|         logger.error( |         logger.error( | ||||||
|             f'Failed to download history data for pair: "{pair}", interval: {ticker_interval}.' |             f'Failed to download history data for pair: "{pair}", interval: {ticker_interval}. ' | ||||||
|  |             f'Error: {e}' | ||||||
|         ) |         ) | ||||||
|         return False |         return False | ||||||
|   | |||||||
| @@ -321,7 +321,8 @@ def test_download_backtesting_data_exception(ticker_history, mocker, caplog, def | |||||||
|     _clean_test_file(file1_1) |     _clean_test_file(file1_1) | ||||||
|     _clean_test_file(file1_5) |     _clean_test_file(file1_5) | ||||||
|     assert log_has( |     assert log_has( | ||||||
|         'Failed to download history data for pair: "MEME/BTC", interval: 1m.', |         'Failed to download history data for pair: "MEME/BTC", interval: 1m. ' | ||||||
|  |         'Error: File Error', | ||||||
|         caplog.record_tuples |         caplog.record_tuples | ||||||
|     ) |     ) | ||||||
|  |  | ||||||
|   | |||||||
| @@ -6,7 +6,7 @@ from unittest.mock import MagicMock | |||||||
| from freqtrade.data.converter import parse_ticker_dataframe | from freqtrade.data.converter import parse_ticker_dataframe | ||||||
| from freqtrade.misc import (common_datearray, datesarray_to_datetimearray, | from freqtrade.misc import (common_datearray, datesarray_to_datetimearray, | ||||||
|                             file_dump_json, file_load_json, format_ms_time, shorten_date) |                             file_dump_json, file_load_json, format_ms_time, shorten_date) | ||||||
| from freqtrade.data.history import load_tickerdata_file, make_testdata_path | from freqtrade.data.history import load_tickerdata_file, pair_data_filename | ||||||
| from freqtrade.strategy.default_strategy import DefaultStrategy | from freqtrade.strategy.default_strategy import DefaultStrategy | ||||||
|  |  | ||||||
|  |  | ||||||
| @@ -60,13 +60,13 @@ def test_file_dump_json(mocker) -> None: | |||||||
| def test_file_load_json(mocker) -> None: | def test_file_load_json(mocker) -> None: | ||||||
|  |  | ||||||
|     # 7m .json does not exist |     # 7m .json does not exist | ||||||
|     ret = file_load_json(make_testdata_path(None).joinpath('UNITTEST_BTC-7m.json')) |     ret = file_load_json(pair_data_filename(None, 'UNITTEST/BTC', '7m')) | ||||||
|     assert not ret |     assert not ret | ||||||
|     # 1m json exists (but no .gz exists) |     # 1m json exists (but no .gz exists) | ||||||
|     ret = file_load_json(make_testdata_path(None).joinpath('UNITTEST_BTC-1m.json')) |     ret = file_load_json(pair_data_filename(None, 'UNITTEST/BTC', '1m')) | ||||||
|     assert ret |     assert ret | ||||||
|     # 8 .json is empty and will fail if it's loaded. .json.gz is a copy of 1.json |     # 8 .json is empty and will fail if it's loaded. .json.gz is a copy of 1.json | ||||||
|     ret = file_load_json(make_testdata_path(None).joinpath('UNITTEST_BTC-8m.json')) |     ret = file_load_json(pair_data_filename(None, 'UNITTEST/BTC', '8m')) | ||||||
|     assert ret |     assert ret | ||||||
|  |  | ||||||
|  |  | ||||||
|   | |||||||
		Reference in New Issue
	
	Block a user