计划执行与检查节点
executing-plans
按既定实施计划完成工作,保持过程检查和反馈。
instantly-observability【效率与协作】Set up comprehensive observability for Instantly integrations with metrics, traces, and alerts. Use when implementing monitoring for Instantly operations, setting up dashboards, or configuring alerting for Instantly integration health. Trigger with phrases like "instantly monitoring", "instantly metrics", "instantly observability", "monitor instantly…
独立 GitHub 快照 · 自动分类 · 以原作者文档为准
Set up comprehensive observability for Instantly integrations.
| Metric | Type | Description |
|---|---|---|
instantly_requests_total | Counter | Total API requests |
instantly_request_duration_seconds | Histogram | Request latency |
instantly_errors_total | Counter | Error count by type |
instantly_rate_limit_remaining | Gauge | Rate limit headroom |
import { Registry, Counter, Histogram, Gauge } from 'prom-client';
const registry = new Registry();
const requestCounter = new Counter({
name: 'instantly_requests_total',
help: 'Total Instantly API requests',
labelNames: ['method', 'status'],
registers: [registry],
});
const requestDuration = new Histogram({
name: 'instantly_request_duration_seconds',
help: 'Instantly request duration',
labelNames: ['method'],
buckets: [0.05, 0.1, 0.25, 0.5, 1, 2.5, 5],
registers: [registry],
});
const errorCounter = new Counter({
name: 'instantly_errors_total',
help: 'Instantly errors by type',
labelNames: ['error_type'],
registers: [registry],
});
async function instrumentedRequest<T>(
method: string,
operation: () => Promise<T>
): Promise<T> {
const timer = requestDuration.startTimer({ method });
try {
const result = await operation();
requestCounter.inc({ method, status: 'success' });
return result;
} catch (error: any) {
requestCounter.inc({ method, status: 'error' });
errorCounter.inc({ error_type: error.code || 'unknown' });
throw error;
} finally {
timer();
}
}
import { trace, SpanStatusCode } from '@opentelemetry/api';
const tracer = trace.getTracer('instantly-client');
async function tracedInstantlyCall<T>(
operationName: string,
operation: () => Promise<T>
): Promise<T> {
return tracer.startActiveSpan(`instantly.${operationName}`, async (span) => {
try {
const result = await operation();
span.setStatus({ code: SpanStatusCode.OK });
return result;
} catch (error: any) {
span.setStatus({ code: SpanStatusCode.ERROR, message: error.message });
span.recordException(error);
throw error;
} finally {
span.end();
}
});
}
import pino from 'pino';
const logger = pino({
name: 'instantly',
level: process.env.LOG_LEVEL || 'info',
});
function logInstantlyOperation(
operation: string,
data: Record<string, any>,
duration: number
) {
logger.info({
service: 'instantly',
operation,
duration_ms: duration,
...data,
});
}
# instantly_alerts.yaml
groups:
- name: instantly_alerts
rules:
- alert: InstantlyHighErrorRate
expr: |
rate(instantly_errors_total[5m]) /
rate(instantly_requests_total[5m]) > 0.05
for: 5m
labels:
severity: warning
annotations:
summary: "Instantly error rate > 5%"
- alert: InstantlyHighLatency
expr: |
histogram_quantile(0.95,
rate(instantly_request_duration_seconds_bucket[5m])
) > 2
for: 5m
labels:
severity: warning
annotations:
summary: "Instantly P95 latency > 2s"
- alert: InstantlyDown
expr: up{job="instantly"} == 0
for: 1m
labels:
severity: critical
annotations:
summary: "Instantly integration is down"
{
"panels": [
{
"title": "Instantly Request Rate",
"targets": [{
"expr": "rate(instantly_requests_total[5m])"
}]
},
{
"title": "Instantly Latency P50/P95/P99",
"targets": [{
"expr": "histogram_quantile(0.5, rate(instantly_request_duration_seconds_bucket[5m]))"
}]
}
]
}
Implement Prometheus counters, histograms, and gauges for key operations.
Integrate OpenTelemetry for end-to-end request tracing.
Set up JSON logging with consistent field names.
Define Prometheus alerting rules for error rates and latency.
| Issue | Cause | Solution |
|---|---|---|
| Missing metrics | No instrumentation | Wrap client calls |
| Trace gaps | Missing propagation | Check context headers |
| Alert storms | Wrong thresholds | Tune alert rules |
| High cardinality | Too many labels | Reduce label values |
app.get('/metrics', async (req, res) => {
res.set('Content-Type', registry.contentType);
res.send(await registry.metrics());
});
For incident response, see instantly-incident-runbook.