AIリード評価エージェントを構築する

Sanka上でリード評価フローを作成してください。

要件:
1. 入力はリードのメールアドレス
2. コンタクトを作成または更新する
3. ドメインから会社情報を補完する
4. 次のICPでスコアリングする
   - 業種: B2B SaaS、物流、ヘルスケア、業務サービス
   - 従業員数: 50〜500名
   - 地域: 北米または日本
   - シグナル: 比較検討中、または業務変更の必要がある
5. スコア70以上なら高優先度で取引を作成する
6. スコア50〜69なら通常優先度で取引を作成する
7. スコア50未満ならコンタクトのみ残す
8. スコア、理由、次アクションを返す

pip install sanka-sdk

from sanka import Sanka

client = Sanka(api_key="sk_live_...")

def qualify_lead(email: str, icp_criteria: dict) -> dict:
    domain = email.split("@")[1]

    contact = client.contacts.create({
        "email": email,
        "source": "inbound_form"
    })

    enrichment = client.ai.enrich({
        "type": "company",
        "domain": domain
    })

    company_data = enrichment.get("data", {})

    score_result = client.ai.score({
        "type": "company",
        "record_id": contact.get("company_id"),
        "criteria": icp_criteria
    })

    score = score_result.get("score", 0)
    reasons = score_result.get("reasons", [])

    result = {
        "contact_id": contact.get("id"),
        "email": email,
        "company": company_data.get("name"),
        "enrichment": company_data,
        "score": score,
        "reasons": reasons,
    }

    if score >= 70:
        deal = client.deals.create({
            "name": f"{company_data.get('name', domain)} - Inbound Evaluation",
            "contact_id": contact.get("id"),
            "stage": "qualification",
            "priority": "high",
            "source": "inbound_form",
            "score": score,
        })
        result["deal_id"] = deal.get("id")
        result["action"] = "deal_created_high_priority"
    elif score >= 50:
        deal = client.deals.create({
            "name": f"{company_data.get('name', domain)} - Nurture Review",
            "contact_id": contact.get("id"),
            "stage": "qualification",
            "priority": "medium",
            "source": "inbound_form",
            "score": score,
        })
        result["deal_id"] = deal.get("id")
        result["action"] = "deal_created_medium_priority"
    else:
        result["action"] = "contact_saved_no_deal"

    return result

from flask import Flask, jsonify, request

app = Flask(__name__)

@app.route("/webhook/lead", methods=["POST"])
def handle_lead():
    data = request.json or {}
    email = data.get("email")

    if not email:
        return jsonify({"error": "email required"}), 400

    icp = {
        "industries": ["B2B SaaS", "Technology", "Healthcare", "Logistics"],
        "employee_range": [50, 500],
        "regions": ["North America", "Japan"],
        "min_funding_stage": "Series A",
    }

    result = qualify_lead(email, icp)
    return jsonify(result)