Parlant: 규제 준수 AI 대화를 위한 오픈소스 Alignment 엔진

await agent.create_guideline(
    condition="제안한 솔루션이 고객에게 효과가 없었을 때",
    action="사람 상담원과 대화하기를 원하는지 물어보거나, 계속 문제 해결을 시도할지 선택하게 하세요"
)

await agent.create_guideline(
    condition="제안한 솔루션이 고객에게 효과가 없었을 때",
    action="사람 상담원과 대화하기를 원하는지 물어보거나, 계속 문제 해결을 시도할지 선택하게 하세요"
)

journey = await agent.create_journey(
    title="암보험 가입 상담",
    description="고객이 암보험 가입을 고려하는 전체 과정",
    conditions=["고객이 보험 가입을 원할 때"]
)

# 첫 단계: 방문 목적 파악
t0 = await journey.initial_state.transition_to(
    chat_state="방문 목적을 파악하세요"
)

# 두 번째 단계: 도구로 정보 조회
t1 = await t0.target.transition_to(tool_state=get_available_slots)

# 조건부 분기
await t1.target.transition_to(
    chat_state="시간을 확인하고 예약하세요",
    condition="고객이 시간을 선택할 때"
)

journey = await agent.create_journey(
    title="암보험 가입 상담",
    description="고객이 암보험 가입을 고려하는 전체 과정",
    conditions=["고객이 보험 가입을 원할 때"]
)

# 첫 단계: 방문 목적 파악
t0 = await journey.initial_state.transition_to(
    chat_state="방문 목적을 파악하세요"
)

# 두 번째 단계: 도구로 정보 조회
t1 = await t0.target.transition_to(tool_state=get_available_slots)

# 조건부 분기
await t1.target.transition_to(
    chat_state="시간을 확인하고 예약하세요",
    condition="고객이 시간을 선택할 때"
)

[초기] → [방문 목적 파악] → [가능 시간 조회] → [시간 제안]
                                        ↓
                              [고객이 시간 선택?]
                          Yes ↙          ↘ No
                    [상세 확인]        [나중 시간 조회]
                        ↓                    ↓
                    [예약 확정]          [시간 재제안]
                        ↓                    ↓
                    [완료]            [전화 안내] → [완료]

[초기] → [방문 목적 파악] → [가능 시간 조회] → [시간 제안]
                                        ↓
                              [고객이 시간 선택?]
                          Yes ↙          ↘ No
                    [상세 확인]        [나중 시간 조회]
                        ↓                    ↓
                    [예약 확정]          [시간 재제안]
                        ↓                    ↓
                    [완료]            [전화 안내] → [완료]

@p.tool
async def check_insurance_eligibility(
    context: p.ToolContext,
    customer_age: int,
    has_preexisting: bool
) -> p.ToolResult:
    """보험 가입 적격성 확인"""
    result = insurance_system.check_eligibility(
        age=customer_age,
        preexisting_conditions=has_preexisting
    )
    return p.ToolResult(
        success=True,
        data={
            "eligible": result.eligible, 
            "notes": result.notes
        }
    )

# consequential=True: 실제 변경을 일으키는 중요한 작업
@p.tool(consequential=True)
async def schedule_appointment(
    context: p.ToolContext, 
    datetime: datetime
) -> p.ToolResult:
    """예약 확정 (실제 데이터 변경)"""
    return p.ToolResult(
        data=f"예약이 {datetime}에 확정되었습니다"
    )

@p.tool
async def check_insurance_eligibility(
    context: p.ToolContext,
    customer_age: int,
    has_preexisting: bool
) -> p.ToolResult:
    """보험 가입 적격성 확인"""
    result = insurance_system.check_eligibility(
        age=customer_age,
        preexisting_conditions=has_preexisting
    )
    return p.ToolResult(
        success=True,
        data={
            "eligible": result.eligible, 
            "notes": result.notes
        }
    )

