Jobsite Environmental Sensor Ingestion Script

Role: Lead Site Telemetry & Embedded Systems Engineer specializing in commercial real estate IoT networks.

Context

• Telemetry Transport Protocol: {{telemetry_source_protocol}}
• Sensor Poll Interval: {{sampling_interval_seconds}}
• Structural Vibration Ceiling: {{vibration_limit_g}}
• Permissible Decibel Ceiling: {{noise_threshold_db}}
• Compliance Webhook URL: {{alert_webhook_url}}
• Local Edge Buffer Path: {{local_cache_path}}

Task

Create a resilient edge Python monitoring script that ingests environmental telemetry across jobsite hardware nodes, computes moving window averages for noise and vibration, persists buffers locally during network outages, and dispatches immediate breach alerts.

Method

1. Establish connection to the jobsite telemetry stream using {{telemetry_source_protocol}} with automatic retry logic.
2. Configure periodic sampling loops governed strictly by {{sampling_interval_seconds}}.
3. Validate incoming sensor payload schemas for dust, temperature, sound, and tri-axial acceleration.
4. Maintain a 60-second sliding window buffer to compute rolling averages for environmental readings.
5. Compare rolling vibration metrics against {{vibration_limit_g}} and acoustic levels against {{noise_threshold_db}}.
6. Assemble an incident JSON payload upon limit violation and dispatch an HTTP POST to {{alert_webhook_url}}.
7. Intercept network failure exceptions, writing telemetry packages into {{local_cache_path}} for subsequent replay.
8. Implement a graceful SIGINT/SIGTERM shutdown hook to flush remaining buffers to persistent storage.

Constraints

• Memory footprint MUST NOT exceed 128MB to ensure execution on resource-constrained edge gateways.
• The script MUST continue logging to {{local_cache_path}} without crashing if the upstream network disconnects.
• Third-party dependencies MUST be limited to standard networking and parsing modules (e.g., requests, paho-mqtt).
• Plaintext API tokens or sensitive site credentials MUST NOT be hardcoded in the script body.

Output format

Format the response with the following clearly labeled sections:

1. Runtime Architecture (brief overview of thread handling and queue mechanism).
2. Complete Edge Python Script (fully runnable script with inline error handling).
3. Daemon Service Configuration (systemd service unit file definition for automatic restart).

Self-review

• Check that moving window calculations handle zero-division and empty arrays cleanly.
• Verify all 6 context variables ({{telemetry_source_protocol}}, {{sampling_interval_seconds}}, {{vibration_limit_g}}, {{noise_threshold_db}}, {{alert_webhook_url}}, {{local_cache_path}}) are explicitly parameterized.
• Ensure the edge buffer replay mechanism flushes stored records once network connectivity is restored.