计划执行与检查节点
executing-plans
按既定实施计划完成工作,保持过程检查和反馈。
clade-observability【效率与协作】Monitor Claude API calls — log tokens, latency, costs, errors, and Use when working with observability patterns. set up alerts for production Claude integrations. Trigger with "anthropic monitoring", "claude observability", "track claude usage", "anthropic logging".
独立 GitHub 快照 · 自动分类 · 以原作者文档为准
name: clade-observability
description: "Monitor Claude API calls \u2014 log tokens, latency, costs, errors,
\ and\nUse when working with observability patterns.\nset up alerts for production
\ Claude integrations.\nTrigger with "anthropic monitoring", "claude observability"
,\n"track claude usage", "anthropic logging".\n"
allowed-tools: Read, Write, Edit
version: 1.1.0
license: MIT
author: Jeremy Longshore jeremy@intentsolutions.io
tags:
Every messages.create call should be instrumented. Track tokens, latency, cost, model, and errors.
import Anthropic from '@claude-ai/sdk';
const client = new Anthropic();
async function trackedCreate(params: Anthropic.MessageCreateParams) {
const start = performance.now();
try {
const message = await client.messages.create(params);
const durationMs = Math.round(performance.now() - start);
const log = {
timestamp: new Date().toISOString(),
model: message.model,
input_tokens: message.usage.input_tokens,
output_tokens: message.usage.output_tokens,
cache_read_tokens: message.usage.cache_read_input_tokens || 0,
duration_ms: durationMs,
stop_reason: message.stop_reason,
estimated_cost: estimateCost(message.model, message.usage),
};
console.log('anthropic_request', JSON.stringify(log));
return message;
} catch (err) {
const durationMs = Math.round(performance.now() - start);
console.error('anthropic_error', JSON.stringify({
timestamp: new Date().toISOString(),
model: params.model,
error_type: err instanceof Anthropic.APIError ? err.error?.type : 'unknown',
status: err instanceof Anthropic.APIError ? err.status : null,
request_id: err instanceof Anthropic.APIError ? err.headers?.['request-id'] : null,
duration_ms: durationMs,
}));
throw err;
}
}
function estimateCost(model: string, usage: Anthropic.Usage): number {
const rates: Record<string, [number, number]> = {
'claude-opus-4-20250514': [15, 75],
'claude-sonnet-4-20250514': [3, 15],
'claude-haiku-4-5-20251001': [0.80, 4],
};
const [inputRate, outputRate] = rates[model] || [3, 15];
return (usage.input_tokens * inputRate + usage.output_tokens * outputRate) / 1_000_000;
}
| Metric | Source | Alert Threshold |
|---|---|---|
| Error rate | error logs | > 5% over 5 minutes |
| p95 latency | duration_ms | > 10s (Sonnet) |
| Daily cost | estimated_cost sum | > 2x daily average |
| 429 rate | error_type = rate_limit | > 10/minute |
| 529 rate | error_type = overloaded | > 5/minute |
| Token usage | input_tokens + output_tokens | > daily budget |
| Error | Cause | Solution |
|---|---|---|
| API Error | Check error type and status code | See clade-common-errors |
See Logging Wrapper with trackedCreate(), estimateCost() function, Key Metrics table with alert thresholds, and Anthropic Console Monitoring section above.
See clade-incident-runbook for when things go wrong.
clade-install-authEach section contains production-ready code examples. Copy and adapt them to your use case.
Integrate the patterns that match your requirements. Test each change individually.
Run your test suite to confirm the integration works correctly.