세그먼트 가져오기

Amazon Pinpoint에서는 세그먼트에 속하는 엔드포인트에 대한 정보를 가져와 사용자 세그먼트를 정의할 수 있습니다. 엔드포인트는 단일 메시징 대상(예: 모바일 푸시 디바이스 토큰, 휴대폰 번호, 이메일 주소)입니다.

Amazon Pinpoint 외부에서 사용자 세그먼트를 이미 만들었지만 사용자를 Amazon Pinpoint 캠페인에 참여시키기 원할 경우 세그먼트 가져오기가 유용합니다.

세그먼트를 가져오면 Amazon Pinpoint는 Amazon Simple Storage Service(Amazon S3)에서 세그먼트의 엔드포인트를 가져옵니다. 가져오기 전에 Amazon S3에 엔드포인트를 추가하고 Amazon Pinpoint에 Amazon S3 액세스 권한을 부여하는 IAM 역할을 생성합니다. 그런 다음 Amazon Pinpoint에 엔드포인트가 저장된 Amazon S3 위치를 제공합니다. 그러면 Amazon Pinpoint가 세그먼트에 각 엔드포인트를 추가합니다.

IAM 역할을 생성하려면 IAM엔드포인트 또는 세그먼트를 가져오기 위한 역할 단원을 참조하세요. Amazon Pinpoint 콘솔을 사용하여 세그먼트를 가져오는 방법에 대한 자세한 내용은 Amazon Pinpoint 사용 설명서의 세그먼트 가져오기를 참조하세요.

더 많은 코드 예제는 코드 예제를 참조하십시오.

세그먼트 가져오기

다음 예제는 AWS SDK for Java를 사용하여 세그먼트를 가져오는 방법을 보여 줍니다.

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

전체 SDK 예제를 ImportingSegments보려면.java on을 참조하십시오. GitHub