Amazon Kinesis コネクタ

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

Cloudストレージソースは、ダウンロード、フォーマット、アップロードを必要とせずに、独自のデータをPlatformに取り込むことができます。 取り込んだデータは、XDM JSON、XDM Parket、または区切り形式で形式設定できます。 プロセスの各手順は、Sourcesワークフローに統合されます。 Platform データをリアルタイムで取り込むこ Amazon Kinesis とができます。

IPアドレス許可リスト

IPアドレスのリストは、ソースコネクタを使用する前に許可リストに追加する必要があります。 地域固有のIPアドレスを許可リストに追加できないと、ソースを使用する際にエラーが発生したり、パフォーマンスが低下したりする可能性があります。 詳しくは、IPアドレスの許可リストページを参照してください。

前提条件

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

アクセスポリシーの設定

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

  • GetShardIterator
  • GetRecords
  • DescribeStream
  • ListStreams

これらの権限はKinesisコンソールを介して設定され、資格情報を入力してデータストリームを選択すると、プラットフォームによって確認されます。

次の例は、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の両方をサポートしています。 PlatformがKinesisソースに対して使用するデフォルトのイテレータ値はTRIM_HORIZONです。

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

Amazon KinesisをPlatformに接続

次のドキュメントは、APIまたはユーザーインターフェイスを使用してAmazon KinesisをPlatformに接続する方法に関する情報を提供しています。

APIの使用

UI の使用

このページ