Build a Sparkplug B Dual-Gateway Telemetry Failover Router

Simulate primary gateway link drops using Sparkplug B edge telemetry. Synthesize backup path failover routing rules, redundant node reconnection sequences, and telemetry consistency audit reports for industrial network admins.

Industrial Automation Network Admin

Monitor simulated Sparkplug B edge node heartbeat flags and broker connectivity payload logs.

Simulate primary gateway connection timeouts and isolate unacknowledged telemetry batches using sequence numbers.

Construct redundant gateway routing rules and generate sequential fallback connection procedures for edge devices.

Compile a simulated dual-gateway readiness dossier, summarizing metric continuity risks and secondary bandwidth constraints.

Dual-gateway state visualizer with packet transmission timelines, unacknowledged message queues, and simulated failover path configuration.

Generate synthetic broker logs with Sparkplug B edge node birth, death, and data message traces. Store in a local SQLite file. Log entries should be treated as simplified synthetic app records, not complete official schema files. Starter examples below are synthetic. They are not downloaded records.

Eclipse Sparkplug Sparkplug B stateful MQTT message exchange and edge node sequence numbering (bdSeq) detailed in Source 2.

dspy, pydantic, sqlite3. DSPy compiles robust prompt pipelines to extract outage patterns from dense network log streams. Fast instruction model capable of log pattern classification and chronological ordering of mock network events.

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.

Detects exact sequence number gaps representing isolated batches during simulated gateway transition events.

Synthesizes chronological failover steps mapping offline nodes to the standby gateway.

Emits explicit bandwidth limitation warnings when secondary gateway utilization exceeds 85% capacity.

```json [ { "input": { "primary_gateway": { "id": "GW_01", "status": "OFFLINE", "last_seq": 105 }, "secondary_gateway": { "id": "GW_02", "status": "STANDBY", "bandwidth_util_pct": 35 }, "edge_nodes": [ { "node_id": "NODE_PACK_A", "unacked_packets": 12, "last_seq_sent": 117 } ] }, "expected_output": { "failover_feasibility": "FEASIBLE", "calculated_data_gap_packets": 12, "routing_sequence": [ "Promote GW_02 from STANDBY to ACTIVE", "Route NODE_PACK_A to GW_02", "Request replay for seq 106 to 117" ], "risk_flag": "LOW" } }, { "input": { "primary_gateway": { "id": "GW_01", "status": "OFFLINE", "last_seq": 500 }, "secondary_gateway": { "id": "GW_02", "status": "DEGRADED", "bandwidth_util_pct": 94 }, "edge_nodes": [ { "node_id": "NODE_LINE_B", "unacked_packets": 140, "last_seq_sent": 640 } ] }, "expected_output": { "failover_feasibility": "CONSTRAINED", "calculated_data_gap_packets": 140, "routing_sequence": [ "Throttle non-essential telemetry on NODE_LINE_B", "Route NODE_LINE_B to GW_02 at reduced frequency" ], "risk_flag": "HIGH" } } ] ```

Software rehearsal environment only. All network traffic and broker failover actions are mock-simulated. Use mock external writes. Require human review before any real deployment.