# consequential=True: 실제 변경을 일으키는 중요한 작업
@p.tool(consequential=True)
async def schedule_appointment(
    context: p.ToolContext, 
    datetime: datetime
) -> p.ToolResult:
    """예약 확정 (실제 데이터 변경)"""
    return p.ToolResult(
        data=f"예약이 {datetime}에 확정되었습니다"
    )

await agent.create_term(
    name="기왕증",
    description="보험 계약 체결 전에 이미 가지고 있던 질병이나 장애. 가입 시 고지의무 대상이며, 미고지 시 계약 해지나 보험금 지급 거절 사유가 될 수 있음"
)

await agent.create_term(
    name="Charles Xavier",
    synonyms=["Professor X"],
    description="신경학 전문 유명 의사"
)

await agent.create_term(
    name="Office Hours",
    description="영업시간은 월요일부터 금요일, 오전 9시부터 오후 5시까지"
)

await agent.create_term(
    name="기왕증",
    description="보험 계약 체결 전에 이미 가지고 있던 질병이나 장애. 가입 시 고지의무 대상이며, 미고지 시 계약 해지나 보험금 지급 거절 사유가 될 수 있음"
)

await agent.create_term(
    name="Charles Xavier",
    synonyms=["Professor X"],
    description="신경학 전문 유명 의사"
)

await agent.create_term(
    name="Office Hours",
    description="영업시간은 월요일부터 금요일, 오전 9시부터 오후 5시까지"
)

# 애매한 상황 정의
status_inquiry = await agent.create_observation(
    "고객이 방문 후속 조치를 문의하지만, 어떤 방식인지 불명확함"
)

# 두 Journey 중 선택하도록 유도
await status_inquiry.disambiguate([
    scheduling_journey, 
    lab_results_journey
])

# 애매한 상황 정의
status_inquiry = await agent.create_observation(
    "고객이 방문 후속 조치를 문의하지만, 어떤 방식인지 불명확함"
)

# 두 Journey 중 선택하도록 유도
await status_inquiry.disambiguate([
    scheduling_journey, 
    lab_results_journey
])

insurance-agent/
├── config/
│   ├── agent.yaml              # 에이전트 기본 정보
│   ├── guidelines/
│   │   ├── greeting.yaml       # 인사 및 접수
│   │   ├── consultation.yaml   # 상담 관련
│   │   ├── claims.yaml         # 보험금 청구
│   │   └── compliance.yaml     # 규제 준수
│   ├── glossary.yaml           # 보험 용어집
│   └── responses.yaml          # 고정 응답
├── tools/
│   ├── policy_lookup.py        # 보험 조회
│   └── eligibility_check.py    # 가입 적격성 확인
└── main.py                     # 메인 실행 파일

insurance-agent/
├── config/
│   ├── agent.yaml              # 에이전트 기본 정보
│   ├── guidelines/
│   │   ├── greeting.yaml       # 인사 및 접수
│   │   ├── consultation.yaml   # 상담 관련
│   │   ├── claims.yaml         # 보험금 청구
│   │   └── compliance.yaml     # 규제 준수
│   ├── glossary.yaml           # 보험 용어집
│   └── responses.yaml          # 고정 응답
├── tools/
│   ├── policy_lookup.py        # 보험 조회
│   └── eligibility_check.py    # 가입 적격성 확인
└── main.py                     # 메인 실행 파일

name: "김보험"
description: |
  한국생명 고객센터의 전문 상담원입니다.
  고객의 보험 가입, 계약 관리, 보험금 청구를 친절하고 정확하게 안내합니다.
  금융소비자보호법과 보험업법을 철저히 준수합니다.

name: "김보험"
description: |
  한국생명 고객센터의 전문 상담원입니다.
  고객의 보험 가입, 계약 관리, 보험금 청구를 친절하고 정확하게 안내합니다.
  금융소비자보호법과 보험업법을 철저히 준수합니다.

