Improve handling of kraken dataconvert
This commit is contained in:
@@ -136,6 +136,7 @@ def convert_trades_format(config: Config, convert_from: str, convert_to: str, er
|
|||||||
)
|
)
|
||||||
from freqtrade.data.converter.trade_converter_kraken import import_kraken_trades_from_csv
|
from freqtrade.data.converter.trade_converter_kraken import import_kraken_trades_from_csv
|
||||||
import_kraken_trades_from_csv(config, convert_to)
|
import_kraken_trades_from_csv(config, convert_to)
|
||||||
|
return
|
||||||
|
|
||||||
from freqtrade.data.history.idatahandler import get_datahandler
|
from freqtrade.data.history.idatahandler import get_datahandler
|
||||||
src = get_datahandler(config['datadir'], convert_from)
|
src = get_datahandler(config['datadir'], convert_from)
|
||||||
|
|||||||
@@ -30,13 +30,13 @@ def import_kraken_trades_from_csv(config: Config, convert_to: str):
|
|||||||
exchange = ExchangeResolver.load_exchange(config, validate=False)
|
exchange = ExchangeResolver.load_exchange(config, validate=False)
|
||||||
# iterate through directories in this directory
|
# iterate through directories in this directory
|
||||||
data_symbols = {p.stem for p in tradesdir.rglob('*.csv')}
|
data_symbols = {p.stem for p in tradesdir.rglob('*.csv')}
|
||||||
print(data_symbols)
|
|
||||||
|
|
||||||
# create pair/filename mapping
|
# create pair/filename mapping
|
||||||
markets = {
|
markets = {
|
||||||
(m['symbol'], m['altname']) for m in exchange.markets.values()
|
(m['symbol'], m['altname']) for m in exchange.markets.values()
|
||||||
if m.get('altname') in data_symbols
|
if m.get('altname') in data_symbols
|
||||||
}
|
}
|
||||||
|
logger.info(f"Found csv files for {', '.join(data_symbols)}")
|
||||||
|
|
||||||
for pair, name in markets:
|
for pair, name in markets:
|
||||||
dfs = []
|
dfs = []
|
||||||
|
|||||||
Reference in New Issue
Block a user