Claude Agent SDKは、Claudeとの各インタラクションに関する詳細なトークン使用量情報を提供します。このガイドでは、特に並列ツール使用やマルチステップの会話を扱う際に、コストを適切に追跡し、使用量レポートを理解する方法を説明します。
完全なAPIドキュメントについては、TypeScript SDKリファレンスを参照してください。
Claudeがリクエストを処理する際、メッセージレベルでトークン使用量を報告します。この使用量データは、コストの追跡とユーザーへの適切な課金に不可欠です。
Claudeがツールを実行する際、ツールが順次実行されるか並列実行されるかによって、使用量レポートが異なります:
import { query } from "@anthropic-ai/claude-agent-sdk";
// 例: 会話での使用量追跡
const result = await query({
prompt: "Analyze this codebase and run tests",
options: {
onMessage: (message) => {
if (message.type === 'assistant' && message.usage) {
console.log(`Message ID: ${message.id}`);
console.log(`Usage:`, message.usage);
}
}
}
});典型的なマルチステップ会話でのメッセージと使用量の報告方法は以下の通りです:
<!-- ステップ1: 並列ツール使用を含む初期リクエスト -->
assistant (text) { id: "msg_1", usage: { output_tokens: 100, ... } }
assistant (tool_use) { id: "msg_1", usage: { output_tokens: 100, ... } }
assistant (tool_use) { id: "msg_1", usage: { output_tokens: 100, ... } }
assistant (tool_use) { id: "msg_1", usage: { output_tokens: 100, ... } }
user (tool_result)
user (tool_result)
user (tool_result)
<!-- ステップ2: フォローアップレスポンス -->
assistant (text) { id: "msg_2", usage: { output_tokens: 98, ... } }同じidフィールドを持つすべてのメッセージは同一の使用量を報告します。Claudeが同じターンで複数のメッセージを送信する場合(例:テキスト + ツール使用)、それらは同じメッセージIDと使用量データを共有します。
// これらのメッセージはすべて同じIDと使用量を持つ
const messages = [
{ type: 'assistant', id: 'msg_123', usage: { output_tokens: 100 } },
{ type: 'assistant', id: 'msg_123', usage: { output_tokens: 100 } },
{ type: 'assistant', id: 'msg_123', usage: { output_tokens: 100 } }
];
// ユニークなメッセージIDごとに1回だけ課金する
const uniqueUsage = messages[0].usage; // このIDを持つすべてのメッセージで同じユーザーへの課金はステップごとに1回だけにすべきであり、個々のメッセージごとではありません。同じIDを持つ複数のアシスタントメッセージが表示された場合、そのうちのいずれか1つの使用量を使用してください。
最終的なresultメッセージには、会話内のすべてのステップからの合計累積使用量が含まれます:
// 最終結果には合計使用量が含まれる
const result = await query({
prompt: "Multi-step task",
options: { /* ... */ }
});
console.log("Total usage:", result.usage);
console.log("Total cost:", result.usage.total_cost_usd);結果メッセージにはmodelUsageも含まれており、モデルごとの正式な使用量データを提供します。total_cost_usdと同様に、このフィールドは正確で課金目的に適しています。これは、複数のモデルを使用する場合(例:サブエージェントにHaiku、メインエージェントにOpus)に特に便利です。
// modelUsageはモデルごとの内訳を提供する
type ModelUsage = {
inputTokens: number
outputTokens: number
cacheReadInputTokens: number
cacheCreationInputTokens: number
webSearchRequests: number
costUSD: number
contextWindow: number
}
// 結果メッセージからアクセス
const result = await query({ prompt: "..." });
// result.modelUsageはモデル名からModelUsageへのマップ
for (const [modelName, usage] of Object.entries(result.modelUsage)) {
console.log(`${modelName}: $${usage.costUSD.toFixed(4)}`);
console.log(` Input tokens: ${usage.inputTokens}`);
console.log(` Output tokens: ${usage.outputTokens}`);
}完全な型定義については、TypeScript SDKリファレンスを参照してください。
コスト追跡システムの実装の完全な例を以下に示します:
import { query } from "@anthropic-ai/claude-agent-sdk";
class CostTracker {
private processedMessageIds = new Set<string>();
private stepUsages: Array<any> = [];
async trackConversation(prompt: string) {
const result = await query({
prompt,
options: {
onMessage: (message) => {
this.processMessage(message);
}
}
});
return {
result,
stepUsages: this.stepUsages,
totalCost: result.usage?.total_cost_usd || 0
};
}
private processMessage(message: any) {
// 使用量を持つアシスタントメッセージのみ処理
if (message.type !== 'assistant' || !message.usage) {
return;
}
// このメッセージIDが既に処理済みの場合はスキップ
if (this.processedMessageIds.has(message.id)) {
return;
}
// 処理済みとしてマークし、使用量を記録
this.processedMessageIds.add(message.id);
this.stepUsages.push({
messageId: message.id,
timestamp: new Date().toISOString(),
usage: message.usage,
costUSD: this.calculateCost(message.usage)
});
}
private calculateCost(usage: any): number {
// ここに料金計算を実装
// これは簡略化された例です
const inputCost = usage.input_tokens * 0.00003;
const outputCost = usage.output_tokens * 0.00015;
const cacheReadCost = (usage.cache_read_input_tokens || 0) * 0.0000075;
return inputCost + outputCost + cacheReadCost;
}
}
// 使用方法
const tracker = new CostTracker();
const { result, stepUsages, totalCost } = await tracker.trackConversation(
"Analyze and refactor this code"
);
console.log(`Steps processed: ${stepUsages.length}`);
console.log(`Total cost: $${totalCost.toFixed(4)}`);まれに、同じIDを持つメッセージで異なるoutput_tokens値が観察される場合があります。この場合:
total_cost_usdが正式な値ですプロンプトキャッシュを使用する場合、これらのトークンタイプを個別に追跡してください:
interface CacheUsage {
cache_creation_input_tokens: number;
cache_read_input_tokens: number;
cache_creation: {
ephemeral_5m_input_tokens: number;
ephemeral_1h_input_tokens: number;
};
}各使用量オブジェクトには以下が含まれます:
input_tokens: 処理されたベース入力トークンoutput_tokens: レスポンスで生成されたトークンcache_creation_input_tokens: キャッシュエントリの作成に使用されたトークンcache_read_input_tokens: キャッシュから読み取られたトークンservice_tier: 使用されたサービスティア(例:「standard」)total_cost_usd: USD単位の合計コスト(結果メッセージのみ)課金ダッシュボード用に使用量データを集計する方法は以下の通りです:
class BillingAggregator {
private userUsage = new Map<string, {
totalTokens: number;
totalCost: number;
conversations: number;
}>();
async processUserRequest(userId: string, prompt: string) {
const tracker = new CostTracker();
const { result, stepUsages, totalCost } = await tracker.trackConversation(prompt);
// ユーザーの合計を更新
const current = this.userUsage.get(userId) || {
totalTokens: 0,
totalCost: 0,
conversations: 0
};
const totalTokens = stepUsages.reduce((sum, step) =>
sum + step.usage.input_tokens + step.usage.output_tokens, 0
);
this.userUsage.set(userId, {
totalTokens: current.totalTokens + totalTokens,
totalCost: current.totalCost + totalCost,
conversations: current.conversations + 1
});
return result;
}
getUserBilling(userId: string) {
return this.userUsage.get(userId) || {
totalTokens: 0,
totalCost: 0,
conversations: 0
};
}
}Was this page helpful?