KinesisReceiver

Utilise le service Amazon Kinesis pour recevoir des enregistrements de données depuis un flux Amazon Kinesis.

Notes

Les performances de ce Transformer dépendent de la quantité de mémoire allouée à la machine virtuelle Java (Java VM ou JVM pour Java Virtual Machine). Les variables d'environnement suivantes vous permettent de spécifier la mémoire disponible pour les plugins Java :

FME_JVM_MIN_HEAP_SIZE : Taille initiale du tas pour l'initialisation de la JVM. Si elle n'est pas définie, la valeur par défaut est de 1024K.

Ces variables doivent être définies en multiples de 1024 et supérieures à 1 Mo. Pour indiquer des kilo-octets, des méga-octets ou des giga-octets, ajoutez respectivement k ou K, m ou M, ou g ou G. Par exemple, n'importe laquelle de ces valeurs est acceptable :

6291456

6144k

FME_JVM_MAX_HEAP_SIZE : Taille maximale du tas pour l'initialisation de la JVM. Si elle n'est pas définie, la valeur par défaut est de 16384K.

Ces variables doivent être définies en multiples de 1024 et supérieures à 2 Mo. Pour indiquer des kilo-octets, des méga-octets ou des giga-octets, ajoutez respectivement k ou K, m ou M, ou g ou G. Par exemple, n'importe laquelle de ces valeurs est acceptable :

83886080

81920k

80m

Note: Pljrmass

Configuration

Ports d'entrée

Ports de sortie

Output

Entités contenant des enregistrements de données provenant du flux Amazon Kinesis spécifié. Le contenu et les autres détails de l'enregistrement de données sont stockés en tant qu'attributs de l'entité. Les attributs suivants sont utilisés :

Attribut	Description
sequence_number	Numéro de séquence de l'enregistrement de données.
partition_key	Clé de partition de l'enregistrement de données.
data_blob	Attribut blob de l'enregistrement de données.
shard_id	Id du groupe "shard" contenant l'enregistrement de données.

Paramètres

Condition de fin

Condition de fin	Si Aucun, le récepteur fonctionne indéfiniment. Si Temps de scrutation max, entrez une durée maximale d'interrogation en secondes dans Temps de scrutation max. Si Enregistrement max en sortie, entrez le nombre maximum d'enregistrements de données à produire dans Enregistrement max en sortie. Si l'option Les deux est sélectionnée, entrez les valeurs de la durée maximale de scrutation et du nombre maximal d'enregistrements à produire. Quelle que soit la première condition d'arrêt remplie, le récepteur arrête la lecture du flux.
Temps de scrutation maximum	Le temps maximum en secondes passé à ne recevoir aucun enregistrement de données du flux Kinesis. Le temps d'interrogation commence une fois que tous les shards du flux ont été initialisés. Une fois la durée maximale d'interrogation atteinte, le récepteur arrêtera de lire le flux. Le minimum est de 1 seconde et doit être des valeurs entières.
Enregistrements max à produire	Le nombre maximum d'enregistrements de données à sortir par le Transformer. Une fois que le nombre maximum d'enregistrements est sorti, le récepteur arrête de lire le flux.

Éditer les paramètres des Transformers

À l'aide d'un ensemble d'options de menu, les paramètres du Transformer peuvent être attribués en faisant référence à d'autres éléments de traitement. Des fonctions plus avancées, telles qu'un éditeur avancé et un éditeur arithmétique, sont également disponibles dans certains Transformers. Pour accéder à un menu de ces options, cliquez sur à côté du paramètre applicable. Pour plus d'informations, voir Options de menus et paramètres de Transformer.

Catégories de Transformers

Intégrations

FME Community

FME Community iest l'endroit où trouver des démos, des tutoriaux, des articles, des FAQ et bien plus encore. Obtenez des réponses à vos questions, apprenez des autres utilisateurs et suggérez, votez et commentez de nouvelles entités.

Rechercher des exemples et informations à propos de ce Transformer dans FME Community.

OpenSans-BoldItalic.ttf

OpenSans-Italic.ttf

OpenSans-Regular.ttf

SourceSansPro-Bold.ttf

SourceSansPro-BoldItalic.ttf

SourceSansPro-Italic.ttf

SourceSansPro-Regular.ttf

Flux	Nom du flux Kinesis dans lequel les données sont récupérées.
Région	Région AWS dans laquelle le flux Kinesis est créé.
Clé d'accès	Une clé d'accès associée à un utilisateur ayant la permission de recevoir des messages depuis le flux Kinesis.
Clé d'accès secrète	Une clé secrète associée à la clé d'accès fournie.

Nom de l'application	Nom de l'application traitant le flux Kinesis.
Période d'inactivité entre les lectures	Le temps d'inactivité en secondes entre les lectures du flux Kinesis. Le minimum est de 0,001 seconde et peut aller jusqu'à 3 espaces décimaux.
Enregistrements max par lecture	Nombre maximum d'enregistrements pouvant être reçus du flux Kinesis par lecture. Le maximum est de 10 000 enregistrements de données.