Shopify Webhook 500エラーによる自動配信停止と再試行設計（Dead Letter Queue）

即時 200 OK 応答＋非同期キューイングの導入

Webhookを受信した瞬間にステータス200を返し、重い処理（外部API連携等）はバックグラウンドキュー（Redis / SQS / Cloudflare Workers）へ委譲。

// FastAPI / Python 非同期受信用エンドポイント例
@app.post("/webhooks/orders/create")
async def handle_order_webhook(request: Request, background_tasks: BackgroundTasks):
    raw_body = await request.body()
    # 署名検証 (HMAC SHA256)
    verify_shopify_hmac(request.headers, raw_body)
    
    # 重い処理をバックグラウンドに逃がして即時200を返す
    background_tasks.add_task(process_order_to_pos, json.loads(raw_body))
    return JSONResponse(content={"status": "received"}, status_code=200)

HMAC SHA256 署名検証の厳格化

改ざんされた不正リクエストを弾きつつ、正規のリクエストのみをキューへ流す。

Dead Letter Queue (DLQ) と障害アラートの実装

連携先システムがダウンしていても、失敗データを保持して復旧後にワンクリック再送できる管理画面を構築。