Amazon Pinpoint で使用しているエンドポイント ID を一覧表示する

エンドポイントを更新または削除するには、エンドポイント ID が必要です。そのため、Amazon Pinpoint プロジェクトのすべてのエンドポイントでこれらのオペレーションを実行するには、まずそのプロジェクトに属するすべてのエンドポイント ID を一覧表示します。次に、これらの ID を反復処理します。例えば、属性をグローバルに追加するか、プロジェクトのエンドポイントを削除します。

次の例では、 を使用し AWS SDK for Java 、以下を実行します。

1. 「Amazon Pinpoint からエンドポイントをエクスポートする」のサンプルコードからサンプル exportEndpointsToS3 メソッドを呼び出します。このメソッドでは、Amazon Pinpoint プロジェクトからエンドポイント定義をエクスポートします。エンドポイント定義は、gzip ファイルとして Amazon S3 バケットに追加されます。

2. エクスポートされた gzip ファイルをダウンロードします。

3. gzip ファイルを読み込み、各エンドポイントの JSON 定義からエンドポイント ID を取得します。

4. エンドポイント ID がコンソールに出力されます。

5. Amazon Pinpoint によって Amazon S3 に追加されたファイルを削除してクリーンアップします。

import software.amazon.awssdk.regions.Region;
import software.amazon.awssdk.services.pinpoint.PinpointClient;
import software.amazon.awssdk.services.pinpoint.model.EndpointResponse;
import software.amazon.awssdk.services.pinpoint.model.GetUserEndpointsRequest;
import software.amazon.awssdk.services.pinpoint.model.GetUserEndpointsResponse;
import software.amazon.awssdk.services.pinpoint.model.PinpointException;
import java.util.List;

import software.amazon.awssdk.regions.Region;
import software.amazon.awssdk.services.pinpoint.PinpointClient;
import software.amazon.awssdk.services.pinpoint.model.EndpointResponse;
import software.amazon.awssdk.services.pinpoint.model.GetUserEndpointsRequest;
import software.amazon.awssdk.services.pinpoint.model.GetUserEndpointsResponse;
import software.amazon.awssdk.services.pinpoint.model.PinpointException;
import java.util.List;

/**
 * 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 ListEndpointIds {
    public static void main(String[] args) {
        final String usage = """

                Usage:    <applicationId> <userId>

                Where:
                   applicationId - The ID of the Amazon Pinpoint application that has the endpoint.
                   userId - The user id applicable to the endpoints""";

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

        String applicationId = args[0];
        String userId = args[1];
        PinpointClient pinpoint = PinpointClient.builder()
                .region(Region.US_EAST_1)
                .build();

        listAllEndpoints(pinpoint, applicationId, userId);
        pinpoint.close();
    }

    public static void listAllEndpoints(PinpointClient pinpoint,
            String applicationId,
            String userId) {

        try {
            GetUserEndpointsRequest endpointsRequest = GetUserEndpointsRequest.builder()
                    .userId(userId)
                    .applicationId(applicationId)
                    .build();

            GetUserEndpointsResponse response = pinpoint.getUserEndpoints(endpointsRequest);
            List<EndpointResponse> endpoints = response.endpointsResponse().item();

            // Display the results.
            for (EndpointResponse endpoint : endpoints) {
                System.out.println("The channel type is: " + endpoint.channelType());
                System.out.println("The address is  " + endpoint.address());
            }

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

SDK の完全な例については、「GitHub」 の「ListEndpointIs.java」を参照してください。