TradingViewとMT4連携をGCFで自動化！サーバーレスで無料から始める自動売買ガイド

TradingView → Webhook → GCF (Cloud Functions) → Firestore → MT4 EA

import os
from google.cloud import firestore

# 環境変数から秘密鍵を取得
SECRET_KEY = os.environ.get("SECRET_KEY", "default-secret")

def tradingview_webhook(request):
    """
    TradingViewからのWebhookを受信し、Firestoreに注文情報を保存・提供する。
    URLパラメータで渡されたキーを検証し、不正なアクセスを防ぐ。
    """
    # --- セキュリティチェック ---
    request_key = request.args.get("key")
    if request_key != SECRET_KEY:
        print(f"不正なアクセス試行: key={request_key}")
        return {"error": "Invalid key"}, 403 # 403 Forbidden

    db = firestore.Client()
    request_json = request.get_json(silent=True)
    
    # MT4からの注文取得リクエストか、TradingViewからの新規注文かを判断
    if request_json and 'symbol' in request_json and 'order' not in request_json:
        # MT4からのリクエスト：Firestoreから最新の注文を取得して返す
        symbol = request_json['symbol']
        doc_ref = db.collection("TradingViewOrders").document(symbol)
        doc = doc_ref.get()

        if doc.exists:
            order = doc.to_dict().get("order", "none")
            # 取得後に注文情報をクリアし、重複実行を防ぐ
            doc_ref.set({"order": "none", "timestamp": firestore.SERVER_TIMESTAMP})
            return {"order": order}
        else:
            return {"order": "none"}
            
    elif request_json and 'symbol' in request_json and 'order' in request_json:
        # TradingViewからのリクエスト：Firestoreに新しい注文を保存する
        symbol = request_json['symbol']
        order = request_json['order']
        
        doc_ref = db.collection("TradingViewOrders").document(symbol)
        doc_ref.set({
            "order": order,
            "timestamp": firestore.SERVER_TIMESTAMP
        })
        print(f"注文保存: {symbol} - {order}")
        return {"status": "success"}
        
    else:
        # 不正なリクエスト
        print(f"不正なリクエスト: {request_json}")
        return {"error": "Invalid request"}, 400

google-cloud-firestore

#property strict

//--- EA設定
input string web_hook_url = "ここに保護されたCloud FunctionsのURLを貼り付け";
input string symbol_param = ""; // 通貨ペア（空欄ならチャートの通貨ペアを自動使用）
input int magic_number = 12345;
input double lot_size = 0.01;
input int slippage = 3;
input int spread_limit = 30; // pips

//--- グローバル変数
datetime last_request_time = 0;

void OnTick()
{
    // 30秒に1回程度に実行を制限
    if (TimeCurrent() - last_request_time < 30) {
        return;
    }
    last_request_time = TimeCurrent();

    // スプレッドが広すぎる場合は何もしない
    if (Ask - Bid > spread_limit * _Point * (Digits % 2 == 1 ? 10 : 1)) {
        Print("スプレッドが広すぎるためスキップ");
        return;
    }

    string order = GetOrderFromGCF();

    // 受信した注文に応じて処理を実行
    if (order == "buy") {
        ClosePositions(OP_SELL); // ドテンの場合は反対ポジションを閉じる
        if (CountPositions(OP_BUY) == 0) { // 新規ロング
            OrderSend(Symbol(), OP_BUY, lot_size, Ask, slippage, 0, 0, "GCF Signal", magic_number, 0, clrBlue);
        }
    }
    else if (order == "sell") {
        ClosePositions(OP_BUY); // ドテン
        if (CountPositions(OP_SELL) == 0) { // 新規ショート
            OrderSend(Symbol(), OP_SELL, lot_size, Bid, slippage, 0, 0, "GCF Signal", magic_number, 0, clrRed);
        }
    }
    else if (order == "buy_close") {
        ClosePositions(OP_BUY); // ロングポジションを決済
    }
    else if (order == "sell_close") {
        ClosePositions(OP_SELL); // ショートポジションを決済
    }
}

// GCFから注文情報を取得する関数
string GetOrderFromGCF()
{
    char data[], result[];
    string headers = "Content-Type: application/json\r\n";
    string symbol_to_req = (symbol_param == "") ? Symbol() : symbol_param;
    string json_payload = "{\"symbol\":\"" + symbol_to_req + "\"}";
    
    StringToCharArray(json_payload, data, 0, WHOLE_ARRAY, CP_UTF8);

    // WebRequestを実行
    int res = WebRequest("POST", web_hook_url, headers, 5000, data, result, headers);

    if (res == 200) {
        string response = CharArrayToString(result);
        string order_value = ParseJson(response, "order"); // JSON解析関数を呼び出す
        
        if (order_value != "none" && order_value != "") {
            Print("GCFから注文受信: ", order_value);
        }
        return order_value;
    } else {
        Print("GCFリクエストエラー: ", res, " - ", CharArrayToString(result));
    }
    return "";
}

//--- ユーティリティ関数 ---

// JSON文字列から指定したキーの値を取得する簡易パーサー
string ParseJson(string json_string, string key)
{
    string search_key = "\"" + key + "\":\"";
    int key_pos = StringFind(json_string, search_key);
    if (key_pos < 0) return ""; // キーが見つからない

    int start_pos = key_pos + StringLen(search_key);
    int end_pos = StringFind(json_string, "\"", start_pos);
    if (end_pos < 0) return ""; // 閉じ引用符が見つからない

    return StringSubstr(json_string, start_pos, end_pos - start_pos);
}

// 指定したタイプのポジション数を数える
int CountPositions(int type) {
    int count = 0;
    for (int i = OrdersTotal() - 1; i >= 0; i--) {
        if (OrderSelect(i, SELECT_BY_POS) && OrderMagicNumber() == magic_number && OrderSymbol() == Symbol()) {
            if (OrderType() == type) {
                count++;
            }
        }
    }
    return count;
}

// 指定したタイプの全ポジションを決済する
void ClosePositions(int type) {
    for (int i = OrdersTotal() - 1; i >= 0; i--) {
        if (OrderSelect(i, SELECT_BY_POS) && OrderMagicNumber() == magic_number && OrderSymbol() == Symbol()) {
            if (OrderType() == type) {
                double close_price = (type == OP_BUY) ? Bid : Ask;
                OrderClose(OrderTicket(), OrderLots(), close_price, slippage);
            }
        }
    }
}