adelorenzo/stable
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Add convert_* methods

Browse Source
This commit is contained in:
Matthias 2019-12-23 15:04:45 +01:00
parent e5a61667dd
commit cd4466a626
1 changed files with 46 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

46
freqtrade/utils.py
View File

@ -17,6 +17,7 @@ from freqtrade.configuration import (Configuration, TimeRange,
from freqtrade.configuration.directory_operations import (copy_sample_files,
create_userdata_dir)
from freqtrade.constants import USERPATH_HYPEROPTS, USERPATH_STRATEGY
from freqtrade.data.datahandlers import get_datahandlerclass
from freqtrade.data.history import (convert_trades_to_ohlcv,
refresh_backtest_ohlcv_data,
refresh_backtest_trades_data)
@ -241,12 +242,53 @@ def start_list_strategies(args: Dict[str, Any]) -> None:
print(tabulate(strats_to_print, headers='keys', tablefmt='pipe'))
def convert_trades_format(config: Dict[str, Any], convert_from: str, convert_to: str):
"""
TODO: move this to converter.py (?)
"""
SrcClass = get_datahandlerclass(convert_from)
TrgClass = get_datahandlerclass(convert_to)
if 'pairs' not in config:
config['pairs'] = SrcClass.trades_get_pairs(config['datadir'])
logger.info(f"Converting trades for {config['pairs']}")
for pair in config['pairs']:
src = SrcClass(config['datadir'], pair)
trg = TrgClass(config['datadir'], pair)
data = src.trades_load()
logger.info(f"Converting {len(data)} trades for {pair}")
trg.trades_store(data)
def convert_ohlcv_format(config: Dict[str, Any], convert_from: str, convert_to: str):
"""
TODO: move this to converter.py (?)
"""
SrcClass = get_datahandlerclass(convert_from)
TrgClass = get_datahandlerclass(convert_to)
if 'pairs' not in config:
config['pairs'] = SrcClass.ohclv_get_pairs(config['datadir'], config['ticker_interval'])
logger.info(f"Converting OHLCV for {config['pairs']}")
for pair in config['pairs']:
src = SrcClass(config['datadir'], pair)
trg = TrgClass(config['datadir'], pair)
data = src.ohlcv_load()
logger.info(f"Converting {len(data)} candles for {pair}")
trg.ohlcv_store(data)
def start_convert_data(args: Dict[str, Any]) -> None:
"""
Convert data from one format to another
"""
config = setup_utils_configuration(args, RunMode.UTIL_EXCHANGE)
print(config)
config = setup_utils_configuration(args, RunMode.UTIL_NO_EXCHANGE)
from pprint import pprint
pprint(config)
# convert_trades_format(config, 'json', 'jsongz')
def start_list_timeframes(args: Dict[str, Any]) -> None: