Utilisation de la diffusion améliorée dans les tâches de streaming Kinesis - AWS Glue

Les traductions sont fournies par des outils de traduction automatique. En cas de conflit entre le contenu d'une traduction et celui de la version originale en anglais, la version anglaise prévaudra.

Utilisation de la diffusion améliorée dans les tâches de streaming Kinesis

Un client bénéficiant de la diffusion améliorée est capable de recevoir des enregistrements provenant d'un flux Kinesis avec un débit dédié qui peut être supérieur à celui des consommateurs classiques. Cela se fait en optimisant le protocole de transfert utilisé pour fournir des données à un client Kinesis, tel que votre tâche. Pour plus d'informations sur la diffusion améliorée de Kinesis, consultez la documentation Kinesis.

En mode de diffusion améliorée, les options de connexion maxRecordPerRead et idleTimeBetweenReadsInMs ne s'appliquent plus, car ces paramètres ne sont pas configurables lors de la diffusion améliorée. Les options de configuration pour les nouvelles tentatives fonctionnent comme décrit.

Utilisez les procédures suivantes pour activer et désactiver la diffusion améliorée pour votre tâche de streaming. Vous devez enregistrer un consommateur de flux pour chaque tâche qui consommera des données de votre flux.

Pour activer la consommation de diffusion améliorée sur votre tâche :

  1. Enregistrez un consommateur de flux pour votre tâche à l'aide de l'API Kinesis. Suivez les instructions de la documentation Kinesis pour enregistrer un consommateur avec une diffusion améliorée en utilisant à l'aide de l'API Kinesis Data Streams. Il vous suffira de suivre la première étape : appeler RegisterStreamConsumer. Votre requête doit renvoyer un ARN, consumerARN.

  2. Définissez l'option de connexion fanoutConsumerARN sur consumerARN dans les arguments de votre méthode de connexion.

  3. Redémarrez votre tâche.

Pour désactiver la consommation de diffusion améliorée sur votre tâche :

  1. Supprimez l'option de connexion fanoutConsumerARN de votre appel de méthode.

  2. Redémarrez votre tâche.

  3. Suivez les instructions de la documentation Kinesis pour annuler l'enregistrement d'un consommateur. Ces instructions s'appliquent à la console, mais peuvent également être obtenues via l'API Kinesis. Pour plus d'informations sur l'annulation de l'enregistrement d'un consommateur du flux via l'API Kinesis, consultez DeregisterStreamConsumer dans la documentation Kinesis.