[Ultimate]{class="badge positive"}

Amazon Kinesis ソース

IMPORTANT
  • Amazon Kinesis ソースは、Real-Time CDP Ultimateを購入したユーザーがソースカタログで利用できます。

  • Amazon Web Services(AWS)でAdobe Experience Platformを実行する際に、Amazon Kinesis ソースを使用できるようになりました。 AWS上で動作するExperience Platformは、現在、一部のお客様にご利用いただけます。 サポートされているExperience Platform インフラストラクチャについて詳しくは、Experience Platform マルチクラウドの概要を参照してください。

Adobe Experience Platformは、AWS、Google Cloud Platform、Azureなどのクラウドプロバイダーにネイティブ接続を提供します。 これらのシステムからデータをExperience Platformに取り込むことができます。

クラウドストレージソースを使用すると、ダウンロード、フォーマット、アップロードを行う必要なく、独自のデータを Experience Platform に取り込むことができます。 取り込んだデータは、XDM JSON、XDM Parquet 形式または区切り形式で書式設定できます。 プロセスのすべての手順がソースワークフローに統合されます。 Experience Platformでは、Amazon Kinesisからデータをリアルタイムで取り込むことができます。

NOTE
大量のデータを取り込む必要がある場合は、Kinesisのスケール係数を上げる必要があります。 現在、Kinesis アカウントからExperience Platformに取り込むことができるデータの最大量は、1秒あたり4000 レコードです。 より大量のデータをスケールアップして取り込む場合は、Adobe担当者にお問い合わせください。

前提条件

次の節では、Kinesis ソース接続を作成する前に必要な前提条件の設定について詳しく説明します。

アクセスポリシーの設定

Kinesis ストリームでソース接続を作成するには、次の権限が必要です。

  • GetShardIterator
  • GetRecords
  • DescribeStream
  • ListStreams

これらの権限はKinesis コンソールを通じて配置され、資格情報を入力してデータストリームを選択すると、Experience Platformによって確認されます。

次の例は、Kinesis ソース接続の作成に必要な最小アクセス権を示しています。

{
    "Version": "2012-10-17",
    "Statement": [
        {
            "Effect": "Allow",
            "Action": [
                "kinesis:GetShardIterator",
                "kinesis:GetRecords",
                "kinesis:DescribeStream",
                "kinesis:ListStreams"
            ],
            "Resource": [
                "arn:aws:kinesis:us-east-2:901341027596:stream/*"
            ]
        }
    ]
}
プロパティ
説明
kinesis:GetShardIterator
レコードをトラバースするために必要なアクション。
kinesis:GetRecords
特定のオフセット IDまたはシャード IDからレコードを取得するために必要なアクション。
kinesis:DescribeStream
シャード IDの生成に必要なシャード マップを含むストリームに関する情報を返すアクション。
kinesis:ListStreams
UIから選択できる利用可能なストリームを一覧表示するために必要なアクション。

Kinesis データストリームのアクセス制御について詳しくは、次のKinesis ドキュメント ​を参照してください。

イテレータータイプの設定

Kinesisでは、データの読み取り方法の順序を指定できるように、次のイテレーターの種類をサポートしています。

イテレーターの種類
説明
AT_SEQUENCE_NUMBER
特定のシーケンス番号で識別された位置からデータを読み出す。
AFTER_SEQUENCE_NUMBER
データは、特定のシーケンス番号で識別された位置の後から読み取られます。
AT_TIMESTAMP
データは、特定のタイムスタンプによって識別された位置から読み取られます。
TRIM_HORIZON
データは、最も古いデータレコードから読み取られます。
LATEST
データは、最新のデータレコードから読み取られます。

Kinesis UI ソースは現在TRIM_HORIZONのみをサポートしていますが、APIはTRIM_HORIZONLATESTの両方をデータを取得するモードとしてサポートしています。 Experience PlatformがKinesis ソースに使用するデフォルトのイテレータ値はTRIM_HORIZONです。

イテレータの種類について詳しくは、次のKinesis ドキュメント ​を参照してください。

Amazon KinesisをExperience Platformに接続

NOTE
ストリーミングデータフローを作成または更新した後、データの損失やデータの削除の可能性のあるインスタンスを防ぐには、データの取り込みを5分間だけ一時停止する必要があります。

以下のドキュメントでは、APIまたはユーザーインターフェイスを使用してAmazon KinesisをExperience Platformに接続する方法について説明します。

API の使用

UI の使用

recommendation-more-help
experience-platform-help-sources