AI-powered Spark job analyzer - NATS worker service
Project description
spark-advisor-analyzer
AI-powered Spark job analyzer — NATS worker service. Part of the spark-advisor ecosystem.
Install
pip install spark-advisor-analyzer
What it does
Combines deterministic rules engine with optional Claude AI analysis to provide actionable Spark configuration recommendations.
- Rules engine — 11 expert rules detecting data skew, GC pressure, disk spill, and more
- AI analysis — Claude API integration for prioritized recommendations with causal chains
- Agent mode — multi-turn Claude tool_use loop for autonomous job exploration
- NATS worker — FastStream subscriber for
analysis.runandanalysis.run.agent
Deployment
As a standalone NATS worker:
export SA_ANALYZER_NATS__URL=nats://localhost:4222
export ANTHROPIC_API_KEY=sk-ant-...
spark-advisor-analyzer
Or use via spark-advisor CLI or spark-advisor-mcp server.
Configuration
| Variable | Default | Description |
|---|---|---|
SA_ANALYZER_NATS__URL |
nats://localhost:4222 |
NATS broker URL |
SA_ANALYZER_AI__ENABLED |
true |
Enable AI analysis |
ANTHROPIC_API_KEY |
— | Claude API key (required if AI enabled) |
SA_ANALYZER_OTEL__ENABLED |
false |
Enable OpenTelemetry distributed tracing |
Links
License
Apache 2.0
Release history Release notifications | RSS feed
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
Built Distribution
Filter files by name, interpreter, ABI, and platform.
If you're not sure about the file name format, learn more about wheel file names.
Copy a direct link to the current filters
File details
Details for the file spark_advisor_analyzer-0.1.11.tar.gz.
File metadata
- Download URL: spark_advisor_analyzer-0.1.11.tar.gz
- Upload date:
- Size: 22.1 kB
- Tags: Source
- Uploaded using Trusted Publishing? No
- Uploaded via: uv/0.10.11 {"installer":{"name":"uv","version":"0.10.11","subcommand":["publish"]},"python":null,"implementation":{"name":null,"version":null},"distro":{"name":"Ubuntu","version":"24.04","id":"noble","libc":null},"system":{"name":null,"release":null},"cpu":null,"openssl_version":null,"setuptools_version":null,"rustc_version":null,"ci":true}
File hashes
| Algorithm | Hash digest | |
|---|---|---|
| SHA256 |
46434289340818c4b15e664c571b626981c198f4ccdf5cae2a69241fcc3fcbfb
|
|
| MD5 |
b6f71c8f35ade050392764a35badfbc0
|
|
| BLAKE2b-256 |
c52ebbb8eb6c880d723a581ad09d473e80ccb21ff119e967847353dec521f7e0
|
File details
Details for the file spark_advisor_analyzer-0.1.11-py3-none-any.whl.
File metadata
- Download URL: spark_advisor_analyzer-0.1.11-py3-none-any.whl
- Upload date:
- Size: 23.3 kB
- Tags: Python 3
- Uploaded using Trusted Publishing? No
- Uploaded via: uv/0.10.11 {"installer":{"name":"uv","version":"0.10.11","subcommand":["publish"]},"python":null,"implementation":{"name":null,"version":null},"distro":{"name":"Ubuntu","version":"24.04","id":"noble","libc":null},"system":{"name":null,"release":null},"cpu":null,"openssl_version":null,"setuptools_version":null,"rustc_version":null,"ci":true}
File hashes
| Algorithm | Hash digest | |
|---|---|---|
| SHA256 |
7f27b910d3b639f0150c737431f084c97b7d2003431bdf2db57061d291a2a010
|
|
| MD5 |
b77d83d5e0c798ca5e3784db96599114
|
|
| BLAKE2b-256 |
ce21a26470caa1ddaf6e66476933666bf04a31e3507f12d3202c9ee77b66f65c
|
