Dapatkan output terstruktur dari agen

import { query } from "@anthropic-ai/claude-agent-sdk";

// Tentukan bentuk data yang ingin Anda kembalikan
const schema = {
  type: "object",
  properties: {
    company_name: { type: "string" },
    founded_year: { type: "number" },
    headquarters: { type: "string" }
  },
  required: ["company_name"]
};

try {
  for await (const message of query({
    prompt: "Teliti Anthropic dan berikan informasi perusahaan utama",
    options: {
      outputFormat: {
        type: "json_schema",
        schema: schema
      }
    }
  })) {
    // Pesan hasil berisi structured_output dengan data yang divalidasi
    if (message.type === "result" && message.subtype === "success" && message.structured_output) {
      console.log(message.structured_output);
      // { company_name: "Anthropic", founded_year: 2021, headquarters: "San Francisco, CA" }
    }
  }
} catch (error) {
  // query() sekali jalan melempar setelah menghasilkan hasil kesalahan, seperti
  // error_max_structured_output_retries; lihat bagian Penanganan kesalahan.
  console.error(`Sesi berakhir dengan kesalahan: ${error}`);
}

import asyncio
from claude_agent_sdk import query, ClaudeAgentOptions, ResultMessage

# Tentukan bentuk data yang ingin Anda kembalikan
schema = {
    "type": "object",
    "properties": {
        "company_name": {"type": "string"},
        "founded_year": {"type": "number"},
        "headquarters": {"type": "string"},
    },
    "required": ["company_name"],
}


async def main():
    try:
        async for message in query(
            prompt="Teliti Anthropic dan berikan informasi perusahaan utama",
            options=ClaudeAgentOptions(
                output_format={"type": "json_schema", "schema": schema}
            ),
        ):
            # Pesan hasil berisi structured_output dengan data yang divalidasi
            if isinstance(message, ResultMessage) and message.structured_output:
                print(message.structured_output)
                # {'company_name': 'Anthropic', 'founded_year': 2021, 'headquarters': 'San Francisco, CA'}
    except Exception as error:
        # query() sekali jalan memunculkan exception setelah menghasilkan hasil kesalahan, seperti
        # error_max_structured_output_retries; lihat bagian Penanganan kesalahan.
        print(f"Sesi berakhir dengan kesalahan: {error}")


asyncio.run(main())

import { z } from "zod";
import { query } from "@anthropic-ai/claude-agent-sdk";

// Define schema with Zod
const FeaturePlan = z.object({
  feature_name: z.string(),
  summary: z.string(),
  steps: z.array(
    z.object({
      step_number: z.number(),
      description: z.string(),
      estimated_complexity: z.enum(["low", "medium", "high"])
    })
  ),
  risks: z.array(z.string())
});

type FeaturePlan = z.infer<typeof FeaturePlan>;

// Convert to JSON Schema using the draft-07 target the SDK expects
const schema = z.toJSONSchema(FeaturePlan, { target: "draft-7" });

// Use in query
try {
  for await (const message of query({
    prompt:
      "Plan how to add dark mode support to a React app. Break it into implementation steps.",
    options: {
      outputFormat: {
        type: "json_schema",
        schema: schema
      }
    }
  })) {
    if (message.type === "result" && message.subtype === "success" && message.structured_output) {
      // Validate and get fully typed result
      const parsed = FeaturePlan.safeParse(message.structured_output);
      if (parsed.success) {
        const plan: FeaturePlan = parsed.data;
        console.log(`Feature: ${plan.feature_name}`);
        console.log(`Summary: ${plan.summary}`);
        plan.steps.forEach((step) => {
          console.log(`${step.step_number}. [${step.estimated_complexity}] ${step.description}`);
        });
      }
    }
  }
} catch (error) {
  // A single-shot query() throws after yielding an error result, such as
  // error_max_structured_output_retries; see the Error handling section.
  console.error(`Session ended with an error: ${error}`);
}

import asyncio
from pydantic import BaseModel
from claude_agent_sdk import query, ClaudeAgentOptions, ResultMessage


class Step(BaseModel):
    step_number: int
    description: str
    estimated_complexity: str  # 'low', 'medium', 'high'


class FeaturePlan(BaseModel):
    feature_name: str
    summary: str
    steps: list[Step]
    risks: list[str]


async def main():
    try:
        async for message in query(
            prompt="Plan how to add dark mode support to a React app. Break it into implementation steps.",
            options=ClaudeAgentOptions(
                output_format={
                    "type": "json_schema",
                    "schema": FeaturePlan.model_json_schema(),
                }
            ),
        ):
            if isinstance(message, ResultMessage) and message.structured_output:
                # Validate and get fully typed result
                plan = FeaturePlan.model_validate(message.structured_output)
                print(f"Feature: {plan.feature_name}")
                print(f"Summary: {plan.summary}")
                for step in plan.steps:
                    print(
                        f"{step.step_number}. [{step.estimated_complexity}] {step.description}"
                    )
    except Exception as error:
        # A single-shot query() raises after yielding an error result, such as
        # error_max_structured_output_retries; see the Error handling section.
        print(f"Session ended with an error: {error}")


asyncio.run(main())

import { query } from "@anthropic-ai/claude-agent-sdk";

// Tentukan struktur untuk ekstraksi TODO
const todoSchema = {
  type: "object",
  properties: {
    todos: {
      type: "array",
      items: {
        type: "object",
        properties: {
          text: { type: "string" },
          file: { type: "string" },
          line: { type: "number" },
          author: { type: "string" },
          date: { type: "string" }
        },
        required: ["text", "file", "line"]
      }
    },
    total_count: { type: "number" }
  },
  required: ["todos", "total_count"]
};

