elasticsearch-anomaly-detection-explainer
>
它会碰到什么
这一栏是扫描器报的事实,不是结论。命中多不等于有毒(安全工具、规则库、示例脚本本来就会包含危险写法),命中少也不等于干净。它和你手上的凭据、文件、网络有什么关系,需要你自己看。
技能内容
Anomaly Detection Score Explainer
Explain anomaly scores, model behavior, and why results look the way they do. Use the ML REST API for job config and
the standard _search API against .ml-anomalies-* for results — no ES|QL, fully compatible with Elastic
Serverless. For job lifecycle (create, start, stop), use the elasticsearch-anomaly-detection skill.
<!-- begin-partial: preamble -->
Environment Configuration
This skill executes Elasticsearch operations through the elastic CLI. If the
elastic CLI is not installed, tell the user what it is needed for. Do
not guess credentials, call the HTTP API directly, or attempt other workarounds.
This skill references operations in HTTP-shorthand form (e.g., GET /, GET /_cat/indices, GET /{index}/_mapping,
GET /{index}/_settings/index.mode, POST /_query). The [Operations](#operations) table at the end of this document
maps each shorthand to the equivalent elastic CLI command — always use the CLI rather than calling the HTTP API
directly.
<!-- end-partial: preamble -->
> Prerequisite: ML anomaly detection requires a Platinum-equivalent license on self-managed clusters. Serverless
> projects include ML. The caller needs monitor_ml to read job config and anomaly results.
>
> Serverless note: The _ml/.../results/* REST endpoints return HTTP 410 in Elastic Serverless. Always use
> POST /.ml-anomalies-*/_search for result queries instead — fully supported everywhere this skill runs.
Process
- Decide whether to fetch data or interpret what the user supplied. If the user embeds an anomaly record (or job
config) in the prompt, interpret it directly using the domain knowledge below — do not call APIs to re-fetch fields
already present. If the job ID, time range, or record is missing, retrieve it from the cluster.
The decision: proceed with judgment-only explanation when the record contains record_score, initial_record_score,
actual, typical, and function; otherwise fetch the missing pieces before explaining.
- Verify connectivity when calling the cluster. Call
GET /. If the call fails, stop and surface the connection
error — do not guess endpoints or credentials.
- Resolve the job ID and load config. When the job ID is unknown, call
GET /_ml/anomaly_detectorsto list
candidates. Call GET /_ml/anomaly_detectors/{job_id} for full analysis_config (bucket_span, detectors,
custom_rules, use_null, model_plot_config) and GET /_ml/anomaly_detectors/{job_id}/_stats for state,
model_size_stats.memory_status, and data counts.
The decision: confirm detector function and direction match the user's question before interpreting scores. A
low_count job legitimately fires on drops; a high_count job does not.
- Retrieve anomaly records for the time range. Call
POST /.ml-anomalies-*/_searchwithresult_type: record, the
job ID, a timestamp range, and optional record_score filter. Read initial_record_score, record_score, actual,
typical, function, multi_bucket_impact, and anomaly_score_explanation.
Always show both initial_record_score and record_score. The gap is the renormalization story.
- Classify the score pattern before speculating on causes.
initial_record_score>>record_score— Renormalization. A later, more extreme anomaly rescale this
record downward. This is expected, healthy model behavior — not a broken model or reason to distrust the detection.
Use initial_record_score for alerting severity; show both scores and explain the gap explicitly.
initial_record_score==record_score— No renormalization has occurred since detection.actual<<typicalwithlow_count,count, orlow_mean— Absence / drop anomaly. A high score is
legitimate — the job detected an outage, pipeline stall, or service failure. This is not a false positive.
Recommend incident investigation, not score tuning.
actual>>typicalwithhigh_countorhigh_mean— Spike anomaly; confirm withsingle_bucket_impact.
Only cite anomaly_score_explanation factors present in the record. If high_variance_penalty is false, do
not blame variance. If a factor is absent, note that it was not returned — do not invent it.
- Quantify renormalization across the job (optional). Re-query
POST /.ml-anomalies-*/_searchfor records in the
time range sorted by timestamp ascending. Compute score_drift = initial_record_score − record_score per record
and filter to |score_drift| ≥ 20. Large negative drift (initial >> record) confirms renormalization after a more
extreme anomaly appeared later.
- Add context when the user asks "what caused this?" or "why so low/high?"
- Model bounds — If
model_plot_config.enabledis true, callPOST /.ml-anomalies-*/_searchwith
result_type: model_plot for the same job and time range. Compare actual to model_lower / model_upper.
- Influencers — Call
POST /.ml-anomalies-*/_searchwithresult_type: influencerfor the bucket time range;
sort by influencer_score descending.
- Categorization jobs — Call
POST /.ml-anomalies-*/_searchwithresult_type: category_definitionto list
learned log patterns (terms, regex, examples per category_id).
For aggregations, cross-job queries, bucket-level results, or custom filters beyond score and time, see
[references/explainer-reference.md](references/explainer-reference.md).
Common multi-step workflows
| Task | Steps (in order) |
| ------------------------------- | ---------------------------------------------------------------------------------------------------- |
| Explain a specific anomaly | job config → records (job + exact time) → show initial_record_score vs record_score + score factors. |
| Why is my score low? | job config → records → renormalization check → model plot (if enabled) → explain score factors. |
| Why is my score high? | job config → records → check function direction, insufficient history, use_null, cardinality. |
| Renormalization drift | records (timestamp sort) → compute score_drift → list records where initial >> record. |
| Which entities contributed? | influencers (job + time range) → sort by influencer_score. |
| Visualize model bounds | model plot (job + time range) → compare model_lower/model_upper vs actual. |
| Categorization job patterns | category_definition (job_id) → terms, regex, examples per category. |
Critical principles
- Retrieve the record first (or use the one the user supplied). Never explain scores without
initial_record_score,
record_score, actual, typical, and function.
- Renormalization is healthy. When
initial_record_score >> record_score, a more extreme anomaly appeared later and
lowered this score — expected behavior, not a model failure.
- Direction matters.
low_countfires when values drop;high_countfires on spikes. A high score on a traffic
stop with low_count is correct detection, not a false positive.
- Explain factors before speculating. Read
anomaly_score_explanationfrom the record. Only address factors that
are present and relevant.
- Job config is essential.
bucket_span, detector function,custom_rules,use_null, and memory status all
affect scores. Inspect job config when a score is surprising.
- Model plot is the most visual explanation. When enabled, show model bounds to illustrate where the actual value
falls relative to the expected range.
- For job health ("missing documents", "memory limit", "datafeed not running") use the
elasticsearch-anomaly-detection
skill.
Domain knowledge
Score types
| Term | Meaning |
| ------------------------ | ---------------------------------------------------------------------------------------- |
| record_score | Normalized 0–100 for a single anomaly record; updated by renormalization. >75 critical. |
| initial_record_score | Score assigned at detection time, before renormalization. Use for alerting. |
| anomaly_score | Bucket-level severity aggregated across all detectors in a job. |
| influencer_score | How unusual a specific entity (host, user, service) is in a bucket; high = likely cause. |
| multi_bucket_impact | 0–5; how much sustained, multi-bucket behavior raised the score. ≥3 = behavioral shift. |
anomaly_score_explanation factors
The anomaly_score_explanation field on each record breaks the score into components:
| Factor | Direction | Meaning |
| ---------------------------------- | --------- | ----------------------------------------------------------------------- |
| anomaly_length | Raises | Number of consecutive buckets the anomaly spans. Longer → higher score. |
| single_bucket_impact | Raises | Extremity of this single bucket. Lower probability → higher impact. |
| multi_bucket_impact | Raises | Contribution of sustained multi-bucket pattern. |
| anomaly_characteristics_impact | Raises | Whether the anomaly is a mean shift vs. variance change. |
| high_variance_penalty | Lowers | Noisy data or early training → wide confidence bounds → score reduced. |
| incomplete_bucket_penalty | Lowers | Bucket had less data than expected (delayed data, sparse events). |
Why a score might be unexpectedly low
- high_variance_penalty: The metric is historically noisy — wide confidence bounds absorb the spike.
- Renormalization: A more extreme anomaly appeared later and pushed this score down (
initial_record_score>>
record_score).
- Insufficient training history: Need ≥3 weeks for weekly seasonality, ≥2 full cycles for any detected period.
- bucket_span too large: Short-duration spikes get smoothed. Use a smaller
bucket_spanfor high-frequency events. - Detector function mismatch:
meanvshigh_mean,countvshigh_count— only one direction fires. - incomplete_bucket_penalty: Bucket received less data than expected (ingest latency or gaps).
- custom_rules: A detector filter may be suppressing the anomaly.
Why a score might be unexpectedly high
- Insufficient history: Model hasn't learned the normal pattern yet — early anomalies are unreliable.
- Model split thin: High-cardinality
partition_fieldorby_field→ very few points per entity → unreliable
probabilities.
- use_null: If
use_null: true, missing entities produce "null" anomalies that may not be meaningful. - Absence / drop detection: With
low_countorlow_mean,actual << typicalproduces a legitimately high score —
treat as a real incident, not a false positive.
Model behavior concepts
| Concept | Meaning |
| ------------------- | ------------------------------------------------------------------------------------------------------ |
| actual | Observed value. typical is what the model expected. The direction matters. |
| Absence anomaly | actual << typical with count, low_count, or low_mean → outage, pipeline stop, service failure. |
| by_field | Independent baseline per entity (e.g., per host). Each entity compared to its own history. |
| over_field | Population analysis — entity compared to its peer group in the same bucket, not its own history. |
| partition_field | Fully independent sub-models with separate score normalization per partition. |
Model plot and categories
- Model plot: Shows the model's learned upper and lower bounds at each time point. If
actualis within bounds, no
anomaly; if outside, the score depends on the distance from bounds. Only available when model_plot_config is enabled
on the job. Query via POST /.ml-anomalies-*/_search with result_type: model_plot.
- Categories: For jobs with a
categorization_field_name, queryresult_type: category_definitionto show log
message patterns (terms, regex, examples per category_id). Anomaly records use by_field_value = <category_id>.
Score troubleshooting protocol
- List jobs — Call
GET /_ml/anomaly_detectorswhen the job ID is unknown. - Get job config and stats — Call
GET /_ml/anomaly_detectors/{job_id}and
GET /_ml/anomaly_detectors/{job_id}/_stats. Verify bucket_span, detector function, custom_rules, use_null,
job state (opened/closed/failed), and model_size_stats.memory_status.
- Retrieve the record — Call
POST /.ml-anomalies-*/_searchwithresult_type: record, the job ID, time range,
and optional minimum record_score. Inspect initial_record_score, record_score, actual, typical, function,
multi_bucket_impact, and anomaly_score_explanation.
- Check renormalization — Compare
initial_record_scorevsrecord_score. If initial >> record, re-query records
sorted by timestamp and compute score_drift to quantify renormalization across the job.
- Visualize model bounds — If
model_plot_configis enabled, queryresult_type: model_plotand show where the
actual value fell relative to model_lower and model_upper.
- Influencers — Query
result_type: influencerfor the anomaly bucket time range; sort byinfluencer_score. - Explain factors — From the record's
anomaly_score_explanation, address each present relevant factor:
high_variance_penalty, incomplete_bucket_penalty, anomaly_length, single_bucket_impact,
multi_bucket_impact. Do not cite factors absent from the record.
Examples
- "Why is my anomaly score only 15 when the spike looks huge?" → Check renormalization:
initial_record_score(~92) >>
record_score (~15). The spike was real; the current score was rescaled down. Use the initial score for alerting.
- "Traffic stopped and I got a HIGH score — false positive?" → No.
low_countwithactualfar belowtypicalis
legitimate absence detection. Investigate the outage.
- "Which entities contributed most to the anomalies in job X last night?" → Query influencers for the time range.
- "Show me the model bounds for this job." → Query model plot when
model_plot_configis enabled. - "List records where the score was renormalized down a lot." → Records sorted by timestamp; filter large
initial_record_score − record_score.
Guidelines
- Report only what the API or the user-supplied record contains; do not invent scores, timestamps, entity values, or
explanation factors.
- Always show both
initial_record_scoreandrecord_scorewhen explaining a record; state explicitly whether
renormalization occurred.
- When a score factor is missing from the record, do not assert it; note that the field was not returned.
- Do not attribute low scores to
high_variance_penaltyorincomplete_bucket_penaltywhen those flags arefalseor
absent in the record.
- For investigation ("what caused this?", "which service is responsible?") query influencers or construct cross-job
searches via [references/explainer-reference.md](references/explainer-reference.md).
- For job health use the
elasticsearch-anomaly-detectionskill.
Operations
| HTTP API (shorthand) | elastic CLI command |
| -------------------------------------------- | ------------------------------------------------------------------------------- |
| GET / | elastic es info |
| GET /_ml/anomaly_detectors | elastic es ml get-jobs |
| GET /_ml/anomaly_detectors/{job_id} | elastic es ml get-jobs --job-id '<job_id>' |
| GET /_ml/anomaly_detectors/{job_id}/_stats | elastic es ml get-job-stats --job-id '<job_id>' |
| POST /.ml-anomalies-/_search | elastic es search --index '.ml-anomalies-' --input-file '<search-body.json>' |
Query body shapes for each result_type (record, influencer, model_plot, category_definition) are documented in
[references/explainer-reference.md](references/explainer-reference.md).
想直接用这个技能?
本站把开放许可(MIT / Apache 等)的技能按仓库打包整理到网盘,点一下转存到你自己的网盘,不用一个个从 GitHub 拉。许可未声明的技能只给原始仓库链接,不打包。
它属于哪个仓库
skills/elasticsearch/elasticsearch-anomaly-detection-explainer/SKILL.md同一个仓库里的其他技能
- cloud-onboarding
- cloud-provisioning
- elasticsearch-anomaly-detection
- elasticsearch-anomaly-detection-explainer
- elasticsearch-cluster-health
- elasticsearch-esql
- elasticsearch-index-design
- elasticsearch-ingest
- elasticsearch-onboarding
- elasticsearch-query-optimization
- elasticsearch-reindex
- elasticsearch-search-relevance
同名技能的其他版本
有 2 个不同仓库或目录里都有叫 elasticsearch-anomaly-detection-explainer 的技能。它们内容并不相同,别混用: