Utilizzo del fan-out avanzato nei processi di flussi di dati Kinesis - AWS Glue

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

Utilizzo del fan-out avanzato nei processi di flussi di dati Kinesis

Un consumatore con fan-out avanzato è in grado di ricevere i record da un flusso Kinesis con una velocità di trasmissione effettiva dedicata che può essere superiore a quella dei consumatori tipici. Questo viene fatto ottimizzando il protocollo di trasferimento utilizzato per fornire dati a un consumatore Kinesis, ad esempio il tuo processo. Per ulteriori informazioni sul fan-out avanzato di Kinesis, consulta la documentazione di Kinesis.

Nella modalità fan-out avanzato, le opzioni di connessione maxRecordPerRead e idleTimeBetweenReadsInMs non sono più valide, poiché tali parametri non sono configurabili quando si utilizza il fan-out avanzato. Le opzioni di configurazione per i nuovi tentativi funzionano come descritto.

Utilizza le seguenti procedure per abilitare e disabilitare il fan-out avanzato per il tuo processo di flussi di dati. Devi registrare un consumatore del flusso per ogni processo che consumerà i dati del flusso.

Per abilitare il consumo con fan-out avanzato nel processo:

  1. Registra un consumatore del flusso per il tuo processo utilizzando l'API Kinesis. Segui le istruzioni per registrare un consumatore con fan-out avanzato utilizzando l'API Flusso di dati Kinesis riportate nella documentazione di Kinesis. Dovrai eseguire solo il primo passaggio: chiamare RegisterStreamConsumer. La tua richiesta dovrebbe restituire un ARN, consumerARN.

  2. Imposta l'opzione di connessione fanoutConsumerARN su consumerARN negli argomenti del metodo di connessione.

  3. Riavvia il processo.

Per disabilitare il consumo con fan-out avanzato nel processo:

  1. Rimuovi l'opzione di connessione fanoutConsumerARN dalla chiamata al metodo.

  2. Riavvia il processo.

  3. Segui le istruzioni per annullare la registrazione di un consumatore riportate nella documentazione di Kinesis. Queste istruzioni si applicano alla console, ma possono essere utilizzate anche per l'API Kinesis. Per ulteriori informazioni sull'annullamento della registrazione dei consumatori dei flussi tramite l'API Kinesis, consulta la sezione DeregisterStreamConsumer nella documentazione di Kinesis.