Cloud RunからMeasurement Protocolを使ってGA4にUser-IDを送信してみた

mp-userid-sender/
├── main.py
└── requirements.txt

functions-framework==3.*
requests==2.*

import functions_framework
import requests

# GA4の設定
GA4_MEASUREMENT_ID = "測定ID(トラッキングコード)"
GA4_API_SECRET = "APIシークレット"
MP_ENDPOINT = "https://www.google-analytics.com/mp/collect"

@functions_framework.http
def send_user_id(request):
    """User-IDを含めたイベントをMeasurement Protocolで送信する"""
    req = request.get_json(silent=True)
    if not req:
        return "リクエストボディが空です", 400

    # 必須パラメータ
    client_id = req.get("client_id")
    user_id = req.get("user_id")
    if not client_id or not user_id:
        return "client_idとuser_idは必須です", 400

    # イベント名（デフォルトはlogin）
    event_name = req.get("event_name", "login")

    # イベントパラメータ
    event_params = req.get("event_params", {})
    # engagement_time_msecを含める
    event_params.setdefault("engagement_time_msec", "10000")

    # Measurement Protocolペイロードの構築
    payload = {
        "client_id": client_id,
        "user_id": user_id,
        "events": [
            {
                "name": event_name,
                "params": event_params,
            }
        ],
    }

    url = f"{MP_ENDPOINT}?measurement_id={GA4_MEASUREMENT_ID}&api_secret={GA4_API_SECRET}"
    response = requests.post(url, json=payload)

    print(f"Measurement Protocol送信完了: status={response.status_code}, user_id={user_id}")
    print(f"ペイロード: {payload}")

    return {
        "status": "success",
        "mp_status_code": response.status_code,
        "user_id": user_id,
        "event_name": event_name,
    }, 200

    client_id = req.get("client_id")
    user_id = req.get("user_id")
    if not client_id or not user_id:
        return "client_idとuser_idは必須です", 400

    event_params.setdefault("engagement_time_msec", "10000")

    payload = {
        "client_id": client_id,
        "user_id": user_id,
        "events": [
            {
                "name": event_name,
                "params": event_params,
            }
        ],
    }

    url = f"{MP_ENDPOINT}?measurement_id={GA4_MEASUREMENT_ID}&api_secret={GA4_API_SECRET}"
    response = requests.post(url, json=payload)

gcloud run deploy mp-userid-sender \
    --source . \
    --function=send_user_id \
    --base-image python312 \
    --region asia-northeast1 \
    --no-allow-unauthenticated

FUNCTION_URL=$(gcloud run services describe mp-userid-sender --region asia-northeast1 --format='value(status.url)')
TOKEN=$(gcloud auth print-identity-token)

curl -X POST $FUNCTION_URL \
    -H "Authorization: Bearer ${TOKEN}" \
    -H "Content-Type: application/json" \
    -d '{
      "client_id": "123456789.1234567890",
      "user_id": "user-001",
      "event_name": "login",
      "event_params": {
        "debug_mode": 1,
        "engagement_time_msec": "100",
        "session_id": "1234567890"
      }
    }'

{"event_name":"login","mp_status_code":204,"status":"success","user_id":"user-001"}

curl -X POST "https://www.google-analytics.com/debug/mp/collect?measurement_id=G-QHDFZPCEDT&api_secret=Xjk8qdmbRb6ffvSiaNnMAQ" \
    -H "Content-Type: application/json" \
    -d '{
      "client_id": "123456789.1234567890",
      "user_id": "user-001",
      "events": [{"name": "login", "params": {"engagement_time_msec": "100"}}]
    }'

{
  "validationMessages": []
}

curl -X POST "https://www.google-analytics.com/debug/mp/collect?measurement_id=G-QHDFZPCEDT&api_secret=Xjk8qdmbRb6ffvSiaNnMAQ" \
    -H "Content-Type: application/json" \
    -d '{
      "client_id": "123456789.1234567890",
      "user_id": "user-001",
      "events": [{"name": "_bad_event"}]
    }'

{
  "validationMessages": [ {
    "fieldPath": "events",
    "description": "Event at index: [0] has invalid name [_bad_event]. Names must start with an alphabetic character.",
    "validationCode": "NAME_INVALID"
  } ]
}

curl -X POST "https://www.google-analytics.com/debug/mp/collect?measurement_id=G-QHDFZPCEDT&api_secret=Xjk8qdmbRb6ffvSiaNnMAQ" \
    -H "Content-Type: application/json" \
    -d '{
      "client_id": "",
      "user_id": "user-001",
      "events": [{"name": "login"}]
    }'

{
  "validationMessages": [ {
    "fieldPath": "client_id",
    "description": "Measurement requires a client_id.",
    "validationCode": "VALUE_REQUIRED"
  } ]
}