Configura Amazon Pinpoint per lo streaming dei dati degli eventi delle app tramite Amazon Kinesis o Amazon Data Firehose

Puoi configurare Amazon Pinpoint per inviare i dati degli eventi a uno stream Amazon Kinesis o a un flusso di distribuzione Amazon Data Firehose. Amazon Pinpoint può inviare dati sugli eventi per campagne, viaggi, e-mail e messaggi transazionali. SMS

Questa sezione include informazioni sulla configurazione dello streaming di eventi a livello di programmazione. Puoi anche utilizzare la console Amazon Pinpoint per configurare lo streaming di eventi. Per informazioni sulla configurazione dello streaming di eventi utilizzando la console Amazon Pinpoint, consulta Impostazioni del flusso di eventi nella Guida per l'utente di Amazon Pinpoint.

Prerequisiti

Gli esempi in questa sezione richiedono il seguente input:

• L'ID di un'applicazione integrata con Amazon Pinpoint e che segnala gli eventi. Per informazioni sull'integrazione, consulta Integra Amazon Pinpoint con la tua applicazione.

• L'Amazon Resource Name (ARN) di uno stream Kinesis o di un flusso di distribuzione Firehose nel tuo account. AWS Per informazioni sulla creazione di queste risorse, consulta Creating and Managing Streams nella Amazon Kinesis Data Streams Developer Guide o Creazione di un flusso di distribuzione Amazon Data Firehose nella Amazon Data Firehose Developer Guide.

• Il ruolo ARN di un AWS Identity and Access Management (IAM) che autorizza Amazon Pinpoint a inviare dati allo stream. Per informazioni su come creare un ruolo, consulta IAMruolo per lo streaming di eventi su Kinesis.

AWS CLI

L' AWS CLI esempio seguente utilizza il comando. put-event-stream Questo comando configura Amazon Pinpoint per l'invio di eventi a un flusso Kinesis:

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

AWS SDK for Java

L'esempio Java seguente configura Amazon Pinpoint per l'invio di eventi a un flusso 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);
}

Questo esempio costruisce un WriteEventStream oggetto che memorizza il ARNs flusso Kinesis e IAM il ruolo. L'oggetto WriteEventStream viene passato a un oggetto PutEventStreamRequest per configurare Amazon Pinpoint per lo streaming degli eventi per un'applicazione specifica. L'oggetto PutEventStreamRequest viene passato al metodo putEventStream del client Amazon Pinpoint.

Puoi assegnare un flusso Kinesis a più applicazioni. In questo caso, Amazon Pinpoint invia i dati degli eventi con codifica Base64 da ogni applicazione al flusso e ciò consente di analizzare i dati come una raccolta. Il seguente metodo di esempio accetta un elenco di applicazioni (app) IDs e utilizza il metodo di esempio precedente per assegnare uno stream a ciascuna applicazione: 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());
}

Sebbene sia possibile assegnare un flusso a più applicazioni, non è possibile assegnare più flussi a una sola applicazione.