【ETH自動積立】Bitflyerでイーサリアムを自動積立

こんにちわ、Heywaです。

前回ビットコインの自動積立をするスクリプトを作成し、うまく動いているので、今度はイーサを積立するスクリプトにチャレンジしてみました。

ちょうどCoincheckで積立サービスがアナウンスされたところでタイムリーですが、ビットコインのみが対象のようなので、他の通貨も積み立てたい方は参考にしていただければ嬉しいです。

コード
使い方
後記

コード

前回のビットコイン積立のスクリプトのペアを変更しただけです。手抜きですいません。。。

import ccxt
import time
from pprint import pprint
import csv
import configparser
import datetime
import calendar
import pandas as pd
import numpy
import os
import json
import requests
import sys

from pysnooper import snoop
@snoop()


def ccxtAPIobj(): #CCXT を呼び出す関数
    ccxtAPIobj = ccxt.bitflyer({
 
        #APIキーをご自分のものに差し替えてください
       'apiKey': 'apikey',
       'secret': 'secret',
       
       })
    
    return ccxtAPIobj

def LINENotifysend(message): #LINENotifyで通知を送る関数
    url = "https://notify-api.line.me/api/notify"
    access_token = 'access_token' #発行したAccess Token
    headers = {'Authorization': 'Bearer ' + access_token}

    message = message
    payload = {'message': message}
    r = requests.post(url, headers=headers, params=payload,)


if __name__ == '__main__':
    #変数定義
    ##通貨ペア
    # pair = "BTC/JPY"
    # product_code = "BTC_JPY"
    pair = "ETH/JPY"
    product_code = "ETH_JPY"
    ##積立金額
    AccumulationJPY = 300
    ##口座情報
    myaccount = {}
    #Ticker情報
    price = {}

    print('処理開始')
    #時間計測
    start = time.time()

    #口座情報を取得
    # bitflyerのAPIを実行
    balance = ccxtAPIobj().fetch_balance()
    pprint(balance)
    #JPY保有量格納
    # JPY総額
    myaccount['JPYtotal'] = round(balance['JPY']['total'], 0)
    print("# JPY総額:" + str(myaccount['JPYtotal']))
    # JPY拘束中(必要証拠金)
    myaccount['JPYused'] = round(balance['JPY']['used'], 0)
    print("# JPY拘束中:" + str(myaccount['JPYused']))
    # ETH使用可能
    myaccount['JPYfree'] = round(balance['JPY']['free'], 4)
    print("# JPY使用可能:" + str(myaccount['JPYfree']))
    #ETH保有量格納
    # ETH総額
    myaccount['ETHtotal'] = round(balance['ETH']['total'], 4)
    print("# ETH総額:" + str(myaccount['ETHtotal']))
    # ETH拘束中(必要証拠金)
    myaccount['ETHused'] = round(balance['ETH']['used'], 4)
    print("# ETH拘束中:" + str(myaccount['ETHused']))
    # ETH使用可能
    myaccount['ETHfree'] = round(balance['ETH']['free'], 4)
    print("# ETH使用可能:" + str(myaccount['ETHfree']))


    #利用可能金額が積立金額を下回っていた場合にはメッセージを表示して終了する
    if myaccount['JPYtotal'] < AccumulationJPY:
        # print("入金金額が積立金額を下回っているので処理を中止しました。入金してください")
        # print("# JPY総額:" + str(myaccount['JPYtotal']))
        # print("# 積立金額:" + str(AccumulationJPY))
        message = "【Bitflyer積立】入金金額が積立金額を下回っているので処理を中止しました。入金してください" + "\n"
        message = message + "# JPY総額:" + str(myaccount['JPYtotal']) + "\n"
        message = message + "# 積立金額:" + str(AccumulationJPY) + "\n"
        print(message)
        LINENotifysend(message)
        sys.exit()       


    #現在価格を取得
    ##Tickerの取得
    print("#Tickerの取得")
    ticker = ccxtAPIobj().fetch_ticker(pair, params = { "product_code" : product_code })
    #pprint(ticker)
    #Json から要素へアクセス
    price['Bid'] = ticker['bid']
    price['Ask'] = ticker['ask']
    price['last'] = ticker['last']
    print("Bid=「売る」。Ask=「買う」")
    print("Bid")
    print(price['Bid'])
    print("Ask")
    print(price['Ask'])
    print("last")
    print(price['last'])
    ################

    #設定された積立金額で購入可能な量を算出
    buy_lot = AccumulationJPY / price['Bid']
    #積立金額で購入不可の場合はメッセージを表示して終了する
    ##【参考】bitflyerの最小購入数量
    ##https://bitflyer.com/ja-jp/faq/4-5
    ##Lightning 現物（ETH/JPY）における最小発注数量は 0.01 ETH
    ##Lightning 現物（BTC/JPY）における最小発注数量は 0.001 BTC
    ##購入可否判定
    ###成り行き注文なので、少し余裕をもたせて0.011ETHで判定する
    if buy_lot < 0.011:
        ##メッセージ表示
        # print("積立金額で最低購入枚数を購入できないので処理を中止しました。積立金額を修正してください")
        # print("# ETH価格:" + str(price['Bid']))
        # print("# 積立金額:" + str(AccumulationJPY))
        message = "【Bitflyer積立】積立金額で最低購入枚数を購入できないので処理を中止しました。積立金額を修正してください" + "\n"
        message = message + "# ETH価格:" + str(price['Bid']) + "\n"
        message = message + "# 積立金額:" + str(AccumulationJPY) + "\n"
        print(message)
        LINENotifysend(message)
        sys.exit()
    
    #購入可能な場合、成り行き買い注文を入れる
    print("#成行き買い")
    buy_lot = round(buy_lot, 3)
    buymarket = ccxtAPIobj().createMarketBuyOrder (pair , buy_lot,{ "product_code" : product_code })
    pprint(buymarket)

    #注文した数量、価格のメッセージを表示する
    ##注文後の数量、金額については計算した値を表示する
    print("積立注文が完了しました")
    myaccount['JPYdiff'] = myaccount['JPYtotal'] - AccumulationJPY
    myaccount['ETHtotal2'] = myaccount['ETHtotal'] + buy_lot
    print("# JPY残額:" + str(myaccount['JPYdiff']))
    print("# ETH総額:" + str(myaccount['ETHtotal2']))
    message = "【Bitflyer積立】注文が完了しました" + "\n"
    message = message + "# JPY残額:" + str(myaccount['JPYdiff'])+ "\n"
    message = message + "# ETH総額:" + str(myaccount['ETHtotal2']) + "\n"
    LINENotifysend(message)
    print("処理終了")
    elapsed_time = time.time() - start
    print ("elapsed_time:{0}".format(elapsed_time) + "[sec]")

