kabuステーション®APIを使った簡単なロジックの自動売買プログラムの作り方【株の自動売買プログラムをPythonで自作しよう⑤】

import time
import urllib.request
import pprint
import json

# 設定項目
api_password = 'YOUR_PASSWORD'
order_password = 'YOUR_PASSWORD'
symbol = '9432'
buy_price = 150


# トークンを発行する関数
def generate_token():
    obj = {'APIPassword': api_password}
    json_data = json.dumps(obj).encode('utf8')

    url = 'http://localhost:18080/kabusapi/token'
    req = urllib.request.Request(url, json_data, method='POST')
    req.add_header('Content-Type', 'application/json')

    try:
        with urllib.request.urlopen(req) as res:
            content = json.loads(res.read())
            token_value = content.get('Token')
    except urllib.error.HTTPError as e:
        print(e)

    return token_value


# 板情報を取得する関数
def get_board_information(token):
    url = 'http://localhost:18080/kabusapi/board/' + symbol + '@1'
    req = urllib.request.Request(url, method='GET')
    req.add_header('Content-Type', 'application/json')
    req.add_header('X-API-KEY', token)

    try:
        with urllib.request.urlopen(req) as res:
            print(res.status, res.reason)
            for header in res.getheaders():
                print(header)
            print()
            content = json.loads(res.read())
            pprint.pprint(content)
    except urllib.error.HTTPError as e:
        print(e)
        content = json.loads(e.read())
        pprint.pprint(content)
    except Exception as e:
        print(e)

    return content


# 注文を出す関数
def kabusapi_sendorder_cash(token):
    obj = {'Password': order_password,  # 注文パスワード
           'Symbol': symbol,  # 銘柄コード
           'Exchange': 1,  # 市場コード
           'SecurityType': 1,  # 商品種別
           'Side': '2',  # 売買区分
           'CashMargin': 1,  # 信用区分
           'DelivType': 2,  # 受渡区分
           'FundType': 'AA',  # 資産区分（預り区分）
           'AccountType': 4,  # 口座種別
           'Qty': 100,  # 注文数量
           'FrontOrderType': 10,  # 執行条件
           'Price': 0,  # 注文価格
           'ExpireDay': 0  # 注文有効期限
           }
    json_data = json.dumps(obj).encode('utf-8')

    url = 'http://localhost:18080/kabusapi/sendorder'
    req = urllib.request.Request(url, json_data, method='POST')
    req.add_header('Content-Type', 'application/json')
    req.add_header('X-API-KEY', token)

    try:
        with urllib.request.urlopen(req) as res:
            print(res.status, res.reason)
            for header in res.getheaders():
                print(header)
            print()
            content = json.loads(res.read())
            pprint.pprint(content)
    except urllib.error.HTTPError as e:
        print(e)
        content = json.loads(e.read())
        pprint.pprint(content)
    except Exception as e:
        print(e)


# メイン処理
token_value = generate_token()

while True:
    board_information = get_board_information(token_value)
    sell_price = (board_information['Sell1']['Price'])

    if sell_price <= buy_price:
        kabusapi_sendorder_cash(token_value)
        break

    else:
        time.sleep(5)