スポンサードリンク
Contents
ビットコインAPIで取得した板方法をpandasに突っ込んでみた
bitFlyer, Zaif, coincheckの
各ビットコイン取引所で
提供されているAPIを呼び出す
Pythonプログラムを作ってきました。
今回は、取得した板情報を使いやすいように
pandasに突っ込む処理を実装してみました。
bitFlyer
以前作成したプログラムをカスタマイズしています。
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 |
# -*- coding: utf-8 -*- """ Created on Thu Mar 9 12:00:27 2017 @author: ichizo """ from pubnub.pnconfiguration import PNConfiguration from pubnub.pubnub import PubNub, SubscribeListener import json import requests import time import hmac import hashlib import util class bitflyerApi: def __init__(self): self.api_key = 'APIキー' self.api_secret = 'APIシークレット' self.api_endpoint = 'https://api.bitflyer.jp' def get_api_call(self,path): method = 'GET' timestamp = str(time.time()) text = timestamp + method + path sign = hmac.new(bytes(self.api_secret.encode('ascii')), bytes(text.encode('ascii')), hashlib.sha256).hexdigest() request_data=requests.get( self.api_endpoint+path ,headers = { 'ACCESS-KEY': self.api_key, 'ACCESS-TIMESTAMP': timestamp, 'ACCESS-SIGN': sign, 'Content-Type': 'application/json' }) return request_data def post_api_call(self,path,body): body = json.dumps(body) method = 'POST' timestamp = str(time.time()) text = timestamp + method + path + body sign = hmac.new(bytes(self.api_secret.encode('ascii')), bytes(text.encode('ascii')), hashlib.sha256).hexdigest() request_data=requests.post( self.api_endpoint+path ,data= body ,headers = { 'ACCESS-KEY': self.api_key, 'ACCESS-TIMESTAMP': timestamp, 'ACCESS-SIGN': sign, 'Content-Type': 'application/json' }) return request_data """ channel: 'lightning_ticker_BTC_JPY' """ def pubnub_call(self,channel): pnconfig = PNConfiguration() pnconfig.subscribe_key = "sub-c-52a9ab50-291b-11e5-baaa-0619f8945a4f" pnconfig.ssl = False pubnub = PubNub(pnconfig) my_listener = SubscribeListener() pubnub.add_listener(my_listener) pubnub.subscribe().channels(channel).execute() my_listener.wait_for_connect() bf_result = my_listener.wait_for_message_on(channel) bf_data = bf_result.message pubnub.unsubscribe().channels(channel).execute() my_listener.wait_for_disconnect() return bf_data def get_board(self): api = bitflyerApi() result = api.pubnub_call('lightning_board_snapshot_BTC_JPY') bids = util.util.dict_to_pd(result['bids'],'bf') asks = util.util.dict_to_pd(result['asks'],'bf') return bids,asks def get_balance(self): api = bitflyerApi() result = api.get_api_call('/v1/me/getbalance').json() print('bitFlyer Balance:') data = {} for row in result: if (row['currency_code'] == 'JPY'): data['jpy_amount'] = float(row['amount']) data['jpy_available'] = float(row['available']) elif (row['currency_code'] == 'BTC'): data['btc_amount'] = float(row['amount']) data['btc_available'] = float(row['available']) print(data) return data def order(self,data): api = bitflyerApi() result = api.post_api_call('/v1/me/sendchildorder',data).json() return result |
Zaif
これも、以前作成したプログラムを修正しています。
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 |
# -*- coding: utf-8 -*- """ Created on Fri Mar 10 14:37:22 2017 @author: ichizo """ from zaifapi import ZaifPublicApi, ZaifPrivateApi import util class zaifApi: def __init__(self): self.api_key = 'APIキー' self.api_secret = 'APIシークレット' def get_board(self): zaif = ZaifPublicApi() result = zaif.depth('btc_jpy') bids = util.util.list_to_pd(result['bids'],'zf') asks = util.util.list_to_pd(result['asks'],'zf') return bids,asks def get_balance(self): zaif = ZaifPrivateApi(self.api_key, self.api_secret) result = zaif.get_info() data = {} data['jpy_amount'] = float(result['funds']['jpy']) data['jpy_available'] = float(result['funds']['jpy']) data['btc_amount'] = float(result['funds']['btc']) data['btc_available'] = float(result['funds']['btc']) return data """ trade(currency_pair="btc_jpy",action="bid",price=5000,amount=0.001) """ def order(self,data): zaif = ZaifPrivateApi(self.api_key, self.api_secret) return zaif.trade(data) |
coincheck
こちらも以前作成したプログラムを修正しています。
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 |
# -*- coding: utf-8 -*- """ Created on Thu Mar 9 12:00:27 2017 @author: ichizo """ import json import requests import time import hmac import hashlib import util class coincheckApi: def __init__(self): self.api_key = 'APIキー' self.api_secret = 'APIシークレット' self.api_endpoint = 'https://coincheck.com' def get_api_call(self,path): timestamp = str(int(time.time())) text = timestamp + self.api_endpoint + path sign = hmac.new(bytes(self.api_secret.encode('ascii')), bytes(text.encode('ascii')), hashlib.sha256).hexdigest() request_data=requests.get( self.api_endpoint+path ,headers = { 'ACCESS-KEY': self.api_key, 'ACCESS-NONCE': timestamp, 'ACCESS-SIGNATURE': sign, 'Content-Type': 'application/json' }) return request_data def post_api_call(self,path,body): body = json.dumps(body) timestamp = str(int(time.time())) text = timestamp + self.api_endpoint + path + body sign = hmac.new(bytes(self.api_secret.encode('ascii')), bytes(text.encode('ascii')), hashlib.sha256).hexdigest() request_data=requests.post( self.api_endpoint+path ,data= body ,headers = { 'ACCESS-KEY': self.api_key, 'ACCESS-NONCE': timestamp, 'ACCESS-SIGNATURE': sign, 'Content-Type': 'application/json' }) return request_data def get_board(self): api = coincheckApi() result = api.get_api_call('/api/order_books').json() bids = util.util.list_to_pd(result['bids'],'cc') asks = util.util.list_to_pd(result['asks'],'cc') return bids,asks def get_balance(self): api = coincheckApi() result = api.get_api_call('/api/accounts/balance').json() data = {} data['jpy_amount'] = float(result['jpy']) data['jpy_available'] = float(result['jpy']) - float(result['jpy_reserved']) data['btc_amount'] = float(result['btc']) data['btc_available'] = float(result['btc']) - float(result['btc_reserved']) return data def order(self,data): api = coincheckApi() result = api.post_api_call('/api/exchange/orders',data).json() return result |
共通部品
bitflyerApi.py, zaifApi.py, coincheckApi.py の
それぞれのプログラム内で使用している共通部品です。
APIで返ってきた板情報をpandasのDataFrameに
セットして返す処理を行っています。
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 |
# -*- coding: utf-8 -*- """ Created on Sun Mar 12 20:56:18 2017 @author: ichizo """ import pandas as pd class util: def dict_to_pd(datas,code): price = [] size = [] code = [] for data in datas: price.append(float(data['price'])) size.append(float(data['size'])) code.append(code) vals = pd.DataFrame([price,size,code]).T vals.columns = ["price","size","code"] return vals def list_to_pd(datas,code): price = [] size = [] code = [] for data in datas: price.append(float(data[0])) size.append(float(data[1])) code.append(code) vals = pd.DataFrame([price,size,code]).T vals.columns = ["price","size","code"] return vals |
その他
あとは、QUOINEのAPIを使う処理を実装したいのですが、
Private APIの呼び出しでつまづいています。
多分、Token IDの指定が良くないんだろうなと思いつつ、
何をセットすればいいのか分かんないのです。
APIトークンを生成したときに表示されている
ID（5桁の数字）でいいのかな～？
ご存知の方いらっしゃったら教えてください！
QUOINEのサポートにメッセージを送ったのですが、
ちょうど土日を挟んでしまって返信待ちの状態です・・・。
ココを見ると「USERID」と書いているので
やっぱり5桁の数字なんでしょうか・・・。
いずれにしても、もうちょっと弄ってみます。
2017/3/13 追記
ソースコードは変えずに次の日に接続してみたところ
何事もなく接続できたので
QUOINE側で何らかの処理があったのかもしれません。
登録（もしくは本人確認書類の提出）から
日が浅かったために、それらの承認後に
APIが有効になったということでしょうか。
スポンサードリンク