100

101

102

103

104

105

106

107

108

109

110

111

112

113

114

115

116

117

118

119

120

121

122

123

124

125

126

127

128

129

130

131

132

133

134

135

136

137

138

139

140

141

142

143

144

145

146

147

148

149

150

151

152

153

154

155

importccxt

importtime

frompprintimportpprint

importcsv

importconfigparser

importdatetime

importcalendar

importpandasaspd

importnumpy

importos

importjson

importrequests

importsys

frompysnooperimportsnoop

@snoop()

defccxtAPIobj():#CCXT を呼び出す関数

ccxtAPIobj=ccxt.bitflyer({

#APIキーをご自分のものに差し替えてください

'apiKey':'apikey',

'secret':'secret',

})

returnccxtAPIobj

defLINENotifysend(message):#LINENotifyで通知を送る関数

url="https://notify-api.line.me/api/notify"

access_token='access_token'#発行したAccess Token

headers={'Authorization':'Bearer '+access_token}

message=message

payload={'message':message}

r=requests.post(url,headers=headers,params=payload,)

if__name__=='__main__':

#変数定義

##通貨ペア

# pair = "BTC/JPY"

# product_code = "BTC_JPY"

pair="ETH/JPY"

product_code="ETH_JPY"

##積立金額

AccumulationJPY=300

##口座情報

myaccount={}

#Ticker情報

price={}

print('処理開始')

#時間計測

start=time.time()

#口座情報を取得

# bitflyerのAPIを実行

balance=ccxtAPIobj().fetch_balance()

pprint(balance)

#JPY保有量格納

# JPY総額

myaccount['JPYtotal']=round(balance['JPY']['total'],0)

print("# JPY総額:"+str(myaccount['JPYtotal']))

# JPY拘束中(必要証拠金)

myaccount['JPYused']=round(balance['JPY']['used'],0)

print("# JPY拘束中:"+str(myaccount['JPYused']))

# ETH使用可能

myaccount['JPYfree']=round(balance['JPY']['free'],4)

print("# JPY使用可能:"+str(myaccount['JPYfree']))

#ETH保有量格納

# ETH総額

myaccount['ETHtotal']=round(balance['ETH']['total'],4)

print("# ETH総額:"+str(myaccount['ETHtotal']))

# ETH拘束中(必要証拠金)

myaccount['ETHused']=round(balance['ETH']['used'],4)

print("# ETH拘束中:"+str(myaccount['ETHused']))

# ETH使用可能

myaccount['ETHfree']=round(balance['ETH']['free'],4)

print("# ETH使用可能:"+str(myaccount['ETHfree']))

