Importieren von Segmenten

Sie können in Amazon Pinpoint ein Benutzersegment definieren, indem Sie Informationen zu den Endpunkten importieren, die zum Segment gehören. Ein Endpunkt ist ein einzelnes Messaging-Ziel, wie ein Geräte-Token für mobile Push-Benachrichtigungen, eine Mobiltelefonnummer oder eine E-Mail-Adresse.

Das Importieren von Segmenten ist nützlich, wenn Sie Ihre Benutzer bereits außerhalb von Amazon Pinpoint segmentiert haben, Ihre Benutzer jedoch in Amazon-Pinpoint-Kampagnen einbinden möchten.

Wenn Sie ein Segment importieren, ruft Amazon Pinpoint die Endpunkte des Segments von Amazon Simple Storage Service (Amazon S3) ab. Vor dem Importieren fügen Sie die Endpunkte zu Amazon S3 hinzu und erstellen eine IAM-Rolle, die Amazon Pinpoint Zugriff auf Amazon S3 gewährt. Anschließend teilen Sie Amazon Pinpoint den Amazon-S3-Standort mit, an dem die Endpunkte gespeichert sind, und Amazon Pinpoint fügt jeden Endpunkt dem Segment hinzu.

Informationen zum Erstellen der IAM-Rolle finden Sie unter IAM-Rolle für das Importieren von Endpunkten oder Segmenten. Weitere Informationen zum Importieren von Segmenten über die Amazon-Pinpoint-Konsole finden Sie unter Importieren von Segmenten im Amazon-Pinpoint-Benutzerhandbuch.

Importieren von Segmenten

Das folgende Beispiel zeigt, wie Sie ein Segment über AWS SDK for Java importieren.

import software.amazon.awssdk.regions.Region;
import software.amazon.awssdk.services.pinpoint.PinpointClient;
import software.amazon.awssdk.services.pinpoint.model.CreateImportJobRequest;
import software.amazon.awssdk.services.pinpoint.model.ImportJobResponse;
import software.amazon.awssdk.services.pinpoint.model.ImportJobRequest;
import software.amazon.awssdk.services.pinpoint.model.Format;
import software.amazon.awssdk.services.pinpoint.model.CreateImportJobResponse;
import software.amazon.awssdk.services.pinpoint.model.PinpointException;

import software.amazon.awssdk.regions.Region;
import software.amazon.awssdk.services.pinpoint.PinpointClient;
import software.amazon.awssdk.services.pinpoint.model.CreateImportJobRequest;
import software.amazon.awssdk.services.pinpoint.model.ImportJobResponse;
import software.amazon.awssdk.services.pinpoint.model.ImportJobRequest;
import software.amazon.awssdk.services.pinpoint.model.Format;
import software.amazon.awssdk.services.pinpoint.model.CreateImportJobResponse;
import software.amazon.awssdk.services.pinpoint.model.PinpointException;

/**
 * Before running this Java V2 code example, set up your development
 * environment, including your credentials.
 *
 * For more information, see the following documentation topic:
 *
 * https://docs.aws.amazon.com/sdk-for-java/latest/developer-guide/get-started.html
 */
public class ImportSegment {
    public static void main(String[] args) {
        final String usage = """

                Usage:   <appId> <bucket> <key> <roleArn>\s

                Where:
                  appId - The application ID to create a segment for.
                  bucket - The name of the Amazon S3 bucket that contains the segment definitons.
                  key - The key of the S3 object.
                  roleArn - ARN of the role that allows Amazon Pinpoint to access S3. You need to set trust management for this to work. See https://docs.aws.amazon.com/IAM/latest/UserGuide/reference_policies_elements_principal.html
                  """;

        if (args.length != 4) {
            System.out.println(usage);
            System.exit(1);
        }

        String appId = args[0];
        String bucket = args[1];
        String key = args[2];
        String roleArn = args[3];

        PinpointClient pinpoint = PinpointClient.builder()
                .region(Region.US_EAST_1)
                .build();

        ImportJobResponse response = createImportSegment(pinpoint, appId, bucket, key, roleArn);
        System.out.println("Import job for " + bucket + " submitted.");
        System.out.println("See application " + response.applicationId() + " for import job status.");
        System.out.println("See application " + response.jobStatus() + " for import job status.");
        pinpoint.close();
    }

    public static ImportJobResponse createImportSegment(PinpointClient client,
            String appId,
            String bucket,
            String key,
            String roleArn) {

        try {
            ImportJobRequest importRequest = ImportJobRequest.builder()
                    .defineSegment(true)
                    .registerEndpoints(true)
                    .roleArn(roleArn)
                    .format(Format.JSON)
                    .s3Url("s3://" + bucket + "/" + key)
                    .build();

            CreateImportJobRequest jobRequest = CreateImportJobRequest.builder()
                    .importJobRequest(importRequest)
                    .applicationId(appId)
                    .build();

            CreateImportJobResponse jobResponse = client.createImportJob(jobRequest);
            return jobResponse.importJobResponse();

        } catch (PinpointException e) {
            System.err.println(e.awsErrorDetails().errorMessage());
            System.exit(1);
        }
        return null;
    }
}

Das vollständige SDK-Beispiel finden Sie unter ImportingSegments.java auf GitHub.