はじめに

システムでデイトレするためには株価の変化をリアルタイムで欲しいですよね？

そんな時に使えるのが 立花証券e支店 API の EVENT I/F です。

EVENT I/F にはHTTP Protocol版とWebSocket Protocol版がありますが、ここではWebSocket版の話です。

今は eスマート証券（旧カブコム証券）の kabuSTATION API を使ったプログラムを運用してますが、ちょっと立花証券e支店 API は、どんなものかと思って開発中です。
で、立花証券e支店 API の情報が少ないと思ったので投稿してみます。
一応、公式サンプルとかはあるのですが…

ちなみに、立花証券e支店APIは先日(2025-09-27) v4r8がリリースされて POST対応 されました。
これでやっと違和感なく使える感じになりましたね。

WebSocketApp

ここで紹介するのは websocket-client ライブラリの WebSocketApp を使用したものです。
WebSocketAppは非常にシンプルなI/Fで気に入ってます。
非同期I/O asyncio には対応していないのですが、今回は使わない予定です。

というのも、前述のいま運用しているプログラムをGeminiさんに非同期I/O化して貰ったのですが、逆に遅くなってしまいました。
自分のデイトレプログラムはリアルタイムで株価を受け取ってOHLCや複数の移動平均値を計算してるのですが、asyncioが苦手な「CPUバウンドな処理」になるようです。

ということで、事前にライブラリをインストールしておきましょう。

$ uv add websocket-client
$ uv add requests
又は
$ pip install websocket-client
$ pip install requests

※uv を使いだすと、もう便利で戻れませんね。

WebSocket Client サンプル

必要最低限でエラー処理などしていません。

te_websocket_client.py

from urllib.parse import urlencode

import websocket


class TeWebSocketClient:
    def __init__(self, ws_url: str):
        self.ws_url = ws_url
        self.ws = None
        self._is_connected = False

    def _on_message(self, ws, message):
        print(f"Received: {message}")

    def _on_error(self, ws, error):
        print(f"Error: {error}")

    def _on_close(self, ws, close_status_code, close_msg):
        print("### closed ###")
        self._is_connected = False

    def _on_open(self, ws):
        print("Opened connection")
        self._is_connected = True

    def connect(self):
        # EVENT I/F へのパラメーター
        payload = {}
        payload["p_rid"] = "22"
        payload["p_board_no"] = "1000"
        payload["p_eno"] = "0"
        payload["p_evt_cmd"] = "ST,KP,FD,EC,NS,SS,US"
        # 以下、本来は動的に生成
        payload["p_issue_code"] = "7201,7202,7203"
        payload["p_gyou_no"] = "1,2,3"
        payload["p_mkt_code"] = "00,00,00"

        # EVENT I/F はPOST対応していない（v4r8時点）
        # パラメータ付URL（カンマ(,)はエンコードしない）
        full_url = f"{self.ws_url}?{urlencode(payload, safe=',')}"

        self.ws = websocket.WebSocketApp(
            full_url,
            on_open=self._on_open,
            on_message=self._on_message,
            on_error=self._on_error,
            on_close=self._on_close,
        )
        # Run in a separate thread to not block the main thread
        import threading

        self.ws_thread = threading.Thread(target=self.ws.run_forever)
        self.ws_thread.daemon = (
            True  # Allow the main program to exit even if the thread is still running
        )
        self.ws_thread.start()

        # Wait a bit for the connection to establish
        import time

        time.sleep(1)
        return self._is_connected

    def disconnect(self):
        if self.ws:
            self.ws.close()
            self.ws = None
            self._is_connected = False

    def is_connected(self):
        return self._is_connected

    def join(self):
        if self.ws_thread:
            self.ws_thread.join()

    def send_message(self, message: str):
        if self._is_connected and self.ws:
            self.ws.send(message)
        else:
            print("WebSocket is not connected.")
            return False
        return True

