Source Amazon Kinesis

Last update: Tue Jun 10 2025 00:00:00 GMT+0000 (Coordinated Universal Time)

Rubriques :

Créé pour :

Développeur

IMPORTANT

La source Amazon Kinesis est disponible dans le catalogue des sources pour les utilisateurs qui ont acheté Real-Time CDP Ultimate.
Vous pouvez désormais utiliser la source Amazon Kinesis lors de l’exécution de Adobe Experience Platform sur Amazon Web Services (AWS). Experience Platform s’exécutant sur AWS est actuellement disponible pour un nombre limité de clients. Pour en savoir plus sur l’infrastructure Experience Platform prise en charge, consultez la présentation multi-cloud d’Experience Platform.

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

Les sources de stockage dans le cloud peuvent introduire vos propres données dans Experience 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. Experience 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 depuis votre compte Kinesis vers Experience Platform est de 4 000 enregistrements par seconde. Pour effectuer une mise à l’échelle et ingérer des données à volume plus élevé, contactez votre représentant Adobe.

Conditions préalables

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

Configurer la politique d’accès

Un flux de 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 Experience Platform une fois que vous avez saisi vos informations d’identification et sélectionné votre flux de données.

L’exemple ci-dessous affiche les droits d’accès minimum 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 partition spécifique.

kinesis:DescribeStream

Une action qui renvoie des informations concernant le flux, y compris la carte des partitions, nécessaire pour générer un identifiant de partition.

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.

Configurer le type d’itérateur

Kinesis prend en charge les types d’itérateur 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 à partir d'une 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 ne prend en charge que les TRIM_HORIZON, tandis que l’API prend en charge les modes TRIM_HORIZON et LATEST comme modes d’obtention de données. La valeur d’itérateur par défaut utilisée par Experience Platform pour la source de Kinesis est TRIM_HORIZON.

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

Connexion de Amazon Kinesis à Experience Platform

NOTE

Après avoir créé ou mis à jour un flux de données en continu, une brève pause de 5 minutes dans l’ingestion des données est nécessaire pour éviter toute instance potentielle de perte de données ou d’abandon de données.

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

Utiliser les API

Utiliser l’interface utilisateur

recommendation-more-help

337b99bb-92fb-42ae-b6b7-c7042161d089