Build a Sparkplug B Industrial Energy Demand Shifting Planner
Parse electrical telemetry and plant operational state messages encoded in Sparkplug B payloads. Synthesize off-peak batch rescheduling proposals to avoid peak tariff surcharges.
What you are building
Parse electrical telemetry and plant operational state messages encoded in Sparkplug B payloads. Synthesize off-peak batch rescheduling proposals to avoid peak tariff surcharges.
Plant Energy and Utilities Manager
Collect power consumption metrics and operational states published across Sparkplug B topic trees.
Cross-reference real-time aggregate power draw against utility peak tariff schedule windows.
Identify flexible batch process units such as wash tanks and heat treat ovens currently active in peak hours.
Formulate non-binding schedule shift recommendations to move energy-intensive steps to off-peak periods.
Terminal and web interface presenting load demand curves, tariff brackets, and shift proposals.
Create synthetic MQTT Sparkplug B payloads containing kilowatt demand metrics and batch unit state updates. Starter examples below are synthetic. They are not downloaded records.
Eclipse Sparkplug Extracts Sparkplug B metric datasets and time-series telemetry properties according to Eclipse Tahu standards.
agno, pydantic, pytest. Agno provides lightweight structured agent flows for energy data processing and advisory schedule drafting. Requires standard text reasoning LLM via hosted API or local inference server.
Submit runnable source, pinned dependencies, setup commands, a working interface, example outputs, and a recorded end-to-end demo. Include tests and an action log.
Parses Sparkplug B power metric payloads and computes aggregate line consumption.
Identifies process units operating during defined high-tariff windows.
Generates rescheduling proposals that maintain daily throughput targets.
Flags incomplete telemetry feeds when power readings fail to report.
```json [ { "input": { "current_time": "2025-05-15T14:15:00Z", "peak_window": { "start": "14:00:00Z", "end": "18:00:00Z" }, "devices": [ { "device_id": "Oven_HT01", "kw_draw": 145, "batch_id": "B-912", "can_pause": true }, { "device_id": "Conveyor_CV01", "kw_draw": 12, "batch_id": "B-912", "can_pause": false } ], "max_allowed_peak_kw": 120 }, "expected_output": { "alert": "PEAK_DEMAND_EXCEEDED", "total_kw": 157, "recommended_shifts": [ { "device_id": "Oven_HT01", "batch_id": "B-912", "suggested_start": "2025-05-15T18:05:00Z", "estimated_kw_reduction": 145 } ], "projected_kw_after_shift": 12 } }, { "input": { "current_time": "2025-05-15T10:00:00Z", "peak_window": { "start": "14:00:00Z", "end": "18:00:00Z" }, "devices": [ { "device_id": "Oven_HT01", "kw_draw": 145, "batch_id": "B-910", "can_pause": true } ], "max_allowed_peak_kw": 120 }, "expected_output": { "alert": "NORMAL_OPERATION", "total_kw": 145, "recommended_shifts": [], "projected_kw_after_shift": 145 } } ] ```
Strictly advisory schedule recommendations; does not alter PLC registers, breakers, or batch timers. Use mock external writes. Require human review before any real deployment.
Rules
Strictly advisory schedule recommendations; does not alter PLC registers, breakers, or batch timers. Use mock external writes and human review.
How work is evaluated
Parses Sparkplug B power metric payloads and computes aggregate line consumption. Identifies process units operating during defined high-tariff windows. Generates rescheduling proposals that maintain daily throughput targets. Flags incomplete telemetry feeds when power readings fail to report.
Runnable source, pinned dependencies, setup commands, working interface, example outputs, recorded demo, tests, and action logs.
Datasets
Public datasets, plus the private datasets you have access to.
How submissions are scored
Complete workflow
Collect power consumption metrics and operational states published across Sparkplug B topic trees. Cross-reference real-time aggregate power draw against utility peak tariff schedule windows. Identify flexible batch process units such as wash tanks and heat treat ovens currently active in peak hours. Formulate non-binding schedule shift recommendations to move energy-intensive steps to off-peak periods.
Missing or incorrect.
Partly complete, with documented gaps.
Complete, with reproducible evidence.
Correctness and evidence
Parses Sparkplug B power metric payloads and computes aggregate line consumption. Identifies process units operating during defined high-tariff windows. Generates rescheduling proposals that maintain daily throughput targets. Flags incomplete telemetry feeds when power readings fail to report.
Missing or incorrect.
Partly complete, with documented gaps.
Complete, with reproducible evidence.
Review interface
Terminal and web interface presenting load demand curves, tariff brackets, and shift proposals.
Missing or incorrect.
Partly complete, with documented gaps.
Complete, with reproducible evidence.
Safe execution
Strictly advisory schedule recommendations; does not alter PLC registers, breakers, or batch timers.
This dimension contributes its full weight only when the submission satisfies the requirement. Partial credit is not awarded.
Learning goals
Collect power consumption metrics and operational states published across Sparkplug B topic trees.
Cross-reference real-time aggregate power draw against utility peak tariff schedule windows.
Identify flexible batch process units such as wash tanks and heat treat ovens currently active in peak hours.
Formulate non-binding schedule shift recommendations to move energy-intensive steps to off-peak periods.
Resources
Create synthetic MQTT Sparkplug B payloads containing kilowatt demand metrics and batch unit state updates. Supplied starter examples are synthetic, not source extracts.
Challenge setup
Challenge input
Input details are not configured.
Agno
Framework for multimodal agents.
Evaluated output
No output checks are configured.
- Collect power consumption metrics and operational states published across Sparkplug B topic trees. Cross-re...
- Parses Sparkplug B power metric payloads and computes aggregate line consumption. Identifies process units...
- Terminal and web interface presenting load demand curves, tariff brackets, and shift proposals.
- 2 public reference cases
- 2 configured tools
Shows the first task, up to three tools, and up to three evidence items.
View technical recipe
Configured tools
- Agno · Optional
- Agno · Optional
Evaluation contract
- Complete workflow · Weight 40
- Correctness and evidence · Weight 30
- Review interface · Weight 20
- Safe execution · Weight 10
Reference cases
- 2 public reference cases
Workflow tasks
No workflow tasks are configured.
Recipe freeze marker
No recipe freeze time is recorded.