Come generare codice per l'aggiornamento del gemello digitale

**Contesto e ruolo dell'AI** Sei un ingegnere di automazione esperto che deve creare un servizio leggero e autonomo per sincronizzare i dati dei sensori fisici con un gemello digitale in tempo reale. Il codice generato dovrà gestire la ricezione dei dati dai sensori IoT, elaborarli con latenza minima, convalidarli e scrivere gli aggiornamenti nel modello del gemello digitale. **Obiettivi** - Produrre una funzione riutilizzabile che si connetta a un broker di sensori, legga i dati da un sensore specifico e li invii a un servizio di aggiornamento del gemello digitale. - Garantire che il ciclo di lettura e aggiornamento completi entro l'intervallo di polling desiderato, minimizzando la latenza di rete. - Includere controlli di integrità dei dati (range validi, rilevamento dei valori mancanti) prima di applicare le modifiche al gemello. - Fornire un'implementazione eseguibile in modo immediato, con commenti esplicativi e una configurazione minima (es. stringhe di connessione, mappatura dei nomi dei sensori). **Input richiesti** - `[nome_sensore]`: Nome o ID del sensore IoT da monitorare (es. "temperatura_stanza1"). - `[intervallo_poll]`: Intervallo di polling in millisecondi (es. 500). - `conn_string`: Stringa di connessione per il broker di sensori (es. MQTT, HTTP). - `twin_endpoint`: URL o nome del servizio per l'aggiornamento del gemello digitale. - `auth_token`: Token di autenticazione per il servizio del gemello (opzionale, può essere gestito tramite l'ambiente). **Processo step-by-step** 1. **Inizializza il client di connessione** utilizzando la stringa di connessione fornita. Scegli il protocollo appropriato (MQTT, CoAP, HTTP) in base al broker del sensore. 2. **Crea un abbonamento** al topic o all'endpoint del sensore identificato da `[nome_sensore]`. Configura un timeout di keep'alive pari a `[intervallo_poll]` per mantenere il canale attivo. 3. **Avvia un loop di polling** (o ascolta i messaggi in entrata, se supportato). A ogni iterazione: a. Recupera l'ultimo payload dal sensore. b. Esegui la **validazione dei dati** " verifica che i valori numerici siano all'interno di un intervallo predefinito e che non ci siano valori mancanti o NaN. c. Se la validazione ha successo, formatta i dati nel modello JSON atteso dal gemello (es. `{"timestamp":..., "valore":...}`). d. Effettua una **richiesta HTTP POST** (o un'altra operazione appropriata) all'`twin_endpoint` con i dati convalidati e l'`auth_token`. e. Registra lo stato di successo o errore per il monitoraggio. 4. **Gestisci la latenza** " misura il tempo trascorso tra il recupero del sensore e il completamento dell'aggiornamento del gemello. Se il tempo di elaborazione supera l'`[intervallo_poll]` configurato, registra un avviso. 5. **Interrompi in modo pulito** il ciclo in caso di interruzione di rete o di errore di autenticazione, riproponendo la connessione automaticamente. 6. **Genera documentazione** " produci un breve README con i passaggi di installazione, le variabili di ambiente richieste e i comandi di test di base. **Formato output desiderato** - **File principale**: `digital_twin_updater.py` " una singola funzione `async def update_twin(sensor_name, poll_interval_ms, conn_string, twin_endpoint, auth_token)` che implementa i passaggi sopra descritti. - **File di configurazione**: `config.yaml` " contiene intervalli di validazione predefiniti per ogni `[nome_sensore]` (min/max) e l'endpoint del gemello. - **Script di avvio**: `run_twin_updater.sh` " avvia lo script Python con le variabili d'ambiente appropriate. - **Log**: I log di stato vengono scritti in `updater.log` (formato JSON per l'analisi). **Esempio di utilizzo** ```bash export SENSOR_NAME="[nome_sensore]" export POLL_INTERVAL=500 export CONN_STRING="mqtt://broker.example.com:1883" export TWIN_ENDPOINT="https://twin.example.com/api/update" export AUTH_TOKEN="segreto" ./run_twin_updater.sh ``` **Angolo utile per la ricerca** Quando si cerca "come generare codice per l'aggiornamento del gemello digitale" su Google, gli sviluppatori spesso hanno bisogno di un esempio pronto all'uso che gestisca la latenza, la convalida dei dati e il riavvio automatico. Questo prompt fornisce esattamente quello: una soluzione concreta, passo-passo, con tutti i componenti necessari per scrivere, eseguire e testare un servizio di aggiornamento in tempo reale e a bassa latenza per un gemello digitale, utilizzando i dati dei sensori IoT. **Note aggiuntive** - Utilizza librerie asincrone (es. `asyncio`, `aiohttp`) per massimizzare l'efficienza. - Aggiungi un controllo di salute di base (`/health`) che restituisce lo stato del servizio e la latenza media. - Considera l'aggiunta di un meccanismo di ricompattamento del modello del gemello opzionale per applicazioni ad alta frequenza. Questo prompt è progettato per essere copiato direttamente in un editor di codice, modificato con i parametri specifici del progetto e reso operativo in pochi minuti.