시장 센터 고객
저자:fmzero, 날짜: 2020-01-19 23:29:25태그:
비즈니스 센터 클라이언트
왜 쇼핑센터가 있을까요?
시장에 접속하기 위해서는 REST와 웹소켓이 있는데, 웹소켓은 여러 가지 불가항력적인 요인으로 인해 연결이 강제적으로 끊어질 때 전략은 오류를 허용하는 메커니즘을 준비해야 합니다. REST는 종종 가장 안정적인 방법입니다. OKEx와 같은 같은 플랫폼에서 여러 정책을 실행할 때, REST API에 대한 접근은 IP 제한, 계정 제한, 또는 둘의 조합 등 다양한 방법으로 제한됩니다. 시장 센터를 사용하여 REST 요청 빈도를 줄일 수 있습니다.
사건 센터 배치
주의하세요.
- 시장 데이터 인터페이스만 제공하며, 주문 인터페이스는 제공하지 않습니다.
- 비즈니스 센터는 리눅스, 유닉스에서만 실행됩니다.
API
- GetSupport 리스트
- 구독SpotTicker
- 구독SpotDepth
SPOTTrade에 가입하세요- GetSpotTicker
- GetSpotDepth
GetSpotTrade- SubscribeFutureTicker
- SubscribeFutureDepth
FUTURETRADE에 가입하세요터티커 - GetFuture 깊이
GetFutureTrade
// a client for market center, https://github.com/goex-top/market_center
// api list
// * GetSupportList
// * SubscribeSpotTicker
// * SubscribeSpotDepth
// * ~~SubscribeSpotTrade~~
// * GetSpotTicker
// * GetSpotDepth
// * ~~GetSpotTrade~~
// * SubscribeFutureTicker
// * SubscribeFutureDepth
// * ~~SubscribeFutureTrade~~
// * GetFutureTicker
// * GetFutureDepth
// * ~~GetFutureTrade~~
// params wit web
// var udspath = /tmp/goex.market.center //ref to https://github.com/goex-top/market_center/blob/1e1bb15c69a1da6fddbba3d506920e91f9ec7842/const.go#L35
// local variable
// var client = null
var ReqType = {
ReqType_GetSupportList: 1,
ReqType_SubscribeSpotDepth: 2,
ReqType_SubscribeSpotTicker: 3,
ReqType_SubscribeFutureDepth: 4,
ReqType_SubscribeFutureTicker: 5,
ReqType_GetSpotDepth: 6,
ReqType_GetSpotTicker: 7,
ReqType_GetFutureDepth: 8,
ReqType_GetFutureTicker: 9,
}
//---------------------------------------
function newUDSClient() {
var client = Dial('unix://'+udspath)
if (null === client) {
throw 'new usd client fail'
}
return client
}
function udsRequest(client, req) {
try {
client.write(JSON.stringify(req))
var rsp = client.read(20)
if (rsp === null) {
return null
}
var obj = JSON.parse(rsp)
if(obj.status !== 0) {
return null
}
return obj.data
}
catch(e) {
return null
}
}
function GetSupportList(client) {
var req = {type:ReqType.ReqType_GetSupportList}
var rsp = udsRequest(client, req)
if (rsp === null) {
return null
}
return rsp
}
function GetSpotDepth(client, exchangeName, pair) {
var req = {type:ReqType.ReqType_GetSpotDepth, exchange_name: exchangeName, currency_pair: pair}
var rsp = udsRequest(client, req)
if(rsp === null) {
return null
}
return {Asks:rsp.AskList, Bids:rsp.BidList, Time:rsp.UTime, Info:rsp.rsp}
}
function GetSpotTicker(client, exchangeName, pair) {
var req = {type:ReqType.ReqType_GetSpotTicker, exchange_name: exchangeName, currency_pair: pair}
var rsp = udsRequest(client, req)
if(rsp === null) {
return null
}
return {
Last:parseFloat(rsp.last),
Buy:parseFloat(rsp.buy),
Sell:parseFloat(rsp.sell),
Volume:parseFloat(rsp.vol),
Time:parseFloat(rsp.date),
High:parseFloat(rsp.high),
Low:parseFloat(rsp.low),
Info:rsp
}
}
function SubscribeSpotDepth(client, exchangeName, pair, period) {
var req = {type:ReqType.ReqType_SubscribeSpotDepth, exchange_name: exchangeName, currency_pair: pair, period: period}
var rsp = udsRequest(client, req)
return rsp
}
function SubscribeSpotTicker(client, exchangeName, pair, period) {
var req = {type:ReqType.ReqType_SubscribeSpotTicker, exchange_name: exchangeName, currency_pair: pair, period: period}
var rsp = udsRequest(client, req)
return rsp
}
function GetFutureDepth(client, exchangeName, contractType, pair) {
var req = {type:ReqType.ReqType_GetFutureDepth, exchange_name: exchangeName, contract_type: contractType, currency_pair: pair}
var rsp = udsRequest(client, req)
if(rsp === null) {
return null
}
return {Asks:rsp.AskList, Bids:rsp.BidList, Time:rsp.UTime, Info:rsp.rsp}
}
function GetFutureTicker(client, exchangeName, contractType, pair) {
var req = {type:ReqType.ReqType_GetFutureTicker, exchange_name: exchangeName, contract_type: contractType, currency_pair: pair}
var rsp = udsRequest(client, req)
if(rsp === null) {
return null
}
return {
Last:parseFloat(rsp.last),
Buy:parseFloat(rsp.buy),
Sell:parseFloat(rsp.sell),
Volume:parseFloat(rsp.vol),
Time:parseFloat(rsp.date),
High:parseFloat(rsp.high),
Low:parseFloat(rsp.low),
Info:rsp
}
}
function SubscribeFutureDepth(client, exchangeName, contractType, pair, period) {
var req = {type:ReqType.ReqType_SubscribeFutureDepth, exchange_name: exchangeName, contract_type: contractType, currency_pair: pair, period: period}
var rsp = udsRequest(client, req)
return rsp
}
function SubscribeFutureTicker(client, exchangeName, contractType, pair, period) {
var req = {type:ReqType.ReqType_SubscribeFutureTicker, exchange_name: exchangeName, contract_type: contractType, currency_pair: pair, period: period}
var rsp = udsRequest(client, req)
return rsp
}
var MarketCenterClient = (function() {
function MarketCenterClient() {
if (typeof udspath === 'undefined' || udspath === '') {
throw 'udspath not defined'
}
this.client = newUDSClient()
this.list = GetSupportList(this.client)
Log("this.list:" + this.list)
}
MarketCenterClient.prototype.GetSpotTicker = function(exchangeName, pair) {
if (typeof exchangeName === 'undefined' || exchangeName === '') {
throw 'GetSpotTicker exchangeName not defined'
}
if (typeof pair === 'undefined' || pair === '') {
throw 'GetSpotTicker pair not defined'
}
return GetSpotTicker(this.client, exchangeName, pair)
}
MarketCenterClient.prototype.GetSpotDepth = function(exchangeName, pair) {
if (typeof exchangeName === 'undefined' || exchangeName === '') {
throw 'GetSpotDepth exchangeName not defined'
}
if (typeof pair === 'undefined' || pair === '') {
throw 'GetSpotDepth pair not defined'
}
return GetSpotDepth(this.client, exchangeName, pair)
}
MarketCenterClient.prototype.SubscribeSpotDepth = function(exchangeName, pair, period) {
if(typeof(period) === 'undefined') {
period = 200
}
if (typeof exchangeName === 'undefined' || exchangeName === '') {
throw 'SubscribeSpotDepth exchangeName not defined'
}
if (typeof pair === 'undefined' || pair === '') {
throw 'SubscribeSpotDepth pair not defined'
}
var found = false
_.each(this.list, function(item) {
if (item === exchangeName) {
found = true
return false
}
})
if(!found) {
throw 'exchange ('+ exchangeName +') not support, please check it again, https://github.com/goex-top/market_center#support-exchanges'
}
return SubscribeSpotDepth(this.client, exchangeName, pair, period)
}
MarketCenterClient.prototype.SubscribeSpotTicker = function(exchangeName, pair, period) {
if(typeof(period) === 'undefined') {
period = 200
}
if (typeof exchangeName === 'undefined' || exchangeName === '') {
throw 'SubscribeSpotTicker exchangeName not defined'
}
if (typeof pair === 'undefined' || pair === '') {
throw 'SubscribeSpotTicker pair not defined'
}
var found = false
_.each(this.list, function(item) {
if (item === exchangeName) {
found = true
return false
}
})
if(!found) {
throw 'exchange ('+ exchangeName +') not support, please check it again, https://github.com/goex-top/market_center#support-exchanges'
}
return SubscribeSpotTicker(this.client, exchangeName, pair, period)
}
MarketCenterClient.prototype.GetFutureTicker = function(exchangeName, contractType, pair) {
if (typeof exchangeName === 'undefined' || exchangeName === '') {
throw 'GetFutureTicker exchangeName not defined'
}
if (typeof pair === 'undefined' || pair === '') {
throw 'GetFutureTicker pair not defined'
}
return GetFutureTicker(this.client, exchangeName, contractType, pair)
}
MarketCenterClient.prototype.GetFutureDepth = function(exchangeName, contractType, pair) {
if (typeof exchangeName === 'undefined' || exchangeName === '') {
throw 'GetFutureDepth exchangeName not defined'
}
if (typeof pair === 'undefined' || pair === '') {
throw 'GetFutureDepth pair not defined'
}
return GetFutureDepth(this.client, exchangeName, contractType, pair)
}
MarketCenterClient.prototype.SubscribeFutureDepth = function(exchangeName, contractType, pair, period) {
if(typeof(period) === 'undefined') {
period = 200
}
if (typeof exchangeName === 'undefined' || exchangeName === '') {
throw 'SubscribeFutureDepth exchangeName not defined'
}
if (typeof pair === 'undefined' || pair === '') {
throw 'SubscribeFutureDepth pair not defined'
}
var found = false
_.each(this.list, function(item) {
if (item === exchangeName) {
found = true
return false
}
})
if(!found) {
throw 'exchange ('+ exchangeName +') not support, please check it again, https://github.com/goex-top/market_center#support-exchanges'
}
return SubscribeFutureDepth(this.client, exchangeName, contractType, pair, period)
}
MarketCenterClient.prototype.SubscribeFutureTicker = function(exchangeName, contractType, pair, period) {
if(typeof(period) === 'undefined') {
period = 200
}
if (typeof exchangeName === 'undefined' || exchangeName === '') {
throw 'SubscribeFutureTicker exchangeName not defined'
}
if (typeof pair === 'undefined' || pair === '') {
throw 'SubscribeFutureTicker pair not defined'
}
var found = false
_.each(this.list, function(item) {
if (item === exchangeName) {
found = true
return false
}
})
if(!found) {
throw 'exchange ('+ exchangeName +') not support, please check it again, https://github.com/goex-top/market_center#support-exchanges'
}
return SubscribeFutureTicker(this.client, exchangeName, contractType, pair, period)
}
MarketCenterClient.prototype.GetSupportList = function() {
return GetSupportList(this.client)
}
return MarketCenterClient
})()
$.NewMarketCenterClient = function() {
return new MarketCenterClient()
}
function main() {
mcc = $.NewMarketCenterClient()
Log('support list'+mcc.GetSupportList())
mcc.SubscribeSpotDepth('binance.com', 'BTC_USDT', 200)
Sleep(1000)
Log(mcc.GetSpotDepth('binance.com', 'BTC_USDT'))
mcc.SubscribeSpotTicker('binance.com', 'BTC_USDT', 200)
Sleep(1000)
Log(mcc.GetSpotTicker('binance.com', 'BTC_USDT'))
}
더 많은
- 파이썬 버전 MACD 지표 도표 예제
- 해수욕장 전략 btc 현금판
- 티코인 템포
- 로봇 Ctrl (교육 전략)
- 양적 분산율 거래 전략-by: 배우량화
- 파이썬 판자 플랫폼 균형 전략 (교육)
- 업무 센터 지연
- 공유 템플릿 참조 오류 추적
- Bybit 알고리즘 접착제 - VWAP (BTC)
- 파이썬 버전의 다종류 추격 및 추락 전략 (교육)
- 파이썬 추격 및 추락 전략 (교육)
- 파이썬 버전의 간단한 격자 전략 (교육)
- 데리빗 옵션 테스트 전략
- 1btc부터, Fmex 공백 해제 정책, 후시 공백
- 1btc, fmex 다목적 해제 전략, 후 시장 더 보기
- 간단한 시장을 헤지핑하는 기능
- 중·중·중 3주기 점프 전략 V2.0_ 현장_테스트
- 스노그그레드-7*24시간 거래 로봇, 매일 실시간 효과를 업데이트합니다
- 교육 전략 (TCI 전략)
17880207677어떻게?
17880207677어떻게 작동할까요?
아이스크림 닭고기왜 늦춰야 할까요?
fmzero이 테스트 결과는 https://www.fmz.com/strategy/183009에서 확인할 수 있습니다.
fmzero https://www.fmz.com/strategy/183009
fmzero클라이언트에서 센터로의 지연은 기본적으로 무시할 수 있습니다.