パラメーターに渡す ws_url はログインすると発行される仮想URLの一つなので、先にログインする必要があります。

ログイン用のクラスがこちら！

te_api_client.py

import threading
import typing
from datetime import datetime

import requests


class TeApiClient:
    def __init__(self):
        self.session = requests.Session()

        self._lock = threading.Lock()
        self.request_counter: int = 0

        # ログイン情報
        self.session_info: dict = {}

    def _get_next_p_no(self) -> str:
        """
        APIリクエストごとにインクリメントされるp_no（リクエスト番号）を生成します。
        """
        self.request_counter += 1
        return str(self.request_counter)

    def _get_current_datetime(self) -> str:
        """
        p_sd_date用の日時文字列（YYYY.MM.DD-HH:MI:SS.ms）を生成します。
        """
        # APIの仕様に合わせ、マイクロ秒を示す末尾3桁を削除しミリ秒までの精度にします。
        return datetime.now().strftime("%Y.%m.%d-%H:%M:%S.%f")[:-3]

    def _call_api(
        self,
        url: str,
        payload: dict,
        method: str = "POST",
        headers: dict[str, str] = {},
    ) -> dict:
        """
        APIサーバーへリクエストを送信し、結果を取得する共通メソッド。

        APIをコールし、取得したJSONの辞書オブジェクトを返します。
        このメソッド内で、リクエスト共通のパラメータが付与されます。

        Args:
            url (str): エンドポイントURL。
            payload (dict): 送信パラメータ。
            method (str): "GET" または "POST"。
            headers (dict[str, str]): HTTPヘッダー。

        Raises:
            requests.exceptions.RequestException: APIサーバーへ接続出来なかった場合。
            Exception: その他の例外発生時。

        Returns:
            dict: APIから取得したJSONを辞書へ変換したオブジェクト。
        """
        dict_result: dict = {}
        with self._lock:
            try:
                # 共通パラメーターの付与
                payload["p_no"] = self._get_next_p_no()
                payload["p_sd_date"] = self._get_current_datetime()
                payload["sJsonOfmt"] = "4"

                response = self.session.request(
                    method=method,
                    url=url,
                    headers=headers,
                    json=payload,
                    timeout=20,
                )

                response.raise_for_status()
                response.encoding = "cp932"
                if "application/json" in response.headers.get("Content-Type", ""):
                    dict_result = response.json()
                    return dict_result
                else:
                    print(response.text)
                    return {"p_errno": "9999", "p_err": "No JSON"}

            except requests.exceptions.RequestException as exp:
                print(exp)
                if exp.response is not None:
                    print(
                        f"CODE: {exp.response.status_code}, REASON: {exp.response.reason}"
                    )
                raise exp

        return dict_result

    def get_info(self, key: str, default: typing.Any = None) -> typing.Any:
        """
        ログイン時に取得したセッション情報から、指定したキーの値を取得します。
        """
        return self.session_info.get(key, default)

    def login(self, url: str, user_id: str, password: str) -> bool:
        payload = {
            "sCLMID": "CLMAuthLoginRequest",
            "sUserId": user_id,
            "sPassword": password,
        }

        results = self._call_api(url, payload)
        print(results)

        self.session_info = results

        if self.get_info("sUrlRequest") is None:
            print("契約締結前書面が未読です。")
            return False

        return True

    def logout(self) -> bool:
        payload = {
            "sCLMID": "CLMAuthLogoutRequest",
        }
        url = self.get_info("sUrlRequest")
        results = self._call_api(url, payload)
        print(results)

        self.session_info = {}
        return True

メインモジュールは、こちら！

main.py

import time

from te_api_client import TeApiClient
from te_websocket_client import TeWebSocketClient


