CoinPark giao dịch giao thức chung 6.27 16:00 cập nhật tắt SSL xác minh
Tác giả:Cỏ nhỏ, Ngày: 2018-06-26 16:38:27Tags:Python
CoinPark giao thức chung Python phiên bản 2
Sử dụng: Cho phép BotVs hỗ trợ sàn giao dịch coinpark.cc Có thể bạn có thể tham khảo thông tin này tại đây:https://www.fmz.com/strategy/101399Địa chỉ hoạt động
http://127.0.0.1:6667
1.在托管者所在服务器运行插件
Các máy chủ lưu trữ và tải lên các tập tin được lưu trên máy chủ của người quản lý và chạy trong nền:
nohup python coinpark.py &
Bạn cũng có thể chỉ định cổng khi chạy:
python coinpark.py 8866
Nó cũng có thể được xem như một robot thông thường chạy trên đĩa tương tự mà không phải trả phí.
2.在FMZ网站配置交易所
Các sàn giao dịch được cấu hình như sau:)
Vì tài khoản không có tài sản và không được kiểm tra chi tiết, xin chào phản hồi Bug
2018.6.26 15:57 Cập nhật, sửa đổi Bug
#!/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()
Có liên quan
- 练习01.RSI
- Python theo đuổi phiên bản chiến lược giết chết và rơi (giảng dạy) @binanUSDT Hợp đồng vĩnh viễn
- Địa chỉ: http://t.co/vcvc3vc3vc0
- Đăng ký OKCoin máy thu hoạch cải bắp bình luận phiên bản Python
- Đặt cược cố định cho người mới bắt đầu khoảng 100USDT mỗi tuần - khoản không cố định thường xuyên (100USDT Invested Every Week - Regular Variable Investment)
- 100USDT mỗi tuần - khoản định kỳ (100USDT Invested Every Week - Regular Fixed Investment)
- Các sàn giao dịch đánh đổi tỷ lệ quay ngược
- Phiên bản thử nghiệm biểu đồ phức tạp
- Chiến lược quyết định
- Đặt giá mua bán
- Lưu trữ cục bộ
Thêm nữa
- Chiến lược lưới 50 dòng (giảng dạy)
- Dual Thrust OKEX tương lai (dạy)
- [VNC] SVM Test
- Số lượng và độ chính xác tối thiểu của sàn giao dịch
- Fomo3D Smart Contract Monitoring / Fomo3D Giám sát hợp đồng thông minh
- Tính năng API nâng cao BitMEX (tiền tương lai: đặt hàng hàng loạt, hủy bỏ một nút) JavaScript
- Người mới bắt đầu giao dịch CoinEx (LTC_USDT)
- Iceberg mua lệnh
- Tính năng OKEX đẩy kép
- Trung bình di chuyển Bot 30 dòng
- Kiểm tra xem https://quant.la/Argus/ có ổn không
- Binance bán tất cả các đồng xu giả
- Tiếp tục săn lùng
- Chỉ số số hóa
- Số lượng giao dịch tối thiểu của đồng xu okex
- Mạng lưới một bên
- Kiểm tra nhiều biểu đồ hiển thị phiên bản Python
- Tài khoản hợp đồng okex-BTC được công bố
- Chỉ số đồng xu sòng bạc ((2018.02.22 điểm cơ bản 1000)
- Thay thế cho hàm GetMinStock (*) đã bị loại bỏ
bông hoa hồngXin chào, bạn có thể giúp thay đổi phiên bản của Allcoin không, địa chỉ là www.allcoin.ca, hoặc bạn cho tôi biết nơi tôi cần thay đổi, cảm ơn rất nhiều!
812526825@qq.comĐược thử nghiệm, hoạt động hoàn hảo.
Avalon666Có phải là anh trai nhỏ của Grass không?
Cỏ nhỏPhải.