Amazon Kinesis（コホート）

AmplitudeデータのAWS Kinesisコホート連携は、コホートメンバーシップの更新を直接Kinesisストリームにストリーミングします。

考慮事項

• この連携は、Amplitudeの有料プランをご利用のお客様のみがご利用いただけます。
• この連携を使用したいAmplitudeプロジェクトごとに有効にする必要があります。
• この連携を設定する前に、Amplitudeのアクティベーションと行動コホートについて理解しておく必要があります。
• Amplitudeはすべてのコホート更新ケーデンス（毎日、毎時、リアルタイム）をサポートしています。
• 既存のリアルタイムコホート同期の制限値はすべて適用されます。

前提条件

開始する前に、AWSアカウントにKinesisトピックを作成し、Amplitudeがコホートの更新をストリームに公開するために使用するIAMロールを作成してください。

連携を設定する

Kinesis の設定

1. Kinesis ストリームの作成

AWS コンソールで Kinesis ストリームを作成します。

2. IAM ロールを作成する

AmplitudeがAWS Kinesisストリームに直接書き込むための権限を付与するIAMロールを作成します。

• アカウントIDには、358203115967と指定します。これはイベントをエクスポートするために使用される Amplitude の AWS アカウントです。
• ポリシーを割り当てずにロールを最終化します。
• 新しいロールの信頼関係は次のようになります。

{
  "Version": "2012-10-17",
  "Statement": [
    {
      "Effect": "Allow",
      "Principal": {
        "AWS": "arn:aws:iam::358203115967:root"
      },
      "Action": "sts:AssumeRole"
    }
  ]
}

3. IAMポリシーの作成

1. IAM ポリシーを作成して、Amplitude に Kinesis ストリームへの書き込み権限を付与します。

2. JSONからポリシーを作成オプションを選択し、「ポリシードキュメント」フィールドで次のテンプレートポリシーを使用します。{account-id}をお使いのアカウントIDに変更し、{region}および{stream-name}を該当する値に置き換えます。また、{role-name}は作成したロールに置き換えます。

   json

   コピー

   {
       "Version": "2012-10-17",
       "Statement": [
           {
               "Effect": "Allow",
               "Action": [
                   "kinesis:PutRecord",
                   "kinesis:PutRecords",
                   "iam:SimulatePrincipalPolicy"
               ],
               "Resource": [
                   "arn:aws:kinesis:{region}:{account-id}:stream/{stream-name}",
                   "arn:aws:iam::{account-id}:role/{role-name}"
               ]
           }
       ]
   }
   

3. 新しいポリシーをロールに割り当てます。

   1. ロールを開きます。
   2. ポリシーを添付オプションを選択し、新しいポリシーを選択します。

ロールARN、ストリームリージョン、およびストリーム名を記録しておいてください。これらは Amplitude で送信先を設定するために必要です。

Amplitude設定

1. Amplitudeデータで、**[カタログ]をクリックし、[宛先]**タブを選択します。
2. [コホート] セクションで、[Kinesis Data Stream] をクリックします。
3. [別の送信先を追加] をクリックします。
4. この送信先の表示名を入力します。この名前は、コホートを同期する際の送信先を識別します。
5. 作成したストリーム名、AWSリージョン、ロールARNを入力します。
6. 送信先を保存します。

コホートの送信

1. Amplitudeで、エクスポートしたいコホートを開きます。
2. 同期をクリックし、Kinesisデータストリームを選択します。
3. 作成した送信先を選択します。
4. 必要な同期頻度を選択します。

ペイロード

Kinesisに送信されるペイロードはJSONオブジェクトです。例：

{
  "cohort_name": "Test Cohort",
  "cohort_id": "gs72ns",
  "in_cohort": true,
  "computed_time": "1685748245",
  "message_id": "some-message-id:54",
  "users": [{
    "user_id": "user1@amplitude.com",
    "user_properties": {
      "city": "San Francisco",
      "fav_animal": "Bat"
    }
  },
    {
      "user_id": "user2@amplitude.com",
      "user_properties": {
        "city": "Seattle",
        "fav_animal": "Cat"
      }
    }]
}