Amazon Kinesis connecteur

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

Les sources d’enregistrement Cloud peuvent importer vos propres données dans Platform sans avoir à télécharger, mettre en forme ou télécharger. Les données insé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 Amazon Kinesis en temps réel.

LISTE AUTORISÉE d'adresse IP

Une liste d’adresses IP doit être ajoutée à une liste autorisée avant d’utiliser les connecteurs source. Si vous n’ajoutez pas d’adresses IP spécifiques à votre région à votre liste autorisée, des erreurs ou des performances risquent d’apparaître lors de l’utilisation de sources. Pour plus d'informations, consultez la page liste autorisée d'adresse IP.

Conditions préalables

La section suivante fournit des informations supplémentaires sur la configuration de prérequis requise avant de 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 présente 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 ID partagé spécifique.
kinesis:DescribeStream Action qui renvoie des informations concernant le flux, y compris le mappage partagé, nécessaire pour générer un identifiant partagé.
kinesis:ListStreams Action requise pour liste des flux disponibles que vous pouvez sélectionner dans l’interface utilisateur.

Pour plus d'informations sur le contrôle de l'accès aux 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 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 du plus ancien enregistrement de données.
LATEST Les données sont lues à partir de l’enregistrement de données le plus récent.

Une source d'interface utilisateur Kinesis ne prend actuellement en charge que TRIM_HORIZON, tandis que l'API prend en charge à la fois TRIM_HORIZON et LATEST en tant que modes pour obtenir des 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érateur, consultez le Kinesis document suivant.

Connecter Amazon Kinesis à Platform

La documentation ci-dessous fournit des informations sur la façon de se connecter Amazon Kinesis à Platform à l'aide d'API ou de l'interface utilisateur :

Utilisation des API

Utilisation de l’interface utilisateur

Sur cette page