Amazon Kinesis connettore

Adobe Experience Platform fornisce connettività nativa per provider cloud come AWS, Google Cloud Platform e Azure. Puoi inserire i tuoi dati da questi sistemi in Platform.

Le origini di archiviazione cloud possono inserire i tuoi dati in Platform senza dover scaricare, formattare o caricare. I dati acquisiti possono essere formattati come JSON XDM, Parquet XDM o delimitati. Ogni passaggio del processo viene integrato nel flusso di lavoro Origini . Platform consente di inserire dati in tempo Amazon Kinesis reale.

ELENCO CONSENTITI di indirizzo IP

Prima di utilizzare i connettori sorgente, è necessario aggiungere a un elenco consentiti un elenco di indirizzi IP. Se l’utente non aggiunge all’elenco consentiti gli indirizzi IP specifici per l’area geografica, potrebbero verificarsi errori o prestazioni non soddisfacenti durante l’utilizzo delle origini. Per ulteriori informazioni, consulta la pagina elenco consentiti indirizzo IP .

Prerequisiti

La sezione seguente fornisce ulteriori informazioni sulla configurazione dei prerequisiti necessaria per creare una connessione sorgente Kinesis.

Imposta criteri di accesso

Un flusso Kinesis richiede le seguenti autorizzazioni per creare una connessione sorgente:

  • GetShardIterator
  • GetRecords
  • DescribeStream
  • ListStreams

Queste autorizzazioni vengono organizzate attraverso la console Kinesis e controllate da Platform una volta immesse le credenziali e selezionate il flusso di dati.

Nell'esempio seguente vengono visualizzati i diritti di accesso minimi necessari per creare una connessione sorgente 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/*"
            ]
        }
    ]
}
Proprietà Descrizione
kinesis:GetShardIterator Un’azione necessaria per scorrere i record.
kinesis:GetRecords Un'azione necessaria per ottenere i record da un ID offset o condiviso specifico.
kinesis:DescribeStream Un’azione che restituisce informazioni sul flusso, inclusa la mappa condivisa, necessaria per generare un ID condiviso.
kinesis:ListStreams Un’azione necessaria per elencare i flussi disponibili che puoi selezionare dall’interfaccia utente.

Per ulteriori informazioni sul controllo dell'accesso per i flussi di dati Kinesis, consulta il seguente Kinesis document.

Configura il tipo di iteratore

Kinesis supporta i seguenti tipi di iteratore per consentire di specificare l’ordine di lettura dei dati:

Tipo di iteratore Descrizione
AT_SEQUENCE_NUMBER I dati vengono letti a partire da una posizione identificata da un numero di sequenza specifico.
AFTER_SEQUENCE_NUMBER I dati vengono letti a partire dalla posizione identificata da un numero di sequenza specifico.
AT_TIMESTAMP I dati vengono letti a partire da una posizione identificata da un timestamp specifico.
TRIM_HORIZON I dati vengono letti a partire dal record di dati più vecchio.
LATEST I dati vengono letti a partire dal record di dati più recente.

Un’origine Kinesis dell’interfaccia utente supporta attualmente solo TRIM_HORIZON, mentre l’API supporta sia le modalità TRIM_HORIZON che LATEST per ottenere i dati. Il valore iteratore predefinito utilizzato da Platform per l'origine Kinesis è TRIM_HORIZON.

Per ulteriori informazioni sui tipi di iteratore, consulta il seguente Kinesis documento.

Connetti Amazon Kinesis a Platform

La documentazione seguente fornisce informazioni su come connettersi a Amazon Kinesis utilizzando le API o l'interfaccia utente:Platform

Utilizzo delle API

Utilizzo dell’interfaccia

In questa pagina