guidelines:
  - condition: "고객이 처음 보험 상담을 요청할 때"
    action: "나이, 직업, 가족 구성, 기존 보험 가입 여부를 순서대로 확인하세요"

  - condition: "고객이 특정 보험 상품을 문의할 때"
    action: "보장 내용, 보험료, 가입 조건을 설명하되, 가입을 강요하지 마세요. '신중한 검토 후 결정하시라'고 안내하세요"

  - condition: "고객이 기왕증(기존 질병)이 있다고 말할 때"
    action: "정확한 진단명과 치료 내역을 확인하고, 가입 가능 여부는 심사팀 확인이 필요하다고 안내하세요. 절대 즉석에서 가입 가능/불가능을 판단하지 마세요"

guidelines:
  - condition: "고객이 처음 보험 상담을 요청할 때"
    action: "나이, 직업, 가족 구성, 기존 보험 가입 여부를 순서대로 확인하세요"

  - condition: "고객이 특정 보험 상품을 문의할 때"
    action: "보장 내용, 보험료, 가입 조건을 설명하되, 가입을 강요하지 마세요. '신중한 검토 후 결정하시라'고 안내하세요"

  - condition: "고객이 기왕증(기존 질병)이 있다고 말할 때"
    action: "정확한 진단명과 치료 내역을 확인하고, 가입 가능 여부는 심사팀 확인이 필요하다고 안내하세요. 절대 즉석에서 가입 가능/불가능을 판단하지 마세요"

guidelines:
  - condition: "고객이 보험금 청구를 문의할 때"
    action: "보험증권 번호를 확인하고, 청구 사유를 파악한 후 필요 서류를 안내하세요"

  - condition: "고객이 청구 승인 여부를 물어볼 때"
    action: "심사는 별도 부서에서 약관에 따라 진행된다고 안내하고, 승인 가능성을 예측하지 마세요. 심사 기간(7-14일)만 안내하세요"

  - condition: "고객이 청구가 거절되어 항의할 때"
    action: "거절 사유를 확인하고, 이의신청 절차를 안내하세요. 금융감독원 분쟁조정 제도도 소개하세요"

guidelines:
  - condition: "고객이 보험금 청구를 문의할 때"
    action: "보험증권 번호를 확인하고, 청구 사유를 파악한 후 필요 서류를 안내하세요"

  - condition: "고객이 청구 승인 여부를 물어볼 때"
    action: "심사는 별도 부서에서 약관에 따라 진행된다고 안내하고, 승인 가능성을 예측하지 마세요. 심사 기간(7-14일)만 안내하세요"

  - condition: "고객이 청구가 거절되어 항의할 때"
    action: "거절 사유를 확인하고, 이의신청 절차를 안내하세요. 금융감독원 분쟁조정 제도도 소개하세요"

guidelines:
  - condition: "보험 상품을 설명할 때"
    action: "반드시 '이 안내는 약관을 요약한 것이며, 정확한 내용은 약관을 확인하시기 바랍니다'라고 고지하세요"

  - condition: "고객의 개인정보를 요청할 때"
    action: "수집 목적과 이용 범위를 먼저 설명하고, 동의를 받은 후에만 진행하세요"

  - condition: "불완전판매 우려 상황일 때"
    action: "고객이 상품을 충분히 이해했는지 확인하고, 필요시 대면 상담을 권유하세요"

guidelines:
  - condition: "보험 상품을 설명할 때"
    action: "반드시 '이 안내는 약관을 요약한 것이며, 정확한 내용은 약관을 확인하시기 바랍니다'라고 고지하세요"

  - condition: "고객의 개인정보를 요청할 때"
    action: "수집 목적과 이용 범위를 먼저 설명하고, 동의를 받은 후에만 진행하세요"

  - condition: "불완전판매 우려 상황일 때"
    action: "고객이 상품을 충분히 이해했는지 확인하고, 필요시 대면 상담을 권유하세요"

