lychiyu/bbgo_origin
1
0
Fork 0
mirror of https://github.com/c9s/bbgo.git synced 2024-11-10 09:11:55 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

use log fields instead of log prefix

Browse Source
This commit is contained in:
c9s 2020-08-11 08:36:36 +08:00
parent 094da9d3d3
commit 0d9b503278
1 changed files with 9 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
bbgo/exchange/binance/exchange.go
View File

@ -13,6 +13,10 @@ import (
"github.com/sirupsen/logrus" "github.com/sirupsen/logrus"
) )
var log = logrus.WithFields(logrus.Fields{
"exchange": "binance",
})
type Exchange struct { type Exchange struct {
Client *binance.Client Client *binance.Client
} }
@ -108,7 +112,7 @@ func (e *Exchange) SubmitOrder(ctx context.Context, order *types.Order) error {
} }
retOrder, err := req.Do(ctx) retOrder, err := req.Do(ctx)
logrus.Infof("[binance] order created: %+v", retOrder) log.Infof("order created: %+v", retOrder)
return err return err
} }
@ -131,7 +135,7 @@ func (e *Exchange) QueryKLines(ctx context.Context, symbol, interval string, opt
limit = options.Limit limit = options.Limit
} }
logrus.Infof("[binance] querying kline %s %s %v", symbol, interval, options) log.Infof("querying kline %s %s %v", symbol, interval, options)
req := e.Client.NewKlinesService().Symbol(symbol). req := e.Client.NewKlinesService().Symbol(symbol).
Interval(interval). Interval(interval).
@ -203,11 +207,11 @@ func (e *Exchange) QueryTrades(ctx context.Context, symbol string, options *Trad
for _, t := range remoteTrades { for _, t := range remoteTrades {
localTrade, err := convertRemoteTrade(*t) localTrade, err := convertRemoteTrade(*t)
if err != nil { if err != nil {
logrus.WithError(err).Errorf("can not convert binance trade: %+v", t) log.WithError(err).Errorf("can not convert binance trade: %+v", t)
continue continue
} }
logrus.Infof("[binance] trade: %d %s % 4s price: % 13s volume: % 11s %6s % 5s %s", t.ID, t.Symbol, localTrade.Side, t.Price, t.Quantity, BuyerOrSellerLabel(t), MakerOrTakerLabel(t), localTrade.Time) log.Infof("trade: %d %s % 4s price: % 13s volume: % 11s %6s % 5s %s", t.ID, t.Symbol, localTrade.Side, t.Price, t.Quantity, BuyerOrSellerLabel(t), MakerOrTakerLabel(t), localTrade.Time)
trades = append(trades, *localTrade) trades = append(trades, *localTrade)
} }
@ -220,7 +224,7 @@ func (e *Exchange) BatchQueryTrades(ctx context.Context, symbol string, options
startTime = *options.StartTime startTime = *options.StartTime
} }
logrus.Infof("[binance] querying %s trades from %s", symbol, startTime) log.Infof("querying %s trades from %s", symbol, startTime)
var lastTradeID = options.LastTradeID var lastTradeID = options.LastTradeID
for { for {