Richten Sie Amazon Pinpoint ein, um App-Ereignisdaten über Amazon Kinesis oder Amazon Data Firehose zu streamen

Sie können Amazon Pinpoint so einrichten, dass Ereignisdaten an einen Amazon Kinesis Kinesis-Stream oder einen Amazon Data Firehose-Lieferstream gesendet werden. Amazon Pinpoint kann Ereignisdaten für Kampagnen, Reisen sowie Transaktions-E-Mails und -Nachrichten senden. SMS

Dieser Abschnitt enthält Informationen zum programmgesteuerten Konfigurieren von Ereignis-Streaming. Sie können auch die Amazon-Pinpoint-Konsole verwenden, um Ereignis-Streaming zu konfigurieren. Weitere Informationen zum Konfigurieren von Ereignis-Streaming mithilfe der Amazon-Pinpoint-Konsole finden Sie unter Ereignis-Stream-Einstellungen im Amazon-Pinpoint-Benutzerhandbuch.

Voraussetzungen

Die Beispiele in diesem Abschnitt erfordern die folgende Eingabe:

• Die Anwendungs-ID einer Anwendung, die mit Amazon Pinpoint und Berichtsereignissen integriert ist. Weitere Informationen über die Integration finden Sie unter Integrieren Sie Amazon Pinpoint in Ihre Anwendung.

• Der Amazon-Ressourcenname (ARN) eines Kinesis-Streams oder Firehose-Lieferstreams in Ihrem AWS Konto. Informationen zum Erstellen dieser Ressourcen finden Sie unter Creating and Managing Streams im Amazon Kinesis Data Streams Developer Guide oder Creating an Amazon Data Firehose Delivery Stream im Amazon Data Firehose Developer Guide.

• Die Rolle ARN of an AWS Identity and Access Management (IAM), die Amazon Pinpoint autorisiert, Daten an den Stream zu senden. Weitere Informationen zum Erstellen einer Rolle finden Sie unter IAMRolle für das Streamen von Ereignissen zu Kinesis.

AWS CLI

Im folgenden AWS CLI Beispiel wird der put-event-streamBefehl verwendet. Dieser Befehl konfiguriert Amazon Pinpoint, um Ereignisse an einen Kinesis-Stream zu senden:

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

AWS SDK for Java

Im folgenden Java-Beispiel wird Amazon Pinpoint so konfiguriert, dass Ereignisse an einen Kinesis-Stream gesendet werden:

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);
}

In diesem Beispiel wird ein WriteEventStream Objekt erstellt, das den ARNs Kinesis-Stream und die IAM Rolle speichert. Das WriteEventStream-Objekt wird an ein PutEventStreamRequest-Objekt übergeben, um Amazon Pinpoint für das Streamen von Ereignissen für eine bestimmte Anwendung zu konfigurieren. Das PutEventStreamRequest-Objekt wird an die putEventStream-Methode des Amazon-Pinpoint-Client übergeben.

Sie können einen Kinesis-Stream mehreren Anwendungen zuordnen. Wenn Sie dies tun, sendet Amazon Pinpoint in base64 verschlüsselte Ereignisdaten von jeder Anwendung an den Stream, sodass Sie die Daten als Sammlung analysieren können. Die folgende Beispielmethode akzeptiert eine Liste von Anwendungen (App) IDs und verwendet die vorherige Beispielmethode,createEventStream, um jeder Anwendung einen Stream zuzuweisen:

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());
}

Sie können zwar einen Stream mehreren Anwendungen zuweisen, jedoch nicht mehrere Streams einer Anwendung.