terms:
  - term: "기왕증"
    definition: "보험 계약 체결 전에 이미 가지고 있던 질병이나 장애. 가입 시 고지의무 대상"

  - term: "면책기간"
    definition: "보험 계약 체결 후 일정 기간 동안 보험금을 지급하지 않는 기간. 암보험의 경우 일반적으로 90일"

  - term: "실손보험"
    definition: "실제 발생한 의료비를 보장하는 보험. 중복 가입 시 비례보상 원칙 적용"

terms:
  - term: "기왕증"
    definition: "보험 계약 체결 전에 이미 가지고 있던 질병이나 장애. 가입 시 고지의무 대상"

  - term: "면책기간"
    definition: "보험 계약 체결 후 일정 기간 동안 보험금을 지급하지 않는 기간. 암보험의 경우 일반적으로 90일"

  - term: "실손보험"
    definition: "실제 발생한 의료비를 보장하는 보험. 중복 가입 시 비례보상 원칙 적용"

canned_responses:
  - trigger: "상담 시간 안내"
    response: |
      📞 한국생명 고객센터 운영 시간
      - 평일: 09:00 ~ 18:00
      - 토요일: 09:00 ~ 13:00
      - 일요일 및 공휴일: 휴무

      ⚠️ 긴급 보험금 청구는 24시간 가능합니다

  - trigger: "필요 서류 안내"
    response: |
      📋 보험금 청구 기본 서류
      1. 보험금 청구서 (서명 필수)
      2. 신분증 사본
      3. 진단서 또는 소견서
      4. 진료비 영수증 (원본)
      5. 통장 사본

canned_responses:
  - trigger: "상담 시간 안내"
    response: |
      📞 한국생명 고객센터 운영 시간
      - 평일: 09:00 ~ 18:00
      - 토요일: 09:00 ~ 13:00
      - 일요일 및 공휴일: 휴무

      ⚠️ 긴급 보험금 청구는 24시간 가능합니다

  - trigger: "필요 서류 안내"
    response: |
      📋 보험금 청구 기본 서류
      1. 보험금 청구서 (서명 필수)
      2. 신분증 사본
      3. 진단서 또는 소견서
      4. 진료비 영수증 (원본)
      5. 통장 사본

import parlant.sdk as p

@p.tool
async def lookup_policy_details(
    context: p.ToolContext,
    policy_number: str
) -> p.ToolResult:
    """보험 계약 정보 조회"""
    try:
        policy = await insurance_db.get_policy(policy_number)

        return p.ToolResult(
            success=True,
            data={
                "product_name": policy.product_name,
                "coverage_amount": policy.coverage_amount,
                "premium": policy.monthly_premium,
                "status": policy.status
            }
        )
    except PolicyNotFoundError:
        return p.ToolResult(
            success=False,
            error="해당 증권번호를 찾을 수 없습니다"
        )

@p.tool
async def calculate_premium(
    context: p.ToolContext,
    product_code: str,
    age: int,
    gender: str,
    coverage_amount: int
) -> p.ToolResult:
    """보험료 계산"""
    base_rate = premium_table.get_rate(product_code, age, gender)
    premium = base_rate * (coverage_amount / 10000000)

    return p.ToolResult(
        success=True,
        data={
            "monthly_premium": round(premium),
            "annual_premium": round(premium * 12)
        }
    )

import parlant.sdk as p

@p.tool
async def lookup_policy_details(
    context: p.ToolContext,
    policy_number: str
) -> p.ToolResult:
    """보험 계약 정보 조회"""
    try:
        policy = await insurance_db.get_policy(policy_number)

        return p.ToolResult(
            success=True,
            data={
                "product_name": policy.product_name,
                "coverage_amount": policy.coverage_amount,
                "premium": policy.monthly_premium,
                "status": policy.status
            }
        )
    except PolicyNotFoundError:
        return p.ToolResult(
            success=False,
            error="해당 증권번호를 찾을 수 없습니다"
        )

