Rielaborazione dei messaggi del canale - AWS IoT Analytics
ParametriRielaborazione dei messaggi dei canali (console)Rielaborazione dei messaggi di canale (API)Annullamento delle attività di rielaborazione del canale

AWS IoT Analytics non è più disponibile per i nuovi clienti. I clienti esistenti di AWS IoT Analytics possono continuare a utilizzare il servizio normalmente. Ulteriori informazioni

Le traduzioni sono generate tramite traduzione automatica. In caso di conflitto tra il contenuto di una traduzione e la versione originale in Inglese, quest'ultima prevarrà.

Rielaborazione dei messaggi del canale

AWS IoT Analyticsconsente di rielaborare i dati del canale. Ciò può essere utile nei seguenti casi:

  • Vuoi riprodurre dati esistenti inseriti anziché ricominciare da zero.

  • Stai effettuando un aggiornamento a una pipeline e desideri portare i dati esistenti up-to-date con le modifiche.

  • Si desidera includere i dati che sono stati acquisiti prima di apportare modifiche alle opzioni di storage gestite dal cliente, le autorizzazioni per i canali o il data store.

Parametri

Quando si rielaborano i messaggi di canale attraverso la pipeline conAWS IoT Analytics, devi specificare le informazioni seguenti:

StartPipelineReprocessing

Avvia la rielaborazione dei messaggi dei canali tramite la pipeline.

ChannelMessages

Specifica uno o più set di messaggi di canale che si desidera rielaborare.

Se utilizzi il pluginchannelMessagesoggetto, non devi specificare un valore perstartTimeeendTime.

s3Paths

Specifica una o più chiavi che identificano gli oggetti Amazon Simple Storage Service (Amazon S3) che salvano i messaggi del canale. È necessario utilizzare il percorso completo per la chiave.

Esempio di percorso:00:00:00/1582940490000_1582940520000_123456789012_mychannel_0_2118.0.json.gz

Type: Gamma di stringhe

Vincoli dei membri dell'array: 1-100 elementi.

Vincoli di lunghezza: 1-1024 caratteri.

endTime

L'ora di fine (esclusa) della rielaborazione dei dati del canale che vengono rielaborati.

Se specifichi un valore per laendTimeparametro, non è necessario utilizzare ilchannelMessagesoggetto.

Type: Time stamp

startTime

L'ora di inizio (inclusa) della rielaborazione dei dati dei messaggi non elaborati.

Se specifichi un valore per lastartTimeparametro, non è necessario utilizzare ilchannelMessagesoggetto.

Type: Time stamp

pipelineName

Il nome della pipeline su cui avviare la rielaborazione.

Type: Stringa

Vincoli di lunghezza: 1-128 caratteri.

Rielaborazione dei messaggi dei canali (console)

Questo tutorial mostra come rielaborare i dati del canale memorizzati nell'oggetto Amazon S3 specificato nelAWS IoT Analyticsconsole.

Prima di iniziare, assicurati che i messaggi del canale da rielaborare siano salvati in un bucket Amazon S3 gestito dal cliente.

  1. Accedere alla console AWS IoT Analytics.

  2. Nel riquadro di navigazione, sceglierePipeline.

  3. Seleziona la pipeline di destinazione.

  4. ScegliereRielabora i messaggidaOperazioni.

  5. SulRitrattamento della pipeline(Applicare), scegliereS3 objects (Oggetti S3)perRielabora i messaggi.

    LaAWS IoT Analyticsla console fornisce le seguenti opzioni:

    • Tutta la gamma disponibile- Rielabora tutti i dati validi nel canale.

    • Ultimi 120 giorni- Rielabora i dati arrivati negli ultimi 120 giorni.

    • Ultimi 90 giorni- Rielabora i dati arrivati negli ultimi 90 giorni.

    • Ultimi 30 giorni- Rielabora i dati arrivati negli ultimi 30 giorni.

    • Intervallo personalizzato- Rielabora i dati arrivati nell'intervallo di tempo specificato. È possibile scegliere qualsiasi intervallo di tempo.

  6. Inserisci la chiave dell'oggetto Amazon S3 che memorizza i messaggi del tuo canale.

    Per trovare la chiave, esegui queste operazioni:

    1. Accedi aConsole Amazon S3.

    2. Seleziona l'oggetto Amazon S3 di destinazione.

    3. UnderProprietà, nelPanoramica dell'oggettosezione, copia la chiave.

  7. ScegliereInizia a rielaborare.

Rielaborazione dei messaggi di canale (API)

Quando utilizzi il fileStartPipelineReprocessingAPI, tenere presente quanto segue:

  • LastartTimeeendTimei parametri specificano quando sono stati inseriti i dati non elaborati, ma si tratta di stime approssimative. Puoi arrotondare all'ora più vicina. LastartTimeè inclusivo, ma ilendTimeè esclusa.

  • Il comando avvia la rielaborazione in modo asincrono e restituisce immediatamente i risultati.

  • Non vi è alcuna garanzia che i messaggi rielaborati vengano elaborati nell'ordine in cui sono stati ricevuti inizialmente: orientativamente è lo stesso ordine, ma non in modo preciso.

  • Puoi creare fino a 1000StartPipelineReprocessingLe API richiedono ogni 24 ore di rielaborare gli stessi messaggi di canale attraverso una pipeline.

  • La rielaborazione dei dati non elaborati comporta costi supplementari.

Per ulteriori informazioni, consulta la .StartPipelineReprocessingAPI, inAWS IoT AnalyticsDocumentazione di riferimento API.

Annullamento delle attività di rielaborazione del canale

Per annullare un'attività di ritrattamento della pipeline, utilizzare ilCancelPipelineReprocessingAPI o scegliAnnullamento della rielaborazionesulAttivitànellaAWS IoT Analyticsconsole. Se si annulla il ritrattamento, i dati rimanenti non verranno rielaborati. È necessario avviare un'altra richiesta di ritrattamento.

Utilizzo dell'DescribePipelineAPI per controllare lo stato della rielaborazione. Consulta lareprocessingSummariesnella risposta.