1. 開発で遭遇した時系列の隠れた不具合
為替リアルタイム監視システムを開発していた際、分足ローソク生成に奇妙な不具合が頻発しました。価格数値自体に飛びやノイズは見られないのに、出来上がるローソクが時系列順に乱れ、同一時間帯に重複データが生成されるケースが散見されたのです。
当初はローソク集計ロジックや DB の書き込み競合が原因と推測し、コードを何度修正しても再発しました。配信される生データを 1 件ずつ出力して追跡したところ、原因がタイムスタンプにあることが判明。後から受信したメッセージの取引時刻が、先に処理したデータより過去になる「タイムスタンプ巻き戻り」が発生していました。
ネットワークの瞬断、メッセージキューの滞留、配信元の送信タイミング調整など、様々な要因でこの現象は発生します。入口段階で検知する仕組みを持たないと、後続の指標計算・戦略バックテスト全体に悪影響を及ぼします。

2. 受信順＝取引順にならない仕組み
多くの開発者は為替 API から届いたデータを受信した順にそのまま保存・処理しますが、リアルタイム配信には「受信順と実際の取引時刻が一致しない」という特性があります。実際のデータ例で確認します。
3 件目が最後に届いたにもかかわらず、記録された取引時刻は 2 件目より早いです。このまま受信順でローソクを作成すると分足が崩れ、テクニカル指標の値が歪み、定量戦略の判断根拠が失われます。

3. データ受信前に挿入する簡易タイムスタンプ検証層
この問題を回避するため、データをストレージに登録する前段階に軽量な検証処理を追加しています。
基本的な考え方は「各銘柄ごとに直前の正常なタイムスタンプを保持し、新規データと比較する」ことです。
新規時刻＞直前時刻：正常、処理を続行
新規時刻＝直前時刻：業務要件に応じ重複削除を切り替え
新規時刻＜直前時刻：タイムスタンプ巻き戻りと判定、異常ログを出力
汎用的な判定関数の基礎コードは下記の通りです。
複雑なミドルウェアを導入せず実装可能で、リアルタイム配信の異常を高い精度で捉えられます。

4. WebSocket 配信への実装例
リアルタイム為替データは WebSocket 長時間接続で取得するのが一般的です。データ受信、タイム検証、永続化の 3 層に分離して実装することで保守性が高まります。今回は AllTick API の WebSocket エンドポイントを利用し、取得したティックデータを上記検証ロジックに通してから後続処理へ渡す構成にしています。

import json
import websocket

last_time = {}

def on_message(ws, message):
    data = json.loads(message)
    symbol = data.get("symbol")
    timestamp = data.get("timestamp")
    if symbol in last_time and timestamp < last_time[symbol]:
        print("タイムスタンプ巻き戻り：", symbol)
    last_time[symbol] = timestamp
    print(symbol, timestamp)

if __name__ == "__main__":
    ws = websocket.WebSocketApp("wss://api.alltick.co/forex/websocket", on_message=on_message)
    ws.run_forever()

5. タイムスタンプ処理で見落としがちな 3 つの注意点
長期間運用して気付いた、誤判定の原因となる細かいルールを整理します。
タイムフォーマットの統一
API によって秒単位タイムスタンプ、ミリ秒単位、タイムゾーン付き文字列など形式がバラバラです。比較前に全て同一フォーマット（UTC ミリ秒推奨）に変換しないと誤検知が大量に発生します。
クライアント受信時刻を基準にしない
プログラムがデータを受け取った時刻はネットワーク遅延の影響を受けるため、取引の真の時刻として使用できません。必ず API が付与する業務用タイムスタンプを比較基準にします。
同一時刻の複数ティックを異常としない
1 秒間に複数回価格が更新される高頻度配信は正常な現象です。同じタイムスタンプのデータを一律削除せず、巻き戻りの場合のみフィルタリングするよう設計します。

6. 開発まとめ
為替リアルタイムシステムを構築して実感したのは、不具合の多くが高度なアルゴリズムではなくデータ受信の細部管理に起因するという点です。タイムスタンプ巻き戻りは一見小さな不具合に見えますが、ローソク作成・指標算出・過去データ分析全てに連鎖的な歪みを生み出します。
API 接続時にタイムスタンプ検証を標準フローに組み込むだけで、後工程の膨大なデバッグ工数を削減できます。リアルタイム相場は変動が速いため、単なる配信速度の追求より、時系列の正確性を担保する仕組み作りが定量開発の核心と言えます。