[Ultimate]{class="badge positive"}

Source Amazon Kinesis

IMPORTANT
La source Amazon Kinesis est disponible dans le catalogue des sources pour les utilisateurs qui ont acheté Real-Time Customer Data Platform Ultimate.

Adobe Experience Platform fournit une connectivité native pour les fournisseurs cloud tels qu’AWS, Google Cloud Platform et Azure. Vous pouvez importer vos données de ces systèmes dans Platform.

Les sources de stockage dans le cloud peuvent introduire vos propres données dans Platform sans avoir à les télécharger, les formater ou les transférer. Les données ingérées peuvent être formatées sous la forme XDM JSON, XDM Parquet ou délimitées. Chaque étape du processus est intégrée dans le processus Sources. Platform vous permet d’importer des données de Amazon Kinesis en temps réel.

NOTE
Le facteur d’échelle de Kinesis doit être augmenté si vous devez ingérer des données à volume élevé. Actuellement, le volume maximal de données que vous pouvez importer de votre compte Kinesis vers Platform est de 4 000 enregistrements par seconde. Pour augmenter et ingérer des données à volume supérieur, contactez votre représentant Adobe.

Conditions préalables

La section suivante fournit des informations supplémentaires sur la configuration de prérequis requise pour pouvoir créer une connexion source Kinesis.

Configuration de la stratégie d’accès

Un flux Kinesis nécessite les autorisations suivantes pour créer une connexion source :

  • GetShardIterator
  • GetRecords
  • DescribeStream
  • ListStreams

Ces autorisations sont organisées via la console Kinesis et sont vérifiées par Platform une fois que vous avez saisi vos informations d’identification et sélectionné votre flux de données.

L’exemple ci-dessous illustre les droits d’accès minimaux requis pour créer une connexion source Kinesis.

{
    "Version": "2012-10-17",
    "Statement": [
        {
            "Effect": "Allow",
            "Action": [
                "kinesis:GetShardIterator",
                "kinesis:GetRecords",
                "kinesis:DescribeStream",
                "kinesis:ListStreams"
            ],
            "Resource": [
                "arn:aws:kinesis:us-east-2:901341027596:stream/*"
            ]
        }
    ]
}
Propriété
Description
kinesis:GetShardIterator
Action requise pour parcourir les enregistrements.
kinesis:GetRecords
Action requise pour obtenir des enregistrements à partir d’un décalage ou d’un identifiant de partage spécifique.
kinesis:DescribeStream
Action qui renvoie des informations concernant le flux, y compris la carte partagée, nécessaire pour générer un identifiant partagé.
kinesis:ListStreams
Action requise pour répertorier les flux disponibles que vous pouvez sélectionner dans l’interface utilisateur.

Pour plus d’informations sur le contrôle de l’accès pour les flux de données Kinesis, consultez le Kinesis document suivant.

Configuration du type d’itérateur

Kinesis prend en charge les types d’itérateurs suivants pour vous permettre de spécifier l’ordre de lecture de vos données :

Type d’itérateur
Description
AT_SEQUENCE_NUMBER
Les données sont lues à partir d’une position identifiée par un numéro de séquence spécifique.
AFTER_SEQUENCE_NUMBER
Les données sont lues en commençant après la position identifiée par un numéro de séquence spécifique.
AT_TIMESTAMP
Les données sont lues à partir d’une position identifiée par un horodatage spécifique.
TRIM_HORIZON
Les données sont lues à partir de l’enregistrement de données le plus ancien.
LATEST
Les données sont lues à partir de l’enregistrement de données le plus récent.

Actuellement, une source d’interface utilisateur Kinesis prend uniquement en charge TRIM_HORIZON, tandis que l’API prend en charge TRIM_HORIZON et LATEST comme modes d’obtention de données. La valeur d’itérateur par défaut utilisée par Platform pour la source Kinesis est TRIM_HORIZON.

Pour plus d’informations sur les types d’itérateurs, consultez le Kinesis document suivant.

Connectez Amazon Kinesis à Platform

La documentation ci-dessous fournit des informations sur la connexion de Amazon Kinesis à Platform à l’aide des API ou de l’interface utilisateur :

Utiliser les API

Utiliser l’interface utilisateur

recommendation-more-help
337b99bb-92fb-42ae-b6b7-c7042161d089