Torna alla versione precedente KCL - Flusso di dati Amazon Kinesis
Passaggio 1: Esegui lo strumento di migrazione KCL Passaggio 2: ridistribuire il codice con la KCL versione precedente (opzionale)

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à.

Torna alla versione precedente KCL

Questo argomento spiega i passaggi per ripristinare la versione precedente del consumatore. Quando è necessario eseguire il rollback, è prevista una procedura in due fasi:

  1. Esegui lo strumento di KCL migrazione.

  2. Ridistribuisci il codice della KCL versione precedente (opzionale).

Passaggio 1: Esegui lo strumento di migrazione KCL

Quando è necessario ripristinare la KCL versione precedente, è necessario eseguire lo strumento di KCL migrazione. Lo strumento di KCL migrazione svolge due attività importanti:

  • Rimuove una tabella di metadati denominata tabella delle metriche dei lavoratori e indice secondario globale nella tabella di lease in DynamoDB. Questi due artefatti vengono creati dalla versione KCL 3.x ma non sono necessari quando si torna alla versione precedente.

  • Consente a tutti i lavoratori di funzionare in una modalità compatibile con KCL 2.x e di iniziare a utilizzare l'algoritmo di bilanciamento del carico utilizzato nelle versioni precedenti. KCL In caso di problemi con il nuovo algoritmo di bilanciamento del carico in KCL 3.x, questo ridurrà immediatamente il problema.

Importante

La tabella degli stati del coordinatore in DynamoDB deve esistere e non deve essere eliminata durante il processo di migrazione, rollback e rollforward.

Nota

È importante che tutti i lavoratori dell'applicazione consumer utilizzino lo stesso algoritmo di bilanciamento del carico in un determinato momento. Lo strumento di KCL migrazione assicura che tutti i lavoratori dell'applicazione consumer KCL 3.x passino alla modalità compatibile con la versione KCL 2.x, in modo che tutti i lavoratori eseguano lo stesso algoritmo di bilanciamento del carico durante il roll-depayment alla versione precedente. KCL

È possibile scaricare lo strumento di KCL migrazione nella directory degli script del repository. KCL GitHub Lo script può essere eseguito da qualsiasi lavoratore o da qualsiasi host che disponga delle autorizzazioni necessarie per scrivere nella tabella degli stati del coordinatore, eliminare la tabella delle metriche dei lavoratori e aggiornare la tabella dei leasing. È possibile fare riferimento a IAMautorizzazioni necessarie per le applicazioni destinate ai consumatori KCL per l'IAMautorizzazione richiesta per eseguire lo script. È necessario eseguire lo script solo una volta per KCL applicazione. È possibile eseguire lo strumento di KCL migrazione con il seguente comando: 

python3 ./KclMigrationTool.py --region <region> --mode rollback [--application_name <applicationName>] [--lease_table_name <leaseTableName>] [--coordinator_state_table_name <coordinatorStateTableName>] [--worker_metrics_table_name <workerMetricsTableName>]

Parametri

  • --region: sostituisci <region> con il tuo Regione AWS.

  • --application_name: Questo parametro è obbligatorio se utilizzi nomi predefiniti per le tabelle dei metadati di DynamoDB (lease table, coordinator state table e worker metrics table). Se hai specificato nomi personalizzati per queste tabelle, puoi omettere questo parametro. <applicationName>Sostituiscilo con il nome effettivo KCL dell'applicazione. Lo strumento utilizza questo nome per derivare i nomi delle tabelle predefiniti se non vengono forniti nomi personalizzati.

  • --lease_table_name (opzionale): questo parametro è necessario quando hai impostato un nome personalizzato per la tabella di leasing nella tua configurazione. KCL Se stai usando il nome di tabella predefinito, puoi omettere questo parametro. leaseTableNameSostituiscilo con il nome della tabella personalizzata che hai specificato per la tabella di leasing.

  • --coordinator_state_table_name (opzionale): questo parametro è necessario quando hai impostato un nome personalizzato per la tabella degli stati del coordinatore nella tua configurazione. KCL Se stai usando il nome di tabella predefinito, puoi omettere questo parametro. <coordinatorStateTableName>Sostituiscilo con il nome di tabella personalizzato che hai specificato per la tabella degli stati del coordinatore.

  • --worker_metrics_table_name (opzionale): questo parametro è necessario quando hai impostato un nome personalizzato per la tabella delle metriche dei lavoratori nella tua configurazione. KCL Se stai usando il nome di tabella predefinito, puoi omettere questo parametro. <workerMetricsTableName>Sostituiscilo con il nome della tabella personalizzata che hai specificato per la tabella delle metriche dei lavoratori.

Passaggio 2: ridistribuire il codice con la KCL versione precedente (opzionale)

Dopo aver eseguito lo strumento di KCL migrazione per un rollback, vedrai uno di questi messaggi:

  • Messaggio 1: «Rollback completato. KCLL'applicazione eseguiva la modalità compatibile con la KCL versione 2.x. Se non vedi alcuna mitigazione di alcuna regressione, torna ai file binari dell'applicazione precedente distribuendo il codice con la versione precedente.» KCL

    • Azione richiesta: ciò significa che i tuoi lavoratori funzionavano nella modalità compatibile con la versione 2.x. KCL Se il problema persiste, ridistribuisci il codice con la KCL versione precedente ai tuoi worker.

  • Messaggio 2: «Rollback completato. L'KCLapplicazione eseguiva la modalità di funzionalità KCL 3.x. Il rollback ai file binari dell'applicazione precedente non è necessario, a meno che non si veda alcuna mitigazione del problema entro 5 minuti. Se il problema persiste, ripristina i file binari dell'applicazione precedente distribuendo il codice con la versione precedente.» KCL

    • Azione richiesta: Ciò significa che i tuoi lavoratori lavoravano in modalità KCL 3.x e lo strumento di KCL migrazione ha portato tutti i lavoratori alla modalità compatibile con la versione 2.x. KCL Se il problema viene risolto, non è necessario ridistribuire il codice con la versione precedente. KCL Se il problema persiste, ridistribuisci il codice con la versione precedente KCL ai tuoi worker.