にゃんきち日和仮想通貨の売買ライブラリをCCXT(CryptoCurrency eXchange Trading Library)に変更しました。
CCXTは、APIを公開している各取引所の売買処理を、ほぼ同じインタフェースで使えるようにしたライブラリです。各取引所のAPIによっては提供有無や、仕様が違っている部分もあるため、ほぼ同じインタフェースとなります。それでも各取引所のAPIを駆使するのより簡単になりますし、別の取引所に変更する場合、修正量が少なくて済むと思います。
今回も、ビットコインで、取引所はzaifとしています。
また、ライブラリを変更した序でに、単純移動平均線、MACDの部分を別モジュールしており、売買処理部分もサブルーチン化しています。
売買処理のサブルーチンは、呼び出す部分をコメントアウトしているので動かないですが、購入申請が動くのは単体で確認しています。
slack通知部分もサブルーチン化しています。
スポンサードリンク
15秒間隔で市場価格を取得を想定しているため正しいMACDにはなっていないかもしれません。1分足に近くなるようにパラメータは以下のようのしています。
プログラムを動かしてみるとわかるのですが、必ずしも15秒間隔で取得できていません。APIがエラーになったり、応答時間が長くなったりしているためです。zaifを使っているとAPIエラー、応答時間の遅延が発生することが多く感じます。
単純移動平均線、ボリンジャーバンド、MACDのパラメータ
約1分足にするには、
PERIOD2 = 104 # 長期移動平均線＆ボリンジャーバンドの間隔数 ※ LOOP_CNT26と同じにするLOOP_CNT9 = 36 # MACD9のための定数(15秒間隔なので36)
LOOP_CNT12 = 48 # EMA12のための定数(15秒間隔なので48)
LOOP_CNT26 = 104 # EMA26のための定数(15秒間隔なので104)
約2分速にする場合は以下にします。
約2分足にするには、
PERIOD2 = 208LOOP_CNT9 = 72
LOOP_CNT12 = 96
LOOP_CNT26 = 208
- 情報収集が目的に作成しているプログラムです。
- プライベートAPIは動かないようにしているため、売買は指定された価格、コイン数で必ず約定されるように動きます。このため、本当の売買とは動きが違うことを認識しておいてください。
実際に売買動作させると、利確したいのにキャンセルになり、損切りに変わったりする場合があります。 - プログラム開始時点の資産はプログラム内で指定しています。
動作環境
pythonが動くなら大丈夫だと思いますが、私の動作環境としては、NCU(4コア)に、ESXiを導入した仮想サーバーを持っているため、windows7(2仮想CPU/4GBメモリ) をインストールして常時稼働させています。リモートディスクトップは、高速リモートディスクトップ「Yule」を使っています。
python 3.6.4 は、Anaconda version 5.2.0 を導入しています。
スポンサードリンク
コード
注意
プライベートAPIはコメントアウトしていますが、テスト用部分を削除してAPIコメントアウトを生かすと売買することも可能ですが、動作確認が済んでいません。使用する場合は自己責任でお願いします。コードをコピーするのも大変なので、GitHubに置いておきます。
key.jsonの作成
config/key.json
プライベートAPIを使わないのですが、zaif_keyとzaif_secretはプラグラム的に必要なので以下のように適当に指定してください。
slack_webhook_urlは、取得したURLを指定してください。
{
"zaif_key": "xxxxxxxx-xxxx-xxxx-xxxx-xxxxxxxxxxxx",
"zaif_secret": "xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx",
"slack_webhook_url": "https://取得したURL"
}
※ slack_webhook_urlのURLに、"hooks.slack.com"を含まなければ、slack通知処理はスキップされます。
SMA_BB.py
単純移動平均線とボリンジャーバンドを取得するクラス
# coding=utf-8
"""
このモジュールでは 単純移動平均(SMA)、ボリンジャーバンド(BB) を実装しています。
カレントの価格を加味しています。
"""
import numpy as np
class SimpleMovingAverageBollingerBand:
"""
単純移動平均(SMA)、ボリンジャーバンド(BB)のクラスです。
"""
def __init__(self, period1=12, period2=104):
"""
移動平均線とボリンジャーバンド
:param period1: 短期SMA
:param period2: 長期SMA
"""
self.__count = 0
self.__period1 = period1
self.__period2 = period2
self.__avg1 = 0
self.__avg2 = 0
self.__sigma = 0
self.__avg1_pre = 0
self.__avg2_pre = 0
self.__sigma_pre = 0
self.__MAL1 = []
self.__MAL2 = []
for var in range(0, self.__period1):
self.__MAL1.append(0.00000)
for var in range(0, self.__period2):
self.__MAL2.append(0.00000)
def add(self, price):
"""
仮想通貨のカレントプライスを追加し、移動平均線、ボリンジャーバンドを戻す
:param price: カレントプライス
:return: 短期移動平均、長期移動平均、ボリンジャーバンド、一つ前の短期移動平均、一つ前の長期移動平均、一つ前のボリンジャーバンド
"""
# self.__avg1 = np.average(self.__MAL1)
# self.__avg2 = np.average(self.__MAL2)
# self.__sigma = np.std(self.__MAL2, ddof=1)
self.__count += 1
for var in range(0, self.__period1 - 1):
self.__MAL1[var] = self.__MAL1[var + 1]
self.__MAL1[self.__period1 - 1] = price
for var in range(0, self.__period2 - 1):
self.__MAL2[var] = self.__MAL2[var + 1]
self.__MAL2[self.__period2 - 1] = price
if self.__count <= self.__period2 + 1:
self.__avg1 = np.average(self.__MAL1)
self.__avg2 = np.average(self.__MAL2)
self.__sigma = np.std(self.__MAL2, ddof=1)
return False, 0, 0, 0, 0, 0, 0
else:
self.__avg1_pre = self.__avg1
self.__avg2_pre = self.__avg2
self.__sigma_pre = self.__sigma
self.__avg1 = np.average(self.__MAL1)
self.__avg2 = np.average(self.__MAL2)
self.__sigma = np.std(self.__MAL2, ddof=1)
return True, self.__avg1, self.__avg2, self.__sigma, self.__avg1_pre, self.__avg2_pre, self.__sigma_pre
MACD.py
MACDとシグナルを取得するクラス
# coding=utf-8
"""
このモジュールでは MACD(Moving Average Convergence Divergence)を実装しています。
"""
class MovingAverageConvergenceDivergence:
"""
MACD(Moving Average Convergence Divergence)のクラスです。
"""
def __init__(self, cnt9=36, cnt12=48, cnt26=104):
"""
MACD(Moving Average Convergence Divergence)の初期化
:param cnt9: シグナル
:param cnt12: 短期EMA
:param cnt26: 長期EMA
"""
self.__count = 0
self.__LOOP_CNT9 = cnt9
self.__LOOP_CNT12 = cnt12
self.__LOOP_CNT26 = cnt26
self.__A12AAA = 2 / (cnt12 + 1.0000)
self.__A26AAA = 2 / (cnt26 + 1.0000)
self.__SMA12_AVE = 0.0000
self.__SMA26_AVE = 0.0000
self.__MACD9_AVE = 0.0000
self.__MACD = 0.0
self.__MACD9_AVE_pre = 0.0000
self.__MACD_pre = 0.0
self.__SMA12 = []
self.__SMA26 = []
self.__EMA12 = []
self.__EMA26 = []
self.__MACD9 = []
for var in range(0, self.__LOOP_CNT12):
self.__SMA12.append(self.__SMA12_AVE)
for var in range(0, self.__LOOP_CNT26):
self.__SMA26.append(self.__SMA12_AVE)
for var in range(0, self.__LOOP_CNT12):
self.__EMA12.append(self.__SMA12_AVE)
for var in range(0, self.__LOOP_CNT26):
self.__EMA26.append(self.__SMA12_AVE)
for var in range(0, self.__LOOP_CNT9):
self.__MACD9.append(self.__SMA12_AVE)
def add(self, price):
"""
仮想通貨のカレントプライスを追加し、MACD,Signalを戻す
:param price: カレントプライス
:return: MACD, SIGNAL, 一つ前のMACD, 一つ前のSIGNAL
"""
self.__count += 1
if self.__count <= self.__LOOP_CNT26:
for var in range(self.__LOOP_CNT12 - 1, 0, -1):
self.__SMA12[var] = self.__SMA12[var - 1]
for var in range(self.__LOOP_CNT26 - 1, 0, -1):
self.__SMA26[var] = self.__SMA26[var - 1]
self.__SMA12[0] = price
self.__SMA26[0] = price
sum12 = 0.0000
sum26 = 0.0000
for var in range(0, self.__LOOP_CNT12):
sum12 += self.__SMA12[var]
for var in range(0, self.__LOOP_CNT26):
sum26 += self.__SMA26[var]
self.__SMA12_AVE = sum12 / self.__LOOP_CNT12
self.__SMA26_AVE = sum26 / self.__LOOP_CNT26
return False, 0, 0, 0, 0
else:
self.__MACD_pre = self.__MACD
self.__MACD9_AVE_pre = self.__MACD9_AVE
# #######################EMAの算出#########################
for var in range(self.__LOOP_CNT12 - 1, 0, -1):
self.__EMA12[var] = self.__EMA12[var - 1]
for var in range(self.__LOOP_CNT26 - 1, 0, -1):
self.__EMA26[var] = self.__EMA26[var - 1]
# EMA ＝ B + α( A - B )
self.__SMA12_AVE = self.__SMA12_AVE + (self.__A12AAA * (price - self.__SMA12_AVE)) # EMA12
self.__SMA26_AVE = self.__SMA26_AVE + (self.__A26AAA * (price - self.__SMA26_AVE)) # EMA26
# print('__EMA12:', self.__SMA12_AVE)
# print('__EMS26:', self.__SMA26_AVE)
self.__EMA12[0] = self.__SMA12_AVE
self.__EMA26[0] = self.__SMA26_AVE
# #######################EMAの算出#########################
# #######################MACDの算出########################
self.__MACD = self.__SMA12_AVE - self.__SMA26_AVE # MACD ＝ 基準線(EMA) － 相対線(EMA)
for var in range(self.__LOOP_CNT9 - 1, 0, -1):
self.__MACD9[var] = self.__MACD9[var - 1]
self.__MACD9[0] = self.__MACD
sum9 = 0.0000
for var in range(0, self.__LOOP_CNT9):
sum9 += self.__MACD9[var]
self.__MACD9_AVE = sum9 / self.__LOOP_CNT9
# print('__MACD:', self.__MACD)
# print('__MACD9:', self.__MACD9_AVE)
# #######################MACDの算出########################
if self.__count == self.__LOOP_CNT26 + 1:
return False, 0, 0, 0, 0
else:
return True, self.__MACD, self.__MACD9_AVE, self.__MACD_pre, self.__MACD9_AVE_pre
main.py
# coding=utf-8
import json
import time
import codecs
import slackweb
import datetime
import ccxt
import SMA_BB
import MACD
import urllib.error
from decimal import (Decimal)
from logger import error_logger
from logger import trade_logger
# 本プログラムは、マルチ売買申請には対応していない。必ず1申請での処理となる。
# MACDの指標でのプログラムであり、実売買はしないが、売買ルーチンやオーダーチェックのルーチンは含まれています。
# ただし、実売買ルーチン等は、まだ実働させていないことに注意してください。
with codecs.open('config/key.json', 'r', 'utf-8') as f:
API_data = json.load(f)
WEBHOOK_URL = API_data["slack_webhook_url"]
slack_flag = 'hooks.slack.com' in WEBHOOK_URL
slack = slackweb.Slack(WEBHOOK_URL)
API_KEY = API_data["zaif_key"]
API_SECRET = API_data["zaif_secret"]
COIN_NAME = 'BTC'
COIN_PAIR = 'BTC/JPY'
EXCHANGE = 'Zaif:'
exchange = ccxt.zaif()
exchange.apiKey = API_KEY
exchange.secret = API_SECRET
trade_log = trade_logger.TradeLogger('zaif', COIN_NAME)
error_log = error_logger.ErrorLogger('error')
# 市場価格の取得間隔
loop_count = 0
LOOP_TIME = 15 # 市場価格取得間隔の秒数
# 移動平均線、ボリンジャーバンドの間隔数
PERIOD1 = 12 # 短期移動平均線
PERIOD2 = 104 # 長期移動平均線＆ボリンジャーバンドの間隔数 ※ LOOP_CNT26と同じにする
# MACDの間隔数
LOOP_CNT9 = 36 # MACD9のための定数(15秒間隔なので36)
LOOP_CNT12 = 48 # EMA12のための定数(15秒間隔なので48)
LOOP_CNT26 = 104 # EMA26のための定数(15秒間隔なので104)
# デットクロス売りに移行したかのフラグ
dead_cross_flag = False
# キャンセル処理への変数
CANCEL_LOOP_MAX = 4 # キャンセルするまでのループ回数 4x15=60秒
cancel_flag = False # 約定してない売買申請がある場合にキャンセル処理を動かすフラグ
cancel_loop_count = 0 # キャンセルまでのカウント
# 売買後にホールドする回数の変数
TRADE_HOLD_MAX = 4 # トレード直後に売買しないようにする回数 4x15=60秒
trade_hold_count = 0 # トレード後直ぐに売買処理しないようにするカウント
# 売買取引量、板情報に表示されてる売買量(情報収集)
bid_amount = 0.0 # 買い取引量
ask_amount = 0.0 # 売り取引量
bid_depth_amount = 0.0 # 板買い
ask_depth_amount = 0.0 # 板売り
# アセット
funds_jpy = 0 # 注文余力日本円
funds_coin = 0.0 # 注文余力コイン
start_funds_jpy = 0 # プログラム開始時の日本円
asset_info = False
# 最後のトレード情報
last_trade_func = '' # 取引機能
last_trade_order_id = 0 # 最後に取引したID
last_trade_size = 0.0 # 最後に取引したサイズ
last_trade_price = 0 # 最後に取引した価格
last_trade_price_pre = 0 # 一つ前の取引した価格(キャンセルした時用)
last_trade_type = 0 # 0:購入、1:利確1、2:利確2、3:損切り
# トレードログ用
message_func = ''
message_trade = ''
message_size = 0
message_price = 0.0
date_time = datetime.datetime.now() # print用表示タイム
# 現在の市場価格情報
current_price = 0 # 市場価格
current_price_pre = 0 # 前の市場価格
current_bid_price = 0 # 買い気配
current_ask_price = 0 # 売り気配
# プログラムの終了処理変数
END_FLAG = False # プログラムの終了フラグ
end_datetime = datetime.datetime.now() # 終了タイム
END_HOUR = 16 # 終了時
END_MINUTE = 30 # 終了分
#####################################
# テスト用 #
user_coin_asset = 0.0 # 実売買しないのでテスト用コイン資産
user_jpy_asset = 5000.0 # 実売買しないのでテスト用日本円資産
# #
#####################################
def order_limit_call(side, coin_amount, price):
"""
仮想通貨指値注文
繰り返しは5回までとしている。
:param side: 'buy','sell'
:param coin_amount: コイン数
:param price: 価格
:return: APIが正常応答したかのフラグ、オーダーID
"""
global exchange, COIN_PAIR, error_log
coin_float_amount = float(coin_amount)
for _a in range(5):
try:
if side == 'buy':
ccxt_result = exchange.create_limit_buy_order(COIN_PAIR, coin_float_amount, price)
elif side == 'sell':
ccxt_result = exchange.create_limit_sell_order(COIN_PAIR, coin_float_amount, price)
else:
return False, 0
except ccxt.RequestTimeout:
error_log.write()
print('エラー: call ', side, ' order timeout')
time.sleep(1)
except ccxt.ExchangeNotAvailable:
error_log.write()
print('エラー: call ', side, ' order NotAvailable')
time.sleep(1)
except ccxt.ExchangeError:
error_log.write()
print('エラー: call ', side, ' order ExchangeError')
time.sleep(1)
else:
return True, ccxt_result['id']
# エラーでも申請が通っている場合があるのでチェック(タイムアウトしてた時に一度発生した)
# 複数申請は無いプログラムでのチェック内容。
check_flag, check_id, check_status = order_check()
if check_flag and check_id != 0:
return True, check_id
for _b in range(5):
try:
ccxt_result = exchange.fetch_balance()
except ccxt.RequestTimeout:
error_log.write()
print('エラー:balance Timeout')
time.sleep(1)
except ccxt.ExchangeNotAvailable:
error_log.write()
print('エラー:balance NotAvailable')
time.sleep(1)
except ccxt.ExchangeError:
error_log.write()
print('エラー:balance ExchangeError')
time.sleep(1)
else:
if side == 'buy':
if ccxt_result['BTC']['total'] != 0:
return True, 0
else:
if ccxt_result['BTC']['total'] == 0:
return True, 0
else:
print('order_limit_call balance リトライ5回失敗')
return False, 0
else:
print('order_limit_call リトライ5回失敗')
return False, 0
def order_check():
"""
有効なオーダーがあるか確認
:return: APIが正常応答したかのフラグ、オーダーID、オーダーステータス
"""
global exchange, COIN_PAIR, error_log
for _c in range(10):
try:
ccxt_result = exchange.fetch_open_orders(COIN_PAIR)
except ccxt.RequestTimeout:
error_log.write()
print('エラー:cant open orders Timeout')
time.sleep(1)
except ccxt.ExchangeNotAvailable:
error_log.write()
print('エラー:cant open orders NotAvailable')
time.sleep(1)
except ccxt.ExchangeError:
error_log.write()
print('エラー:cant open orders ExchangeError')
time.sleep(1)
else:
if len(ccxt_result) == 0:
return True, 0, 0
else:
return True, ccxt_result[0]['id'], ccxt_result[0]['status']
else:
print('order_check リトライ10回失敗')
return False, 0, 0
def slack_notify(message):
"""
Slackへの通知
:param message: 通知メッセージ
"""
global slack_flag, slack, error_log
if slack_flag:
for _d in range(5):
try:
slack.notify(text=message)
except urllib.error.HTTPError:
error_log.write()
print("エラー:slack call HTTPError")
except urllib.error.URLError:
error_log.write()
print("エラー:slack call URLError")
else:
break
else:
print('slack call error')
if __name__ == '__main__':
sma_bb = SMA_BB.SimpleMovingAverageBollingerBand(PERIOD1, PERIOD2)
macd = MACD.MovingAverageConvergenceDivergence(LOOP_CNT9, LOOP_CNT12, LOOP_CNT26)
sma_flag = True
sma_avg1 = 0
sma_avg2 = 0
sma_sigma = 0
sma_avg1_pre = 0
sma_avg2_pre = 0
sma_sigma_pre = 0
macd_flag = True
macd_macd = 0
macd_signal = 0
macd_macd_pre = 0
macd_signal_pre = 0
order_flag = True
order_id = 0
order_status = 0
init_flag = False
while not init_flag:
try:
last_trade_price = int(exchange.fetch_ticker(COIN_PAIR)['last'])
# result = exchange.fetch_balance()
# start_funds_jpy = result['total']['JPY']
# if result['total'][COIN_NAME] != 0:
# start_funds_jpy += result['total'][COIN_NAME] * last_trade_price
# print('start jpy:', start_funds_jpy)
#####################################
# テスト用 #
start_funds_jpy = user_jpy_asset
# #
#####################################
except (ccxt.RequestTimeout, ccxt.ExchangeNotAvailable, ccxt.ExchangeError):
error_log.write()
continue
else:
init_flag = True
# 終了タイムを設定
date_time = datetime.datetime.now()
end_datetime = datetime.datetime(date_time.year, date_time.month, date_time.day, END_HOUR, END_MINUTE)
END_FLAG = False
if date_time > end_datetime:
end_datetime += datetime.timedelta(days=1)
print('END DATE TIME:', end_datetime)
profit_count = 0
loss_count = 0
while True:
message_func = ''
message_trade = ''
message_price = 0
message_size = 0.0
date_time = datetime.datetime.now()
start_time = time.time()
try:
# result = exchange.fetch_balance()
# funds_jpy = result['total']['JPY']
# funds_coin = Decimal(result['total'][COIN_NAME]).quantize(Decimal('0.0001'))
#####################################
# テスト用 #
funds_coin = user_coin_asset
funds_jpy = user_jpy_asset
# #
#####################################
result = exchange.fetch_ticker(COIN_PAIR)
current_price_pre = current_price
current_price = int(result['last'])
current_bid_price = int(result['bid'])
current_ask_price = int(result['ask'])
# trades
result = exchange.fetch_trades(COIN_PAIR)
bid_amount = 0
ask_amount = 0
for currency in result:
if currency['side'] == 'buy':
bid_amount += Decimal(float(currency['amount'])).quantize(Decimal('0.0001'))
if currency['side'] == 'sell':
ask_amount += Decimal(float(currency['amount'])).quantize(Decimal('0.0001'))
# depth
result = exchange.fetch_order_book(COIN_PAIR)
bid_depth_amount = 0
ask_depth_amount = 0
for currency in result['bids']:
bid_depth_amount += Decimal(float(currency[1])).quantize(Decimal('0.0001'))
for currency in result['asks']:
ask_depth_amount += Decimal(float(currency[1])).quantize(Decimal('0.0001'))
except ccxt.RequestTimeout:
error_log.write()
print("エラー:Cant get data Timeout")
time.sleep(1)
continue
except ccxt.ExchangeNotAvailable:
error_log.write()
print("エラー:Cant get data NotAvailable")
time.sleep(1)
continue
except ccxt.ExchangeError:
error_log.write()
print("エラー:Cant get data Error")
time.sleep(1)
continue
else:
loop_count += 1
sma_flag, sma_avg1, sma_avg2, sma_sigma, sma_avg1_pre, sma_avg2_pre, sma_sigma_pre \
= sma_bb.add(current_price)
macd_flag, macd_macd, macd_signal, macd_macd_pre, macd_signal_pre = macd.add(current_price)
if sma_flag:
print('■資産、平均線、ボリンジャーバンド、MACD', loop_count)
print(str(date_time))
print(COIN_NAME + '資産:', str(funds_coin))
print('jpy資産:', str(funds_jpy))
print('市場価格:', str(current_price))
print('市場買い気配:', str(current_bid_price))
print('市場売り気配:', str(current_ask_price))
print('平均 :', str(sma_avg2))
print('高偏差:', str(sma_avg2 + sma_sigma))
print('低偏差:', str(sma_avg2 - sma_sigma))
print('MACD', str(macd_macd))
print('SIGNAL', str(macd_signal))
print("最終取引価格:" + str(last_trade_price))
message_func = EXCHANGE + '資産、平均、標準偏差'
else:
print("■ 現在の情報です", loop_count)
print(str(date_time))
print("市場取引価格:" + str(current_price))
print("市場買い気配:" + str(current_bid_price))
print("市場売り気配:" + str(current_ask_price))
print(COIN_NAME + "資産:" + str(funds_coin))
print("jpy資産:" + str(funds_jpy))
print("最終取引価格:" + str(last_trade_price))
if asset_info or loop_count == 1:
if funds_coin < 0.0001 and last_trade_order_id == 0:
message_text = EXCHANGE + '現在の資産: ' + str(date_time) + '\njpy資産:'
message_text += str(funds_jpy) + '\n' + COIN_NAME + '資産:' + str(funds_coin)
message_text += '\nProfit:' + str(profit_count) + ' Loss:' + str(loss_count)
message_text += '\nGain:' + str(funds_jpy - start_funds_jpy)
else:
message_text = EXCHANGE + '現在の資産: ' + str(date_time) + '\njpy資産:'
message_text += str(funds_jpy) + '\n' + COIN_NAME + '資産:' + str(funds_coin)
message_text += '\nProfit:' + str(profit_count) + ' Loss:' + str(loss_count)
slack_notify(message_text)
asset_info = False
# コインを持っていて、デットクロス売り
if funds_coin >= 0.0001 and trade_hold_count > TRADE_HOLD_MAX and macd_macd < macd_signal \
and macd_macd_pre > macd_signal_pre and not dead_cross_flag:
if last_trade_price > current_price:
dead_cross_flag = True
message_text = EXCHANGE + '■ デットクロス処理移行: ' + str(date_time)
print(message_text)
slack_notify(message_text)
message_func += '、デットクロス処理移行'
else:
amount = funds_coin
# 売り
# order_flag, order_id = order_limit_call('sell', amount, current_price - 5)
#####################################
# テスト用 #
time.sleep(1)
user_coin_asset -= float(amount)
user_jpy_asset += ((current_price - 5) * float(amount))
order_flag = True
order_id = 0
# #
#####################################
if order_flag:
if order_id != 0:
cancel_flag = True
cancel_loop_count = 0
last_trade_func = 'ask'
last_trade_size = amount
last_trade_price_pre = last_trade_price
last_trade_price = current_price - 5
last_trade_order_id = order_id
trade_hold_count = 0
asset_info = True
dead_cross_flag = True
if last_trade_price_pre < last_trade_price:
profit_count += 1
last_trade_type = 2
else:
loss_count += 1
last_trade_type = 3
message_func += '、デットクロス'
message_trade = 'ask'
message_price = current_price - 5
message_size = amount
message_text = EXCHANGE + '■ デットクロス売却申請: ' + str(date_time)
message_text += '\nPrice:' + str(current_price - 5) + '\nSize:' + str(amount)
print(message_text)
slack_notify(message_text)
# コインを持っていて
if (dead_cross_flag and funds_coin >= 0.0001 and (current_price * 0.997) > last_trade_price
and trade_hold_count > TRADE_HOLD_MAX):
if current_price > current_price_pre and (current_price * 0.995) < last_trade_price:
print('上昇傾向なので保留')
message_func += '、上昇傾向'
else:
# 売却
amount = funds_coin
adjustment = 0
if current_price > current_price_pre:
adjustment = 10
elif current_price == current_price_pre:
adjustment = 5
else:
adjustment = 0
# 売り
# order_flag, order_id = order_limit_call('sell', amount, current_price - 5 + adjustment)
#####################################
# テスト用 #
time.sleep(1)
user_coin_asset -= float(amount)
user_jpy_asset += ((current_price - 5 + adjustment) * float(amount))
order_flag = True
order_id = 0
# #
#####################################
if order_flag:
if order_id != 0:
cancel_flag = True
cancel_loop_count = 0
last_trade_func = 'ask'
last_trade_size = amount
last_trade_price_pre = last_trade_price
last_trade_price = current_price - 5 + adjustment
last_trade_order_id = order_id
last_trade_type = 1
trade_hold_count = 0
asset_info = True
profit_count += 1
message_func += '、利確1'
message_trade = 'ask'
message_price = current_price - 5 + adjustment
message_size = amount
message_text = EXCHANGE + '■ 利確1売却申請: ' + str(date_time)
message_text += '\nPrice:' + str(current_price - 5 + adjustment)
message_text += '\nSize:' + str(amount)
print(message_text)
slack_notify(message_text)
# コインを持っていて平均より2%低い場合に損切り
elif (dead_cross_flag and funds_coin >= 0.0001 and trade_hold_count > TRADE_HOLD_MAX
and current_price < (last_trade_price * 0.998)):
amount = funds_coin
# 売り
# order_flag, order_id = order_limit_call('sell', amount, current_price - 5)
#####################################
# テスト用 #
time.sleep(1)
user_coin_asset -= float(amount)
user_jpy_asset += ((current_price - 5) * float(amount))
order_flag = True
order_id = 0
# #
#####################################
if order_flag:
if order_id != 0:
cancel_flag = True
cancel_loop_count = 0
last_trade_func = 'ask'
last_trade_size = amount
last_trade_price_pre = last_trade_price
last_trade_price = current_price - 5
last_trade_order_id = order_id
last_trade_type = 3
trade_hold_count = 0
asset_info = True
loss_count += 1
message_func += '、損切'
message_trade = 'ask'
message_price = current_price - 5
message_size = amount
message_text = EXCHANGE + '■ 損切売却申請: ' + str(date_time)
message_text += '\nPrice:' + str(current_price - 5) + '\nSize:' + str(amount)
print(message_text)
slack_notify(message_text)
# コインを最小単位持っていない場合で
elif (funds_coin < 0.0001 and trade_hold_count > TRADE_HOLD_MAX and last_trade_order_id == 0
and macd_macd > macd_signal and macd_macd_pre < macd_signal_pre):
amount = Decimal(funds_jpy * 0.9 / current_price).quantize(Decimal('0.0001'))
# 買い
# order_flag, order_id = order_limit_call('buy', amount, current_price)
#####################################
# テスト用 #
time.sleep(1)
user_coin_asset += float(amount)
user_jpy_asset -= (current_price * float(amount))
order_flag = True
order_id = 0
# #
#####################################
if order_flag:
if order_id != 0:
cancel_flag = True
cancel_loop_count = 0
last_trade_func = 'bid'
last_trade_size = amount
last_trade_price_pre = last_trade_price
last_trade_price = current_price
last_trade_order_id = order_id
last_trade_type = 0
trade_hold_count = 0
dead_cross_flag = False
asset_info = True
message_func += '、購入'
message_trade = 'bid'
message_price = current_price
message_size = amount
message_text = EXCHANGE + '■ 購入申請: ' + str(date_time)
message_text += '\nPrice:' + str(current_price) + '\nSize:' + str(amount)
print(message_text)
slack_notify(message_text)
if cancel_flag and cancel_loop_count > CANCEL_LOOP_MAX:
order_flag, order_id, order_status = order_check()
if order_flag:
if order_id == 0:
print("■ 約定しました。")
message_func += '、約定'
message_text = EXCHANGE + '■ 約定しました'
slack_notify(message_text)
asset_info = True
last_trade_order_id = 0
cancel_flag = False
else:
try:
print("■ キャンセルしました")
print(exchange.cancel_order(order_id, COIN_PAIR))
except (ccxt.RequestTimeout, ccxt.ExchangeNotAvailable, ccxt.ExchangeError):
error_log.write()
print("エラー:cant trade[info/cancel]")
else:
trade_hold_count = TRADE_HOLD_MAX
last_trade_price = last_trade_price_pre
message_func += '、キャンセル'
message_text = EXCHANGE + '■ キャンセルしました'
slack_notify(message_text)
asset_info = True
if last_trade_type == 1 or last_trade_type == 2:
profit_count -= 1
elif last_trade_type == 3:
loss_count -= 1
last_trade_type = 0
last_trade_order_id = 0
cancel_flag = False
if sma_flag:
trade_log.write(
func=message_func,
coin_asset=funds_coin,
jpy_asset=funds_jpy,
market_price=current_price,
market_bid_price=current_bid_price,
market_ask_price=current_ask_price,
order_id=last_trade_order_id,
trade=message_trade,
last_trade_price=last_trade_price,
price=message_price,
size=message_size,
mean_line1=sma_avg1,
mean_line2=sma_avg2,
bid_amount=bid_amount,
ask_amount=ask_amount,
bid_depth_amount=bid_depth_amount,
ask_depth_amount=ask_depth_amount,
sigma2=sma_sigma,
macd=macd_macd,
signal=macd_signal)
cancel_loop_count += 1
trade_hold_count += 1
if funds_coin < 0.0001 and END_FLAG and last_trade_order_id == 0:
message_text = EXCHANGE + 'プログラム終了\n' + str(date_time) + '\njpy資産:'
message_text += str(funds_jpy) + '\n' + COIN_NAME + '資産:' + str(funds_coin)
message_text += '\nProfit:' + str(profit_count) + ' Loss:' + str(loss_count)
message_text += '\nGain:' + str(funds_jpy - start_funds_jpy)
print(message_text)
slack_notify(message_text)
exit()
if date_time > end_datetime:
END_FLAG = True
end_time = time.time()
elpsed_time = end_time - start_time
if elpsed_time > LOOP_TIME:
elpsed_time %= LOOP_TIME
print('ake time over', str(LOOP_TIME), 'sec')
time.sleep(LOOP_TIME - elpsed_time)
Monappy: MBDQ39VHypMQwfyR8SshuHvfPNUz321F6B
モナゲ(tipmona)ってなに？
そもそもMonacoinってなに？
コメントを残す