Claude Agent SDK

from claude_agent_sdk import query, ClaudeAgentOptions
"""
query는 Claude Agent SDK에서 import된 핵심 함수입니다. 이 함수가 실제로 Claude API와 통신하여 응답을 받아오는 역할을 합니다.

query 함수의 동작 방식

async for message in query(prompt=prompt, options=options):
★ Insight ─────────────────────────────────────
query는 async generator 패턴을 사용합니다. 일반 함수처럼 한 번에 결과를 반환하는 게 아니라, 응답이 생성되는 동안 여러 메시지를 스트리밍으로 yield합니다. 이 덕분에 긴 응답도 실시간으로
 처리할 수 있습니다.
─────────────────────────────────────────────────
메시지 타입별 처리 흐름
"""

async for message in query(prompt=prompt, options=options):
    message_type = type(message).__name__

    # 1. AssistantMessage: 중간 응답들
    if message_type == 'AssistantMessage':
        if hasattr(message, 'content') and isinstance(message.content, list):
            for block in message.content:
                if hasattr(block, 'text'):
                    result_content += block.text

    # 2. ResultMessage: 최종 결과
    if message_type == 'ResultMessage':
        if hasattr(message, 'result') and message.result:
            result_content = message.result  # 덮어쓰기

CODE_GENERATOR_PROMPT = """
You are an expert software developer who implements complete, production-ready projects.
Your task is to implement a project based on the provided specification, technical plan, and task list.
"""

options = ClaudeAgentOptions(
    system_prompt=CODE_GENERATOR_PROMPT,
    max_turns=50,  # Allow many turns for complex implementation
    model="claude-sonnet-4-5-20250929",  # Use powerful model for implementation
    allowed_tools=["Read", "Write", "Edit", "Bash", "Glob", "Grep", "WebSearch", "WebFetch", "Task"],
)

from claude_agent_sdk import ClaudeSDKClient, ClaudeAgentOptions

options = ClaudeAgentOptions(
    model="claude-sonnet-4-5-20250929",  # 사용할 모델
    allowed_tools=["Read", "Write", "Edit", "Bash"],  # 허용할 도구들
    permission_mode="acceptEdits",  # 권한 모드
    cwd="/path/to/working/dir",  # 작업 디렉토리
    resume="session_id_here",  # 세션 재개시 사용
    mcp_servers={...}  # MCP 서버 설정
)

client = ClaudeSDKClient(options=options)
await client.connect()  # 연결 시작

await client.query("사용자 메시지")  # 쿼리 전송

async for message in client.receive_response():  # 스트리밍 응답 수신
    # message 타입: AssistantMessage, SystemMessage, ResultMessage 등
    print(message)

await client.disconnect()