@p.tool
async def calculate_premium(
    context: p.ToolContext,
    product_code: str,
    age: int,
    gender: str,
    coverage_amount: int
) -> p.ToolResult:
    """보험료 계산"""
    base_rate = premium_table.get_rate(product_code, age, gender)
    premium = base_rate * (coverage_amount / 10000000)

    return p.ToolResult(
        success=True,
        data={
            "monthly_premium": round(premium),
            "annual_premium": round(premium * 12)
        }
    )

import asyncio
from pathlib import Path
import yaml
import parlant.sdk as p
from tools.policy_lookup_simple import lookup_policy, calc_premium


class InsuranceAgentLoader:
    """보험 상담 에이전트 로더 클래스"""

    def __init__(self, config_dir="config"):
        """
        Args:
            config_dir: YAML 설정 파일이 위치한 디렉토리 경로
        """
        self.config_dir = Path(config_dir)

    def load_yaml(self, file_path):
        """YAML 파일을 로드하여 딕셔너리로 반환"""
        with open(file_path, "r", encoding="utf-8") as f:
            return yaml.safe_load(f)

    def load_all_guidelines(self):
        """config/guidelines/ 디렉토리의 모든 가이드라인 YAML 파일을 로드"""
        guidelines = []
        guidelines_dir = self.config_dir / "guidelines"

        for yaml_file in sorted(guidelines_dir.glob("*.yaml")):
            config = self.load_yaml(yaml_file)
            guidelines.extend(config.get("guidelines", []))

        return guidelines

    async def create_agent(self, server):
        """
        에이전트를 생성하고 설정을 적용합니다.

        Args:
            server: Parlant Server 인스턴스

        Returns:
            생성된 Agent 객체
        """
        # 1. 에이전트 생성
        agent_config = self.load_yaml(self.config_dir / "agent.yaml")
        agent = await server.create_agent(
            name=agent_config["name"],
            description=agent_config["description"]
        )
        print(f"✅ 에이전트 생성: {agent_config['name']}")

        # 2. 가이드라인 추가
        guidelines = self.load_all_guidelines()
        for guideline in guidelines:
            await agent.create_guideline(
                condition=guideline["condition"],
                action=guideline["action"]
            )
        print(f"✅ {len(guidelines)}개 가이드라인 추가")

        # 3. 용어집 추가
        glossary = self.load_yaml(self.config_dir / "glossary.yaml")
        for term in glossary.get("terms", []):
            await agent.create_term(
                name=term["term"],
                description=term["definition"]
            )
        print(f"✅ {len(glossary.get('terms', []))}개 용어 추가")

        # 4. 고정 응답 추가
        responses = self.load_yaml(self.config_dir / "responses.yaml")
        for response in responses.get("canned_responses", []):
            await agent.create_canned_response(
                template=response["response"],
                signals=[response["trigger"]]
            )
        print(f"✅ {len(responses.get('canned_responses', []))}개 고정 응답 추가")

        # 5. 도구 연결
        await agent.attach_tool(
            lookup_policy,
            condition="고객이 보험 정보를 조회할 때"
        )
        await agent.attach_tool(
            calc_premium,
            condition="고객이 보험료를 계산하고 싶을 때"
        )
        print("✅ 2개 도구 추가")

        return agent


async def main():
    """메인 실행 함수"""
    loader = InsuranceAgentLoader("config")

    async with p.Server(nlp_service=p.NLPServices.openai) as server:
        agent = await loader.create_agent(server)

        print("\n" + "="*50)
        print("🎉 보험 상담 AI 에이전트 준비 완료!")
        print("📱 테스트: http://localhost:8800")
        print("="*50)


if __name__ == "__main__":
    asyncio.run(main())

import asyncio
from pathlib import Path
import yaml
import parlant.sdk as p
from tools.policy_lookup_simple import lookup_policy, calc_premium


