金融サービス業界向け OpenTelemetry ベストプラクティス ​

from opentelemetry import trace
from datetime import datetime

tracer = trace.get_tracer(__name__)

def execute_money_transfer(transfer_id: str, from_account: str, to_account: str, amount: float) -> 'TransferResult':
    """送金処理を実行し、ライフサイクル全体をトレースします"""
    with tracer.start_as_current_span("execute_transfer") as span:
        span.set_attribute("transfer.id", transfer_id)
        span.set_attribute("from_account", from_account)
        span.set_attribute("to_account", to_account)
        span.set_attribute("amount", amount)
        span.set_attribute("timestamp", datetime.utcnow().isoformat())

        # ステップ1: 送金元口座検証
        with tracer.start_as_current_span("validate_source_account") as validate_span:
            account_check = account_service.verify_account(from_account)
            validate_span.set_attribute("account.status", account_check.status)
            validate_span.set_attribute("balance", account_check.balance)

        # ステップ2: 残高確認
        with tracer.start_as_current_span("check_balance") as balance_span:
            if account_check.balance < amount:
                balance_span.set_attribute("sufficient_funds", False)
                raise InsufficientFundsError()
            balance_span.set_attribute("sufficient_funds", True)

        # ステップ3: セキュリティチェック
        with tracer.start_as_current_span("security_check") as security_span:
            security_result = security_service.check_transfer(from_account, to_account, amount)
            security_span.set_attribute("risk_score", security_result.risk_score)
            security_span.set_attribute("check.passed", security_result.passed)

        # ステップ4: 取引実行
        with tracer.start_as_current_span("execute_transaction") as execute_span:
            result = transaction_engine.execute(
                transfer_id, from_account, to_account, amount
            )
            execute_span.set_attribute("transaction.status", result.status)
            execute_span.set_attribute("confirmation_number", result.confirmation)

        # ステップ5: 決済確認
        with tracer.start_as_current_span("confirm_settlement") as settle_span:
            settlement = settlement_service.confirm(result.confirmation)
            settle_span.set_attribute("settlement.status", settlement.status)

        return result

def authenticate_and_authorize(user_id: str, action: str, resource: str) -> bool:
    """ユーザーの認証と認可を行い、セキュリティイベントを記録します"""
    with tracer.start_as_current_span("auth_and_authz") as span:
        span.set_attribute("user.id", user_id)
        span.set_attribute("action", action)
        span.set_attribute("resource", resource)
        span.set_attribute("auth.timestamp", datetime.utcnow().isoformat())

        # 認証
        with tracer.start_as_current_span("authenticate") as auth_span:
            auth_result = auth_service.authenticate(user_id)
            auth_span.set_attribute("auth.success", auth_result.success)
            auth_span.set_attribute("auth.method", auth_result.method)
            auth_span.set_attribute("mfa.used", auth_result.mfa_used)

            if not auth_result.success:
                auth_span.set_attribute("auth.failure_reason", auth_result.failure_reason)
                span.add_event("authentication_failed", {
                    "user": user_id,
                    "reason": auth_result.failure_reason
                })
                raise AuthenticationError()

        # 認可チェック
        with tracer.start_as_current_span("authorize") as authz_span:
            authz_result = authz_service.check_permission(user_id, action, resource)
            authz_span.set_attribute("authz.allowed", authz_result.allowed)
            authz_span.set_attribute("authz.role", authz_result.user_role)

            if not authz_result.allowed:
                span.add_event("unauthorized_access_attempt", {
                    "user": user_id,
                    "action": action,
                    "resource": resource
                })
                raise AuthorizationError()

        # 異常パターン検出
        with tracer.start_as_current_span("anomaly_detection") as anomaly_span:
            anomaly_score = security_ml.detect_anomaly(user_id, action)
            anomaly_span.set_attribute("anomaly.score", anomaly_score)

            if anomaly_score > 0.8:
                span.add_event("suspicious_activity", {
                    "user": user_id,
                    "anomaly_score": anomaly_score
                })

        return True

def execute_trading_order(order_id: str, symbol: str, quantity: int, price: float, strategy: str) -> 'ExecutionResult':
    """取引注文を実行し、高周波取引の各ステップを監視します"""
    with tracer.start_as_current_span("execute_order") as span:
        span.set_attribute("order.id", order_id)
        span.set_attribute("symbol", symbol)
        span.set_attribute("quantity", quantity)
        span.set_attribute("price", price)
        span.set_attribute("strategy", strategy)
        span.set_attribute("execution.timestamp", datetime.utcnow().isoformat())

        # マーケットデータ取得
        with tracer.start_as_current_span("fetch_market_data") as market_span:
            market_data = market_service.get_current_price(symbol)
            market_span.set_attribute("current_price", market_data.price)
            market_span.set_attribute("bid_ask_spread", market_data.spread)

            # 価格スリッページチェック
            slippage = abs(price - market_data.price) / market_data.price
            market_span.set_attribute("slippage_percent", slippage * 100)

        # リスク管理チェック
        with tracer.start_as_current_span("risk_check") as risk_span:
            risk_result = risk_engine.evaluate(order_id, quantity, price)
            risk_span.set_attribute("risk.acceptable", risk_result.acceptable)
            risk_span.set_attribute("position_impact", risk_result.position_impact)

        # 注文実行
        with tracer.start_as_current_span("place_order") as order_span:
            execution = trading_platform.place_order(symbol, quantity, price)
            order_span.set_attribute("execution.status", execution.status)
            order_span.set_attribute("fill.quantity", execution.filled_quantity)
            order_span.set_attribute("average_fill_price", execution.average_price)
            order_span.set_attribute("execution.latency_ms", execution.latency_ms)

        return execution