코인파크 거래소 일반 프로토콜 6.27 16:00 업데이트 SSL 검증 종료
저자:초목, 2018-06-26 16:38:27 날짜태그:파이썬
코인파크 일반 프로토콜 파이썬 2 버전
용도: BotVs가 코인파크.cc 거래소를 지원할 수 있습니다. 코드가 공개된 주소:https://www.fmz.com/strategy/101399운영 주소
http://127.0.0.1:6667
1.在托管者所在服务器运行插件
파일로 저장된 파일을 업로드하는 관리자의 서버에서 백그라운드에서 실행하면:
nohup python coinpark.py &
또한 실행 시 포트를 지정할 수 있습니다.
python coinpark.py 8866
이 로봇은 다른 로봇과 비교해 다른 로봇과 비교해 다른 로봇과 비교해 다른 로봇과 비교해 다른 로봇과 비교해 다른 로봇과 비교해 다른 로봇과 비교해 다른 로봇과 비교해 다른 로봇과 비교해 다른 로봇과 비교해 다른 로봇과 비교해 다른 로봇과 비교해 다른 로봇과 비교해 다른 로봇과 비교해 다른 로봇과 비교해 다른 로봇과 비교해 다른 로봇과 비교해 다른 로봇과 비교해 다른 로봇과 비교해 다른 로봇과 비교해 다른 로봇과 비교해 다른 로봇과 비교해 다른 로봇과 비교해 볼 수 있다.
2.在FMZ网站配置交易所
이 거래소는 다음과 같이 구성됩니다.)
이 계정에는 자산이 없기 때문에 자세한 테스트가 이루어지지 않았기 때문에 피드백을 환영합니다
2018.6.26 15:57 업데이트 및 변경 버그
#!/usr/bin/env python
# -*- coding: utf-8 -*-
'''
CoinPark通用协议,使用Python2.7
运行地址：http://127.0.0.1:6667，端口可指定
由于账户没资产，未作详细测试，欢迎反馈Bug
QQ:1051804485
反馈地址：https://www.botvs.com/bbs-topic/1963
2018.6.26 15:57 更新，修改了Bug
可以把通用协议当成普通机器人，运行在BotVs模拟盘即可，不收取费用
为了使用IO函数，需要重载exchange里的rpc方法，js的例子如下：
exchange.rpc = function(path, obj) {
return exchange.IO("api","POST", path, "obj="+escape(JSON.stringify(obj)));
}
function main() {
Log(exchange.rpc("/transfer", {cmd: "transfer/assets", body: {select:1}}));
}
'''
from BaseHTTPServer import BaseHTTPRequestHandler, HTTPServer
import json
import urllib
import urllib2
import time
import hmac
import hashlib
import random
import ssl
ssl._create_default_https_context = ssl._create_unverified_context
def httpGet(url):
headers = {'User-Agent':'Mozilla/5.0 (Windows; U; Windows NT 6.1; en-US; rv:1.9.1.6) Gecko/20091201 Firefox/3.5.6'}
req = urllib2.Request(url,headers=headers)
response = urllib2.urlopen(req)
return json.loads(response.read())
def getsign(data,secret):
result = hmac.new(secret.encode("utf-8"), data.encode("utf-8"), hashlib.md5).hexdigest()
return result
def httpPostWithSign(url, cmds, api_key, api_secret):
headers = {'User-Agent':'Mozilla/5.0 (Windows; U; Windows NT 6.1; en-US; rv:1.9.1.6) Gecko/20091201 Firefox/3.5.6'}
s_cmds = json.dumps(cmds)
sign = getsign(s_cmds,api_secret)
req = urllib2.Request(url, urllib.urlencode({'cmds': s_cmds, 'apikey': api_key,'sign':sign}), headers=headers)
response = urllib2.urlopen(req)
return json.loads(response.read())
class MyExchange:
market_url = "https://api.coinpark.cc/v1/mdata"
trade_url = "https://api.coinpark.cc/v1"
kline_period = {1:'1min', 3:'3min', 5:'5min', 15:'15min', 30:'30min',\
60:'1hour', 120:'2hour', 240:'4hour', 360:'6hour', \
60*12:'12hour', 60*24:'day', 60*24*7:'week'}
@staticmethod
def GetTicker(symbol):
url = MyExchange.market_url + "?cmd=ticker&pair=" + symbol
raw_data = httpGet(url)
if 'error' in raw_data.keys():
return {'error':json.dumps(raw_data['error'],encoding="utf8", ensure_ascii=False)}
ret_data = {"data": {"time": raw_data['result']['timestamp'], "buy": raw_data['result']['buy'],\
"sell": raw_data['result']['sell'], "last": raw_data['result']['last'],\
"high": raw_data['result']['high'], "low": raw_data['result']['low'],\
"vol": raw_data['result']['vol']}}
return ret_data
@staticmethod
def GetDepth(symbol):
url = MyExchange.market_url + "?cmd=depth&size=10&pair=" + symbol
raw_data = httpGet(url)
if 'error' in raw_data.keys():
return {'error':json.dumps(raw_data['error'],encoding="utf8", ensure_ascii=False)}
ret_data = {"data" : {"time" : raw_data['result']['update_time'], "asks" : [], "bids" : []}}
for bid in raw_data['result']['bids']:
ret_data['data']['bids'].append([bid['price'],bid['volume']])
for ask in raw_data['result']['asks']:
ret_data['data']['asks'].append([ask['price'],ask['volume']])
return ret_data
@staticmethod
def GetRecords(symbol, period):
url = MyExchange.market_url + "?cmd=kline&size=200&period=%s&pair="%MyExchange.kline_period[period] + symbol
raw_data = httpGet(url)
if 'error' in raw_data.keys():
return {'error':json.dumps(raw_data['error'],encoding="utf8", ensure_ascii=False)}
ret_data = {"data": []}
for kline in raw_data['result']:
ret_data['data'].append([kline['time'], kline['open'], kline['high'],\
kline['low'], kline['close'], kline['vol']])
return ret_data
@staticmethod
def GetTrades(symbol):
url = MyExchange.market_url + "?cmd=deals&size=50&pair=" + symbol
raw_data = httpGet(url)
if 'error' in raw_data.keys():
return {'error':json.dumps(raw_data['error'],encoding="utf8", ensure_ascii=False)}
ret_data = {"data":[]}
for trade in raw_data["result"]:
ret_data["data"].append({"id":trade["id"], "time":trade["time"], \
"price":trade["price"], "amount":trade["amount"],"type":"buy" if int(trade["side"])==1 else "sell"})
return ret_data
@staticmethod
def GetAccount(api_key, api_secret):
url = MyExchange.trade_url + "/transfer"
cmds = [{"cmd": "transfer/assets", "body": {"select":1}}]
raw_data = httpPostWithSign(url, cmds, api_key, api_secret)
if 'error' in raw_data.keys():
return {'error':json.dumps(raw_data['error'],encoding="utf8", ensure_ascii=False)}
ret_data = {"data": []}
if "assets_list" in raw_data["result"][0]["result"].keys():
for asset in raw_data["result"][0]["result"]["assets_list"]:
ret_data["data"].append({"currency":asset["coin_symbol"], \
"free":asset["balance"], "frozen":asset["freeze"]})
ret_data["raw"] = raw_data["result"]
return ret_data
@staticmethod
def Trade(api_key, api_secret, pair, order_type, order_side, price, amount):
url = MyExchange.trade_url + "/orderpending"
cmds = [{
'cmd':"orderpending/trade",
'index': random.randint(0,2000),
'body':{
'pair':pair,
'account_type':0,
'order_type':order_type,
'order_side':order_side,
'price':price,
'amount':amount,
}
}]
if order_type==1:
cmds['money'] = amount
raw_data = httpPostWithSign(url, cmds, api_key, api_secret)
if 'error' in raw_data.keys():
return {'error':json.dumps(raw_data['error'],encoding="utf8", ensure_ascii=False)}
ret_data = {"data": {'id':raw_data['result'][0]['result']}}
return ret_data
@staticmethod
def CancelOrder(api_key, api_secret, orders_id):
url = MyExchange.trade_url + "/orderpending"
cmds = [{
'cmd':"orderpending/cancelTrade",
'index': random.randint(0,2000),
'body':{'orders_id':orders_id}
}]
raw_data = httpPostWithSign(url, cmds, api_key, api_secret)
if 'error' in raw_data.keys():
return {'error':json.dumps(raw_data['error'],encoding="utf8", ensure_ascii=False)}
ret_data = {"data":True}
try:
result = raw_data['result'].encode('utf8')
except:
ret_data = {"data":False}
ret_data['raw'] = raw_data
return ret_data
@staticmethod
def GetOrder(api_key, api_secret, orders_id):
url = MyExchange.trade_url + "/orderpending"
cmds = [{
'cmd':"orderpending/order",
'index': random.randint(0,2000),
'body':{'id':orders_id}
}]
raw_data = httpPostWithSign(url, cmds, api_key, api_secret)
if 'error' in raw_data.keys():
return {'error':json.dumps(raw_data['error'],encoding="utf8", ensure_ascii=False)}
status = 'open'
if not raw_data['result'][0]['result']:
return {"error":'Id not found'}
if int(raw_data['result'][0]['result']['status'])==3:
status = 'closed'
if int(raw_data['result'][0]['result']['status'])==5:
status = 'canceled'
ret_data = {
"data": {
"id": raw_data['result'][0]['result']['id'],
"amount": raw_data['result'][0]['result']['amount'],
"price": raw_data['result'][0]['result']['price'],
"status": status,
"deal_amount": raw_data['result'][0]['result']['deal_amount'],
"type": "buy" if raw_data['result'][0]['result']['order_side']==1 else "sell",
"avg_price": 0,
}
}
ret_data['raw'] = raw_data
return ret_data
@staticmethod
def GetOrders(api_key, api_secret, pair):
url = MyExchange.trade_url + "/orderpending"
cmds = [{
'cmd':"orderpending/orderPendingList",
'body':{
'pair':pair,
'page':1,
'size':50
}
}]
raw_data = httpPostWithSign(url, cmds, api_key, api_secret)
if 'error' in raw_data.keys():
return {'error':json.dumps(raw_data['error'],encoding="utf8", ensure_ascii=False)}
ret_data = {"data":[]}
for order in raw_data["result"][0]["result"]["items"]:
status = 'open'
if int(order['status'])==3:
status = 'closed'
if int(order['status'])==5:
status = 'canceled'
ret_data["data"].append(
{
"id": order['id'],
"amount": order['amount'],
"price": order['price'],
"status": status,
"deal_amount": order['deal_amount'],
"type": "buy" if order['order_side']==1 else "sell",
}
)
ret_data['raw'] = raw_data
return ret_data
@staticmethod
def IO(api_key, api_secret, path, params):
url = MyExchange.trade_url + path
cmds = [json.loads(str(urllib.unquote(params['obj'])))]
raw_data = httpPostWithSign(url, cmds, api_key, api_secret)
if 'error' in raw_data.keys():
return {'error':json.dumps(raw_data['error'],encoding="utf8", ensure_ascii=False)}
return {"data":raw_data}
class Server(BaseHTTPRequestHandler):
def do_HEAD(self):
self.send_response(200)
self.send_header('Content-type', 'application/json')
self.end_headers()
def do_POST(self):
self.data_string = self.rfile.read(int(self.headers['Content-Length']))
data =json.loads(self.data_string.replace("'", '"'))
sent_data = {}
if data['method'] == "ticker":
symbol = data['params']['symbol'].upper()
sent_data = MyExchange.GetTicker(symbol)
elif data['method'] == "depth":
symbol = data['params']['symbol'].upper()
sent_data = MyExchange.GetDepth(symbol)
elif data['method'] == "records":
symbol = data['params']['symbol'].upper()
period = data['params']['period']
sent_data = MyExchange.GetRecords(symbol, int(period))
elif data['method'] == "trades":
symbol = data['params']['symbol'].upper()
sent_data = MyExchange.GetTrades(symbol)
elif data['method'] == "accounts":
access_key = data["access_key"]
secret_key = data["secret_key"]
sent_data = MyExchange.GetAccount(access_key, secret_key)
elif data['method'] == "trade":
access_key = data["access_key"]
secret_key = data["secret_key"]
pair = data['params']['symbol'].upper()
order_side = 1 if data['params']['type'] == 'buy' else 2
price = data['params']['price']
order_type = 2 if price > 0 else 1
amount = data['params']['amount']
sent_data = MyExchange.Trade(access_key, secret_key, pair, order_type, order_side, price, amount)
elif data['method'] == "cancel":
access_key = data["access_key"]
secret_key = data["secret_key"]
orders_id = int(data['params']['id'])
sent_data = MyExchange.CancelOrder(access_key, secret_key, orders_id)
elif data['method'] == "order":
access_key = data["access_key"]
secret_key = data["secret_key"]
orders_id = int(data['params']['id'])
sent_data = MyExchange.GetOrder(access_key, secret_key, orders_id)
elif data['method'] == "orders":
access_key = data["access_key"]
secret_key = data["secret_key"]
pair = data['params']['symbol'].upper()
sent_data = MyExchange.GetOrders(access_key, secret_key, pair)
elif data['method'][:2] == "__":
access_key = data["access_key"]
secret_key = data["secret_key"]
path = data["method"].split('_')[-1]
params = data["params"]
sent_data = MyExchange.IO(access_key, secret_key, path, params)
self.do_HEAD()
self.wfile.write(json.dumps(sent_data))
def run(server_class=HTTPServer, handler_class=Server, port=6667):
server_address = ('', port)
httpd = server_class(server_address, handler_class)
print 'Starting http server...'
httpd.serve_forever()
if __name__ == "__main__":
from sys import argv
if len(argv) == 2:
run(port=int(argv[1]))
else:
run()
관련
- 练习01.RSI
- 파이썬 추격 버전?? 죽이고 떨어지는 전략 (교육)
- 아이스크림 위탁 (구매) - 제이슨
- OKCoin을 포스팅합니다.
- 주당 100USDT 정도를 투입하는 신입생 투입자
- 100USDT - 주간 고정금 (100USDT Invested Every Week - Regular Fixed Investment)
- 거래소에서 반刷값을 서로
습니다. - 복잡한 디스크 차트 테스트 버전
- 투표 전략
- 순차적으로 구매하고 판매하는 가격
- 로컬 저장
더 많은
- 50줄 격자 전략 (교육)
- 듀얼 스러스트 오케엑스 선물 (교육)
- SVM 테스트
- 거래소의 최소 수와 정확성
- Fomo3D 스마트 계약 모니터링
- BitMEX 고급 API 기능 (미래: 대량 주문 하락, 한 버튼 취소) 자바스크립트
- 코인 엑스 거래 (LTC_USDT)
- 아이스버그 구매 명령
- 이중 추진력 OKEX 기능
- 이동 평균 봇 30 줄
- 확인합니다. https://quant.la/Argus/
- 비안은 모든 동전을 팔았습니다.
을 쫓아내기 위해 - 지수화
- okex 코인의 최소 거래량
- 단면 격자
- 여러 그래프를 테스트하여 Python 버전을 보여줍니다.
- okex-BTC 계약 계좌 공개
- 산지 코인 지수 ((2018.02.22 기준점 1000)
- 폐지된 GetMinStock (() 함수를 대체합니다.
로지레인안녕하세요, http://www.allcoin.ca/의 Allcoin 거래소의 버전을 변경하는 데 도움이 되겠습니까?
812526825@qq.com테스트 완료, 완벽하게 작동합니다.
아발론666작은 풀의 형?
초목그래요