feed.jl
1 using .Python: pyimport, PyDict, @py, @pymodule 2 using Exchanges: tickers 3 4 function cf_getfeed(; timeout=3) 5 # handler = cryptofeed[].FeedHandler() 6 # handler.add_feed() 7 @pymodule cryptof cryptofeed 8 feed = pyimport("src.exchanges.feed") 9 rld = pyimport("importlib") 10 rld.reload(feed) 11 pairs = tickers() 12 norm_pairs = [] 13 for p in keys(pairs) 14 push!(norm_pairs, replace(p, "/" => "-")) 15 end 16 res = feed.run(; timeout, symbols=first(norm_pairs, 10)) 17 candle = first(res) 18 candle 19 end