class InsuranceAgentLoader:
    """보험 상담 에이전트 로더 클래스"""

    def __init__(self, config_dir="config"):
        """
        Args:
            config_dir: YAML 설정 파일이 위치한 디렉토리 경로
        """
        self.config_dir = Path(config_dir)

    def load_yaml(self, file_path):
        """YAML 파일을 로드하여 딕셔너리로 반환"""
        with open(file_path, "r", encoding="utf-8") as f:
            return yaml.safe_load(f)

    def load_all_guidelines(self):
        """config/guidelines/ 디렉토리의 모든 가이드라인 YAML 파일을 로드"""
        guidelines = []
        guidelines_dir = self.config_dir / "guidelines"

        for yaml_file in sorted(guidelines_dir.glob("*.yaml")):
            config = self.load_yaml(yaml_file)
            guidelines.extend(config.get("guidelines", []))

        return guidelines

    async def create_agent(self, server):
        """
        에이전트를 생성하고 설정을 적용합니다.

        Args:
            server: Parlant Server 인스턴스

        Returns:
            생성된 Agent 객체
        """
        # 1. 에이전트 생성
        agent_config = self.load_yaml(self.config_dir / "agent.yaml")
        agent = await server.create_agent(
            name=agent_config["name"],
            description=agent_config["description"]
        )
        print(f"✅ 에이전트 생성: {agent_config['name']}")

        # 2. 가이드라인 추가
        guidelines = self.load_all_guidelines()
        for guideline in guidelines:
            await agent.create_guideline(
                condition=guideline["condition"],
                action=guideline["action"]
            )
        print(f"✅ {len(guidelines)}개 가이드라인 추가")

        # 3. 용어집 추가
        glossary = self.load_yaml(self.config_dir / "glossary.yaml")
        for term in glossary.get("terms", []):
            await agent.create_term(
                name=term["term"],
                description=term["definition"]
            )
        print(f"✅ {len(glossary.get('terms', []))}개 용어 추가")

        # 4. 고정 응답 추가
        responses = self.load_yaml(self.config_dir / "responses.yaml")
        for response in responses.get("canned_responses", []):
            await agent.create_canned_response(
                template=response["response"],
                signals=[response["trigger"]]
            )
        print(f"✅ {len(responses.get('canned_responses', []))}개 고정 응답 추가")

        # 5. 도구 연결
        await agent.attach_tool(
            lookup_policy,
            condition="고객이 보험 정보를 조회할 때"
        )
        await agent.attach_tool(
            calc_premium,
            condition="고객이 보험료를 계산하고 싶을 때"
        )
        print("✅ 2개 도구 추가")

        return agent


async def main():
    """메인 실행 함수"""
    loader = InsuranceAgentLoader("config")

    async with p.Server(nlp_service=p.NLPServices.openai) as server:
        agent = await loader.create_agent(server)

        print("\n" + "="*50)
        print("🎉 보험 상담 AI 에이전트 준비 완료!")
        print("📱 테스트: http://localhost:8800")
        print("="*50)


if __name__ == "__main__":
    asyncio.run(main())

👤 고객: 안녕하세요, 암보험 가입 상담 받고 싶어요.

🤖 김보험: 안녕하세요! 한국생명 김보험입니다. 암보험 상담을 도와드리겠습니다.
더 나은 상담을 위해 몇 가지 여쭤볼게요.

1. 현재 연세가 어떻게 되시나요?
2. 직업은 무엇이신가요?
3. 현재 가입하신 다른 보험이 있으신가요?

👤 고객: 35세이고, 회사원입니다. 실손보험만 있어요.

🤖 김보험: 35세 회사원이시고 실손보험을 보유 중이시군요. 
한 가지 더 확인할 사항이 있습니다. 현재 치료 중이시거나 과거에 
중대한 질병 진단을 받으신 적이 있으신가요?