#利用可能金額が積立金額を下回っていた場合にはメッセージを表示して終了する

ifmyaccount['JPYtotal']<AccumulationJPY:

# print("入金金額が積立金額を下回っているので処理を中止しました。入金してください")

# print("# JPY総額:" + str(myaccount['JPYtotal']))

# print("# 積立金額:" + str(AccumulationJPY))

message="【Bitflyer積立】入金金額が積立金額を下回っているので処理を中止しました。入金してください"+"\n"

message=message+"# JPY総額:"+str(myaccount['JPYtotal'])+"\n"

message=message+"# 積立金額:"+str(AccumulationJPY)+"\n"

print(message)

LINENotifysend(message)

sys.exit()

#現在価格を取得

##Tickerの取得

print("#Tickerの取得")

ticker=ccxtAPIobj().fetch_ticker(pair,params={"product_code":product_code})

#pprint(ticker)

#Json から要素へアクセス

price['Bid']=ticker['bid']

price['Ask']=ticker['ask']

price['last']=ticker['last']

print("Bid=「売る」。Ask=「買う」")

print("Bid")

print(price['Bid'])

print("Ask")

print(price['Ask'])

print("last")

print(price['last'])

################

#設定された積立金額で購入可能な量を算出

buy_lot=AccumulationJPY/price['Bid']

#積立金額で購入不可の場合はメッセージを表示して終了する

##【参考】bitflyerの最小購入数量

##https://bitflyer.com/ja-jp/faq/4-5

##Lightning 現物（ETH/JPY）における最小発注数量は 0.01 ETH

##Lightning 現物（BTC/JPY）における最小発注数量は 0.001 BTC

##購入可否判定

###成り行き注文なので、少し余裕をもたせて0.011ETHで判定する

ifbuy_lot<0.011:

##メッセージ表示

# print("積立金額で最低購入枚数を購入できないので処理を中止しました。積立金額を修正してください")

# print("# ETH価格:" + str(price['Bid']))

# print("# 積立金額:" + str(AccumulationJPY))

message="【Bitflyer積立】積立金額で最低購入枚数を購入できないので処理を中止しました。積立金額を修正してください"+"\n"

message=message+"# ETH価格:"+str(price['Bid'])+"\n"

message=message+"# 積立金額:"+str(AccumulationJPY)+"\n"

print(message)

LINENotifysend(message)

sys.exit()

#購入可能な場合、成り行き買い注文を入れる

print("#成行き買い")

buy_lot=round(buy_lot,3)

buymarket=ccxtAPIobj().createMarketBuyOrder(pair,buy_lot,{"product_code":product_code})

pprint(buymarket)

#注文した数量、価格のメッセージを表示する

##注文後の数量、金額については計算した値を表示する

print("積立注文が完了しました")

myaccount['JPYdiff']=myaccount['JPYtotal']-AccumulationJPY

myaccount['ETHtotal2']=myaccount['ETHtotal']+buy_lot

print("# JPY残額:"+str(myaccount['JPYdiff']))

print("# ETH総額:"+str(myaccount['ETHtotal2']))

message="【Bitflyer積立】注文が完了しました"+"\n"

message=message+"# JPY残額:"+str(myaccount['JPYdiff'])+"\n"

message=message+"# ETH総額:"+str(myaccount['ETHtotal2'])+"\n"

LINENotifysend(message)

print("処理終了")

elapsed_time=time.time()-start

print("elapsed_time:{0}".format(elapsed_time)+"[sec]")

使い方

前回のビットコイン積立と同じですので、前回記事を御覧ください。

（ご利用は自己責任でお願いします）

Bitflyerでビットコインを自動積立できるBot作成

こんにちは。Heywaです。2009年にビットコインが誕生して以来、暗号通貨の価値は10倍以上に跳ね上がりました。仮想通貨の概念は、取引をより安全に、透明に、匿名で行うために導入されました。今日の投資の世界で最大のトレンドであることは間違い

後記

ビットフライヤーはBTCとETHしかAPIで現物取引できないので、この取引所で自動積立できるのは今のところ二種のみになりそうです。

ビットバンクだとネムやリップルも購入できそうなので、機会があれば試してみたいと思います。

あとは、「XX日間の安値を更新したら積み立てる」などのロジックを入れてみると積立結果がどうなるか、シミュレーションしてみてもいいかなと考えています。

記事を読んでプログラミングに興味を持った方は、ぜひプログラミングを学んで貰えれば幸いです。きっとあなたの人生に役に立つはずです。

以下のような本の他にも、一度挫折した人向けの質問できるサービスやスクールも充実してきていますので、非常に学びやすい時代になってきていると思います。

posted with カエレバ