Siapkan Amazon Pinpoint untuk mengalirkan data peristiwa aplikasi melalui Amazon Kinesis atau Amazon Data Firehose - Amazon Pinpoint
PrasyaratAWS CLIAWS SDK for Java

Terjemahan disediakan oleh mesin penerjemah. Jika konten terjemahan yang diberikan bertentangan dengan versi bahasa Inggris aslinya, utamakan versi bahasa Inggris.

Siapkan Amazon Pinpoint untuk mengalirkan data peristiwa aplikasi melalui Amazon Kinesis atau Amazon Data Firehose

Anda dapat mengatur Amazon Pinpoint untuk mengirim data peristiwa ke aliran Amazon Kinesis atau aliran pengiriman Amazon Data Firehose. Amazon Pinpoint dapat mengirim data acara untuk kampanye, perjalanan, serta email dan pesan transaksional. SMS

Bagian ini mencakup informasi tentang pengaturan streaming acara secara terprogram. Anda juga dapat menggunakan konsol Amazon Pinpoint untuk mengatur streaming acara. Untuk informasi tentang mengatur streaming acara menggunakan konsol Amazon Pinpoint, lihat Pengaturan aliran peristiwa di Panduan Pengguna Amazon Pinpoint.

Prasyarat

Contoh di bagian ini memerlukan masukan berikut:

  • ID aplikasi aplikasi yang terintegrasi dengan Amazon Pinpoint dan melaporkan peristiwa. Untuk informasi tentang cara mengintegrasikan, lihatIntegrasikan Amazon Pinpoint dengan aplikasi Anda.

  • Nama Sumber Daya Amazon (ARN) dari aliran Kinesis atau aliran pengiriman Firehose di akun Anda. AWS Untuk informasi tentang cara membuat sumber daya ini, lihat Membuat dan Mengelola Aliran di Panduan Pengembang Amazon Kinesis Data Streams atau Membuat aliran pengiriman Amazon Data Firehose di Panduan Pengembang Amazon Data Firehose.

  • Peran ARN of a AWS Identity and Access Management (IAM) yang mengizinkan Amazon Pinpoint untuk mengirim data ke aliran. Untuk informasi tentang membuat peran, lihatPeran IAM untuk streaming acara ke Kinesis.

AWS CLI

AWS CLI Contoh berikut menggunakan put-event-streamperintah. Perintah ini mengonfigurasi Amazon Pinpoint untuk mengirim peristiwa ke aliran Kinesis:

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

AWS SDK for Java

Contoh Java berikut mengonfigurasi Amazon Pinpoint untuk mengirim peristiwa ke aliran 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);
}

Contoh ini membangun WriteEventStream objek yang menyimpan ARNs aliran Kinesis dan IAM peran. WriteEventStreamObjek diteruskan ke PutEventStreamRequest objek untuk mengonfigurasi Amazon Pinpoint untuk mengalirkan peristiwa untuk aplikasi tertentu. PutEventStreamRequestObjek diteruskan ke putEventStream metode klien Amazon Pinpoint.

Anda dapat menetapkan aliran Kinesis ke beberapa aplikasi. Jika Anda melakukan ini, Amazon Pinpoint mengirimkan data peristiwa yang dikodekan dalam base64 dari setiap aplikasi ke aliran, yang memungkinkan Anda menganalisis data sebagai koleksi. Contoh metode berikut menerima daftar aplikasi (app)IDs, dan menggunakan metode contoh sebelumnya,createEventStream, untuk menetapkan aliran ke setiap aplikasi:

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

Meskipun Anda dapat menetapkan satu aliran ke beberapa aplikasi, Anda tidak dapat menetapkan beberapa aliran ke satu aplikasi.