def main():
    # 立花証券e支店のデモ環境
    url = "https://demo-kabuka.e-shiten.jp/e_api_v4r8/auth/"

    # 自分のID/PW
    user_id = "XXXX"
    password = "XXXX"

    api_client = TeApiClient()

    # ログイン
    result = api_client.login(url, user_id, password)
    if result is False:
        print("ログイン失敗")
        return

    # EVENT I/F WebSocket版のURL
    ws_url = api_client.get_info("sUrlEventWebSocket")
    print(ws_url)

    ws_client = TeWebSocketClient(ws_url)

    # WebSocket接続（別スレッドが起動する）
    ws_client.connect()

    while ws_client.is_connected():
        try:
            time.sleep(1)
        except KeyboardInterrupt:
            # Ctrl+C で終了
            print("Interrupted")
            break

    ws_client.disconnect()
    ws_client.join()

    # ログアウト
    api_client.logout()


if __name__ == "__main__":
    main()

実行すると以下のような出力が得られます。

(.venv) PS > python main.py
{'p_sd_date': '2025.10.23-23:26:20.602', 'p_no': '1', 'p_rv_date': '2025.10.23-23:26:20.409', 'p_errno': '0', 'p_err': '', 'sCLMID': 'CLMAuthLoginAck', 'sResultCode': '0', 'sResultText': '', 'sZyoutoekiKazeiC': '1', 'sSecondPasswordOmit': '0', 'sLastLoginDate': '20251023230250', 'sSogoKouzaKubun': '1', 'sHogoAdukariKouzaKubun': '1', 'sFurikaeKouzaKubun': '1', 'sGaikokuKouzaKubun': '1', 'sMRFKouzaKubun': '0', 'sTokuteiKouzaKubunGenbutu': '1', 'sTokuteiKouzaKubunSinyou': '1', 'sTokuteiKouzaKubunTousin': '0', 'sTokuteiHaitouKouzaKubun': '1', 'sTokuteiKanriKouzaKubun': '0', 'sSinyouKouzaKubun': '1', 'sSakopKouzaKubun': '0', 'sMMFKouzaKubun': '0', 'sTyukokufKouzaKubun': '0', 'sKawaseKouzaKubun': '0', 'sHikazeiKouzaKubun': '1', 'sKinsyouhouMidokuFlg': '0', 'sUrlRequest': 'https://demo-kabuka.e-shiten.jp/e_api_v4r8/request/NDA5MjAyNjIzMjMxMC0xMTYtNTM5MzA=/', 'sUrlMaster': 'https://demo-kabuka.e-shiten.jp/e_api_v4r8/master/NDA5MjAyNjIzMjMxMC0xMTYtNTM5MzA=/', 'sUrlPrice': 'https://demo-kabuka.e-shiten.jp/e_api_v4r8/price/NDA5MjAyNjIzMjMxMC0xMTYtNTM5MzA=/', 'sUrlEvent': 'https://demo-kabuka.e-shiten.jp/e_api_v4r8/event/NDA5MjAyNjIzMjMxMC0xMTYtNTM5MzA=/', 'sUrlEventWebSocket': 'wss://demo-kabuka.e-shiten.jp/e_api_v4r8/event_ws/NDA5MjAyNjIzMjMxMC0xMTYtNTM5MzA=/', 'sUpdateInformWebDocument': '20241103', 'sUpdateInformAPISpecFunction': '20241103'}
wss://demo-kabuka.e-shiten.jp/e_api_v4r8/event_ws/NDA5MjAyNjIzMjMxMC0xMTYtNTM5MzA=/
Opened connection
Received: p_no1p_date2025.10.23-23:26:20.693p_cmdKP
Received: p_no2p_date2025.10.23-23:26:20.696p_cmdFDp_1_AV94100p_1_BV100p_1_DHF0000p_1_DHP377.7p_1_DHP:T14:33p_1_DJ6635432420p_1_DLF0000p_1_DLP370.8p_1_DLP:T10:00p_1_DOP373.8p_1_DOP:T09:00p_1_DPG0057p_1_DPP377.6p_1_DPP:T15:30p_1_DV17673900p_1_DYRP-0.02p_1_DYWP-0.1p_1_GAP1377.6p_1_GAP10378.5p_1_GAP2377.7p_1_GAP3377.8p_1_GAP4377.9p_1_GAP5378.0p_1_GAP6378.1p_1_GAP7378.2p_1_GAP8378.3p_1_GAP9378.4p_1_GAV194100p_1_GAV1015700p_1_GAV211200p_1_GAV37300p_1_GAV412200p_1_GAV591700p_1_GAV632100p_1_GAV71300p_1_GAV8100p_1_GAV910400p_1_GBP1377.4p_1_GBP10376.2p_1_GBP2377.2p_1_GBP3377.0p_1_GBP4376.9p_1_GBP5376.8p_1_GBP6376.6p_1_GBP7376.5p_1_GBP8376.4p_1_GBP9376.3p_1_GBV1100p_1_GBV10100p_1_GBV2400p_1_GBV37000p_1_GBV4600p_1_GBV5300p_1_GBV62000p_1_GBV76200p_1_GBV856500p_1_GBV910000p_1_LISSCCDFD7B2D1p_1_PRP377.7p_1_QAP377.6p_1_QAS0101p_1_QBP377.4p_1_QBS0101p_1_QOV7279500p_1_QUV5788800p_1_VWAP375.4368p_2_AV200p_2_BV500p_2_DHF0000p_2_DHP1939.0p_2_DHP:T14:15p_2_DJ3731461100p_2_DLF0000p_2_DLP1915.5p_2_DLP:T09:42p_2_DOP1928.0p_2_DOP:T09:00p_2_DPG0058p_2_DPP1931.0p_2_DPP:T15:30p_2_DV1932500p_2_DYRP-0.02p_2_DYWP-0.5p_2_GAP11936.0p_2_GAP101940.5p_2_GAP21936.5p_2_GAP31937.0p_2_GAP41937.5p_2_GAP51938.0p_2_GAP61938.5p_2_GAP71939.0p_2_GAP81939.5p_2_GAP91940.0p_2_GAV1200p_2_GAV10400p_2_GAV2100p_2_GAV3700p_2_GAV41100p_2_GAV5200p_2_GAV63000p_2_GAV73200p_2_GAV813600p_2_GAV918100p_2_GBP11930.5p_2_GBP101926.0p_2_GBP21930.0p_2_GBP31929.5p_2_GBP41929.0p_2_GBP51928.5p_2_GBP61928.0p_2_GBP71927.5p_2_GBP81927.0p_2_GBP91926.5p_2_GBV1500p_2_GBV10400p_2_GBV214400p_2_GBV3400p_2_GBV47600p_2_GBV5400p_2_GBV6500p_2_GBV7400p_2_GBV89200p_2_GBV9400p_2_LISSCCDFD7B2D1p_2_PRP1931.5p_2_QAP1936.0p_2_QAS0101p_2_QBP1930.5p_2_QBS0101p_2_QOV693000p_2_QUV462200p_2_VWAP1930.8984p_3_AV19200p_3_BV1400p_3_DHF0000p_3_DHP3112p_3_DHP:T09:00p_3_DJ55764856000p_3_DLF0000p_3_DLP3057p_3_DLP:T09:39p_3_DOP3100p_3_DOP:T09:00p_3_DPG0057p_3_DPP3091p_3_DPP:T15:30p_3_DV18085400p_3_DYRP-0.41p_3_DYWP-13p_3_GAP13092p_3_GAP103101p_3_GAP23093p_3_GAP33094p_3_GAP43095p_3_GAP53096p_3_GAP63097p_3_GAP73098p_3_GAP83099p_3_GAP93100p_3_GAV119200p_3_GAV1010300p_3_GAV265100p_3_GAV310100p_3_GAV452200p_3_GAV5101600p_3_GAV637000p_3_GAV7115700p_3_GAV821700p_3_GAV9333700p_3_GBP13090p_3_GBP103081p_3_GBP23089p_3_GBP33088p_3_GBP43087p_3_GBP53086p_3_GBP63085p_3_GBP73084p_3_GBP83083p_3_GBP93082p_3_GBV11400p_3_GBV1047500p_3_GBV2900p_3_GBV36100p_3_GBV4200p_3_GBV52300p_3_GBV672900p_3_GBV76900p_3_GBV843500p_3_GBV927600p_3_LISSCCDFD7B2D1p_3_PRP3104p_3_QAP3092p_3_QAS0101p_3_QBP3090p_3_QBS0101p_3_QOV6718500p_3_QUV3647100p_3_VWAP3083.4184
Received: p_no3p_date2025.10.23-23:26:20.812p_cmdSSp_PVMSGSVp_ENO44p_ALT0p_CT20251023081012p_LK1p_SS1
Received: p_no4p_date2025.10.23-23:26:20.812p_cmdUSp_PVMSGSVp_ENO56p_ALT0p_CT20251023084015p_MC00p_GSCDp_SHSBp_UC01p_UU0101p_EDK0p_US100
Received: p_no5p_date2025.10.23-23:26:20.812p_cmdUSp_PVMSGSVp_ENO158p_ALT0p_CT20251023111012p_MC00p_GSCDp_SHSBp_UC01p_UU0101p_EDK0p_US140
Received: p_no6p_date2025.10.23-23:26:20.812p_cmdUSp_PVMSGSVp_ENO167p_ALT0p_CT20251023111212p_MC00p_GSCDp_SHSBp_UC01p_UU0101p_EDK0p_US160
Received: p_no7p_date2025.10.23-23:26:20.921p_cmdUSp_PVMSGSVp_ENO180p_ALT0p_CT20251023114512p_MC00p_GSCDp_SHSBp_UC01p_UU0101p_EDK0p_US200
Received: p_no8p_date2025.10.23-23:26:20.921p_cmdUSp_PVMSGSVp_ENO272p_ALT0p_CT20251023144011p_MC00p_GSCDp_SHSBp_UC01p_UU0101p_EDK0p_US260
Received: p_no9p_date2025.10.23-23:26:20.921p_cmdUSp_PVMSGSVp_ENO284p_ALT0p_CT20251023144212p_MC00p_GSCDp_SHSBp_UC01p_UU0101p_EDK0p_US280
Received: p_no10p_date2025.10.23-23:26:20.921p_cmdUSp_PVMSGSVp_ENO299p_ALT0p_CT20251023151004p_MC00p_GSCDp_SHSBp_UC01p_UU0101p_EDK0p_US200
Received: p_no11p_date2025.10.23-23:26:25.013p_cmdKP
Received: p_no12p_date2025.10.23-23:26:30.035p_cmdKP
Received: p_no13p_date2025.10.23-23:26:35.058p_cmdKP
Received: p_no14p_date2025.10.23-23:26:40.081p_cmdKP
Received: p_no15p_date2025.10.23-23:26:45.003p_cmdKP
Received: p_no16p_date2025.10.23-23:26:50.026p_cmdKP
Interrupted
### closed ###
{'p_sd_date': '2025.10.23-23:26:56.046', 'p_no': '2', 'p_rv_date': '2025.10.23-23:26:55.993', 'p_errno': '0', 'p_err': '', 'sCLMID': 'CLMAuthLogoutAck', 'sResultCode': '0', 'sResultText': ''}
(.venv) >

最初の一行目はログインした時に得られるログイン情報です。
仮想URLはログアウトすると無効になるので公開しても問題なしということです。

Received: に続く文字列が受信したメッセージです。
これは特殊文字(^A, ^B, ^C)で区切られているので、これを解析して辞書型などへ変換します。

もう少しアプリケーションに近い形のソースコードやメッセージ解析について解説していますので、良ければ参考にしてください。

役に立ったら「いいね」お願いします。