[Ultimate]{class="badge positive"}

Amazon Kinesis ソース

IMPORTANT
Real-time Customer Data Platform Ultimate を購入したユーザーは、ソースカタログで Amazon Kinesis ソースを利用できます。

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

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

NOTE
大量のデータを取り込む必要がある場合は、Kinesis のスケールファクターを増やす必要があります。 現在、Kinesis アカウントから Platform に取り込めるデータの最大量は、1 秒あたり 4,000 レコードです。 大量のデータをスケールアップして取り込むには、Adobe担当者にお問い合わせください。

前提条件

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

アクセスポリシーの設定

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

  • GetShardIterator
  • GetRecords
  • DescribeStream
  • ListStreams

これらの権限は Kinesis コンソールを通じて整理され、資格情報を入力してデータストリームを選択すると、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 からレコードを取得するために必要なアクション。
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 の使用

recommendation-more-help
337b99bb-92fb-42ae-b6b7-c7042161d089