[Ultimate]{class="badge positive"}

Amazon Kinesis來源

IMPORTANT
Amazon Kinesis來源可在來源目錄中提供給已購買Real-time Customer Data Platform Ultimate的使用者。

Adobe Experience Platform為AWS、Google Cloud Platform和Azure等雲端提供者提供原生連線。 您可以將資料從這些系統帶入Platform。

雲端儲存空間來源可以將您自己的資料帶入Platform,而不需要下載、格式化或上傳。 內嵌的資料可以格式化為XDM JSON、XDM Parquet或分隔。 流程的每個步驟都會整合至來源工作流程。 Platform可讓您即時從Amazon Kinesis匯入資料。

NOTE
如果您需要擷取大量資料,必須增加Kinesis的縮放因數。 目前,您可以從Kinesis帳戶帶入Platform的最大資料量為每秒4000筆記錄。 若要擴充並擷取較大量的資料,請聯絡您的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