amazon-kinesis-kpl

0La chaleur

1Répondre

Kinesis Agent Input - Fichier journal créé pour chaque jour

Nouveau Le fichier journal est créé pour chaque jour avec la date ajoutée dans le nom. Par exemple, le fichier journal "data_log-2017-05-14" est créé pour le 14 mai. J'ai besoin de configurer Kinesis

0La chaleur

1Répondre

Kinesis Firehose charge les données csv dans Redshift

J'utilise Kinesis firehose pour traiter les données en redshift et j'essaie les formats Json et Csv. Le format JSON fonctionne bien pour moi et les données sont chargées dans la table redshift. COPIE

0La chaleur

1Répondre

L'agent Kinesis n'envoie pas d'enregistrements au flux

J'ai créé un flux Kinesis Firehose pour transférer les données en redshift et j'essaie de transmettre des données à partir d'une instance EC2 à l'aide de l'agent kinésis. Firehose Stream est en mesure

5La chaleur

1Répondre

spark kinesis échouant sur cloudera avec java.lang.AbstractMethodError

ci-dessous est mon fichier POM. Je suis en train d'écrire une étincelle avec le streaming aws Kinesis <dependency> <groupId>org.apache.spark</groupId> <artifactId>spark-streaming_2.10</art

0La chaleur

1Répondre

Impossible de lire les données provenant de la diffusion d'étincelles reliant Kinesis

J'ai écrit ci-dessous du code pour me connecter à Kinesis à partir d'étincelles mais aucune donnée n'a été reçue. val kinesisStream = KinesisUtils.createStream (ssc, appName, streamName, endpointURL,

1La chaleur

1Répondre

Amazon Kinesis - Identifier le délai d'expiration

Vous avez tenté de créer une requête Kinesis Analytics pour vous alerter lorsqu'une étape d'un processus a pris trop de temps (ou est morte et n'a pas été déplacée). Je dispose d'un flux de données co