// Agen menggunakan Grep untuk menemukan TODO, Bash untuk mendapatkan informasi git blame
try {
  for await (const message of query({
    prompt: "Temukan semua komentar TODO dalam basis kode ini dan identifikasi siapa yang menambahkannya",
    options: {
      outputFormat: {
        type: "json_schema",
        schema: todoSchema
      }
    }
  })) {
    if (message.type === "result" && message.subtype === "success" && message.structured_output) {
      const data = message.structured_output as { total_count: number; todos: Array<{ file: string; line: number; text: string; author?: string; date?: string }> };
      console.log(`Ditemukan ${data.total_count} TODO`);
      data.todos.forEach((todo) => {
        console.log(`${todo.file}:${todo.line} - ${todo.text}`);
        if (todo.author) {
          console.log(`  Ditambahkan oleh ${todo.author} pada ${todo.date}`);
        }
      });
    }
  }
} catch (error) {
  // Kueri query() sekali jalan melempar setelah menghasilkan hasil kesalahan, seperti
  // error_max_structured_output_retries; lihat bagian Penanganan kesalahan.
  console.error(`Sesi berakhir dengan kesalahan: ${error}`);
}

import asyncio
from claude_agent_sdk import query, ClaudeAgentOptions, ResultMessage

# Tentukan struktur untuk ekstraksi TODO
todo_schema = {
    "type": "object",
    "properties": {
        "todos": {
            "type": "array",
            "items": {
                "type": "object",
                "properties": {
                    "text": {"type": "string"},
                    "file": {"type": "string"},
                    "line": {"type": "number"},
                    "author": {"type": "string"},
                    "date": {"type": "string"},
                },
                "required": ["text", "file", "line"],
            },
        },
        "total_count": {"type": "number"},
    },
    "required": ["todos", "total_count"],
}


async def main():
    # Agen menggunakan Grep untuk menemukan TODO, Bash untuk mendapatkan informasi git blame
    try:
        async for message in query(
            prompt="Temukan semua komentar TODO dalam basis kode ini dan identifikasi siapa yang menambahkannya",
            options=ClaudeAgentOptions(
                output_format={"type": "json_schema", "schema": todo_schema}
            ),
        ):
            if isinstance(message, ResultMessage) and message.structured_output:
                data = message.structured_output
                print(f"Ditemukan {data['total_count']} TODO")
                for todo in data["todos"]:
                    print(f"{todo['file']}:{todo['line']} - {todo['text']}")
                    if "author" in todo:
                        print(f"  Ditambahkan oleh {todo['author']} pada {todo['date']}")
    except Exception as error:
        # Kueri query() sekali jalan melempar setelah menghasilkan hasil kesalahan, seperti
        # error_max_structured_output_retries; lihat bagian Penanganan kesalahan.
        print(f"Sesi berakhir dengan kesalahan: {error}")


asyncio.run(main())

import { query } from "@anthropic-ai/claude-agent-sdk";

const contactSchema = {
  type: "object",
  properties: {
    name: { type: "string" },
    email: { type: "string" }
  },
  required: ["name"]
};

try {
  for await (const msg of query({
    prompt: "Extract contact info from the document",
    options: {
      outputFormat: {
        type: "json_schema",
        schema: contactSchema
      }
    }
  })) {
    if (msg.type === "result") {
      if (msg.subtype === "success" && msg.structured_output) {
        // Gunakan output yang divalidasi
        console.log(msg.structured_output);
      } else if (msg.subtype === "error_max_structured_output_retries") {
        console.error("Tidak dapat menghasilkan output yang valid");
      } else {
        console.error("Jalannya berakhir tanpa output terstruktur");
      }
    }
  }
} catch (error) {
  // Sebuah query() single-shot melempar setelah menghasilkan pesan hasil kesalahan. Jika
  // kegagalannya adalah hasil kesalahan, cabang subtype kesalahan di atas telah
  // sudah berjalan; kegagalan koneksi atau proses tidak menghasilkan pesan hasil.
  console.log(`Sesi berakhir dengan kesalahan: ${error}`);
}

import asyncio
from claude_agent_sdk import query, ClaudeAgentOptions, ResultMessage

contact_schema = {
    "type": "object",
    "properties": {
        "name": {"type": "string"},
        "email": {"type": "string"},
    },
    "required": ["name"],
}


async def main():
    try:
        async for message in query(
            prompt="Extract contact info from the document",
            options=ClaudeAgentOptions(
                output_format={"type": "json_schema", "schema": contact_schema}
            ),
        ):
            if isinstance(message, ResultMessage):
                if message.subtype == "success" and message.structured_output:
                    # Gunakan output yang divalidasi
                    print(message.structured_output)
                elif message.subtype == "error_max_structured_output_retries":
                    print("Tidak dapat menghasilkan output yang valid")
                else:
                    print("Jalannya berakhir tanpa output terstruktur")
    except Exception as error:
        # Sebuah query() single-shot menaikkan setelah menghasilkan pesan hasil kesalahan. Jika
        # kegagalannya adalah hasil kesalahan, cabang subtype kesalahan di atas telah
        # sudah berjalan; kegagalan koneksi atau proses tidak menghasilkan pesan hasil.
        print(f"Sesi berakhir dengan kesalahan: {error}")


asyncio.run(main())