Configurer Amazon Pinpoint pour diffuser les données d'événements des applications via Amazon Kinesis ou Amazon Data Firehose - Amazon Pinpoint

Les traductions sont fournies par des outils de traduction automatique. En cas de conflit entre le contenu d'une traduction et celui de la version originale en anglais, la version anglaise prévaudra.

Configurer Amazon Pinpoint pour diffuser les données d'événements des applications via Amazon Kinesis ou Amazon Data Firehose

Vous pouvez configurer Amazon Pinpoint pour envoyer les données des événements vers un flux Amazon Kinesis ou un flux de diffusion Amazon Data Firehose. Amazon Pinpoint peut envoyer des données d'événements pour les campagnes, les parcours, les e-mails et les messages transactionnels. SMS

Cette section inclut des informations sur la configuration de la diffusion en continu d'événements par programmation. Vous pouvez également utiliser la console Amazon Pinpoint pour configurer la diffusion en continu des événements. Pour plus d'informations sur la configuration de la diffusion en continu d'événements à l'aide de la console Amazon Pinpoint, consultez Paramètres de flux d'événements dans le Guide de l'utilisateur Amazon Pinpoint.

Prérequis

Les exemples de cette section nécessitent l'entrée suivante :

AWS CLI

L' AWS CLI exemple suivant utilise la put-event-streamcommande. Cette commande configure Amazon Pinpoint pour envoyer des événements vers un flux Kinesis :

aws pinpoint put-event-stream \ --application-id projectId \ --write-event-stream DestinationStreamArn=streamArn,RoleArn=roleArn

AWS SDK for Java

L'exemple Java suivant configure Amazon Pinpoint pour envoyer des événements vers un flux Kinesis :

public PutEventStreamResult createEventStream(AmazonPinpoint pinClient, String appId, String streamArn, String roleArn) { WriteEventStream stream = new WriteEventStream() .withDestinationStreamArn(streamArn) .withRoleArn(roleArn); PutEventStreamRequest request = new PutEventStreamRequest() .withApplicationId(appId) .withWriteEventStream(stream); return pinClient.putEventStream(request); }

Cet exemple construit un WriteEventStream objet qui stocke le ARNs flux Kinesis et IAM le rôle. L'objet WriteEventStream est transmis à un objet PutEventStreamRequest afin de configurer Amazon Pinpoint pour diffuser en continu les événements d'une application spécifique. L'objet PutEventStreamRequest est transmis à la méthode putEventStream du client Amazon Pinpoint.

Vous pouvez attribuer un flux Kinesis à plusieurs applications. Dans ce cas, Amazon Pinpoint envoie les données d'événement de chaque application au flux, ce qui vous permet d'analyser les données sous forme de collection. L'exemple de méthode suivant accepte une liste d'applications (app) IDs et utilise l'exemple de méthode précédent pour attribuer un flux à chaque application : createEventStream

public List<PutEventStreamResult> createEventStreamFromAppList( AmazonPinpoint pinClient, List<String> appIDs, String streamArn, String roleArn) { return appIDs.stream() .map(appId -> createEventStream(pinClient, appId, streamArn, roleArn)) .collect(Collectors.toList()); }

Même si vous pouvez attribuer un même flux à plusieurs applications, vous ne pouvez pas attribuer plusieurs flux à une même application.