👤 고객: 작년에 위염으로 치료받은 적 있어요.

🤖 김보험: 위염 치료 이력이 있으시군요. 정확한 가입 가능 여부와 
조건은 심사팀의 확인이 필요합니다.

[calculate_premium 도구 호출]

고객님 나이와 조건으로 계산한 월 보험료는 약 45,000원입니다.
주요 보장 내용은 다음과 같습니다:
- 암 진단 시: 3,000만원
- 암 수술 시: 500만원
- 암 입원 시: 일당 10만원

⚠️ 이 안내는 약관을 요약한 것이며, 정확한 내용은 약관을 
확인하시기 바랍니다.

더 자세한 상담이나 가입 신청을 원하시면 전문 상담사와 
연결해드릴까요?

👤 고객: 안녕하세요, 암보험 가입 상담 받고 싶어요.

🤖 김보험: 안녕하세요! 한국생명 김보험입니다. 암보험 상담을 도와드리겠습니다.
더 나은 상담을 위해 몇 가지 여쭤볼게요.

1. 현재 연세가 어떻게 되시나요?
2. 직업은 무엇이신가요?
3. 현재 가입하신 다른 보험이 있으신가요?

👤 고객: 35세이고, 회사원입니다. 실손보험만 있어요.

🤖 김보험: 35세 회사원이시고 실손보험을 보유 중이시군요. 
한 가지 더 확인할 사항이 있습니다. 현재 치료 중이시거나 과거에 
중대한 질병 진단을 받으신 적이 있으신가요?

👤 고객: 작년에 위염으로 치료받은 적 있어요.

🤖 김보험: 위염 치료 이력이 있으시군요. 정확한 가입 가능 여부와 
조건은 심사팀의 확인이 필요합니다.

[calculate_premium 도구 호출]

고객님 나이와 조건으로 계산한 월 보험료는 약 45,000원입니다.
주요 보장 내용은 다음과 같습니다:
- 암 진단 시: 3,000만원
- 암 수술 시: 500만원
- 암 입원 시: 일당 10만원

⚠️ 이 안내는 약관을 요약한 것이며, 정확한 내용은 약관을 
확인하시기 바랍니다.

더 자세한 상담이나 가입 신청을 원하시면 전문 상담사와 
연결해드릴까요?

# Parlant 설치
pip install parlant

# LLM 제공자 선택 (하나 선택)
pip install anthropic        # Claude 사용 시 (권장)
pip install openai          # GPT 사용 시

# 추가 의존성
pip install pyyaml python-dotenv

# Parlant 설치
pip install parlant

# LLM 제공자 선택 (하나 선택)
pip install anthropic        # Claude 사용 시 (권장)
pip install openai          # GPT 사용 시

# 추가 의존성
pip install pyyaml python-dotenv

# Claude 사용 시
export ANTHROPIC_API_KEY='your-api-key'

# OpenAI 사용 시
export OPENAI_API_KEY='your-openai-key'

# Claude 사용 시
export ANTHROPIC_API_KEY='your-api-key'

# OpenAI 사용 시
export OPENAI_API_KEY='your-openai-key'

import asyncio
import parlant.sdk as p

async def main():
    async with p.Server() as server:
        agent = await server.create_agent(
            name="상담원",
            description="친절한 보험 상담원"
        )

        # 가이드라인 추가
        await agent.create_guideline(
            condition="고객이 인사할 때",
            action="밝게 환영하세요"
        )

        print("에이전트 준비 완료: http://localhost:8800")

asyncio.run(main())

import asyncio
import parlant.sdk as p

async def main():
    async with p.Server() as server:
        agent = await server.create_agent(
            name="상담원",
            description="친절한 보험 상담원"
        )

        # 가이드라인 추가
        await agent.create_guideline(
            condition="고객이 인사할 때",
            action="밝게 환영하세요"
        )

        print("에이전트 준비 완료: http://localhost:8800")

asyncio.run(main())