/ Exchanges / src / feed.jl
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