Amazon Kinesis bron

Last update: Tue Jun 10 2025 00:00:00 GMT+0000 (Coordinated Universal Time)

Onderwerpen:

Gemaakt voor:

Ontwikkelaar

IMPORTANT

De Amazon Kinesis -bron is in de broncatalogus beschikbaar voor gebruikers die Real-Time CDP Ultimate hebben aangeschaft.
U kunt nu de Amazon Kinesis -bron gebruiken wanneer u Adobe Experience Platform uitvoert op Amazon Web Services (AWS). Experience Platform die op AWS wordt uitgevoerd, is momenteel beschikbaar voor een beperkt aantal klanten. Meer over de gesteunde infrastructuur van Experience Platform leren, zie het multi-wolkenoverzicht van Experience Platform.

Adobe Experience Platform biedt native connectiviteit voor cloudproviders zoals AWS, Google Cloud Platform en Azure . U kunt uw gegevens van deze systemen overbrengen naar Experience Platform .

Met bronnen voor cloudopslag kunt u uw eigen gegevens overbrengen naar Experience Platform zonder dat u deze hoeft te downloaden, opmaken of uploaden. Ingebedde gegevens kunnen worden opgemaakt als XDM JSON, XDM Parquet, of afgebakend. Elke stap van het proces is geïntegreerd in het Bronwerkschema. Met Experience Platform kunt u gegevens van Amazon Kinesis in real-time invoeren.

NOTE

De schaalfactor voor Kinesis moet worden verhoogd als u gegevens met een hoog volume wilt invoeren. Het maximale gegevensvolume dat u van uw Kinesis -account naar Experience Platform kunt verzenden, is momenteel 4000 records per seconde. Neem contact op met uw Adobe-vertegenwoordiger als u de schaal wilt verhogen en meer gegevens wilt invoeren.

Vereisten

In de volgende sectie vindt u meer informatie over de vereiste configuratie voordat u een Kinesis bronverbinding kunt maken.

Toegangsbeleid instellen

Een Kinesis -stream vereist de volgende machtigingen om een bronverbinding te maken:

GetShardIterator
GetRecords
DescribeStream
ListStreams

Deze machtigingen worden gerangschikt via de Kinesis -console en worden gecontroleerd door Experience Platform nadat u uw referenties hebt ingevoerd en uw gegevensstroom hebt geselecteerd.

In het onderstaande voorbeeld worden de minimale toegangsrechten weergegeven die vereist zijn om een Kinesis bronverbinding te maken.

{
    "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/*"
            ]
        }
    ]
}

Eigenschap

Beschrijving

kinesis:GetShardIterator

Een handeling die is vereist om records te doorlopen.

kinesis:GetRecords

Een handeling die is vereist om records op te halen van een specifieke offset- of gedeelde id.

kinesis:DescribeStream

Een actie die informatie betreffende de stroom met inbegrip van de kaart terugkeert, die nodig is om een gedeelde identiteitskaart te produceren.

kinesis:ListStreams

Een handeling die is vereist om beschikbare streams weer te geven die u kunt selecteren in de gebruikersinterface.

Voor meer informatie bij het controleren van toegang voor Kinesis gegevensstromen, zie het volgende Kinesis document.

Type iterator configureren

Kinesis ondersteunt de volgende iteratortypen waarmee u de volgorde kunt opgeven waarin de gegevens worden gelezen:

Type iterator

Beschrijving

AT_SEQUENCE_NUMBER

De gegevens worden gelezen vanaf een positie die wordt aangeduid met een specifiek volgnummer.

AFTER_SEQUENCE_NUMBER

De gegevens worden gelezen vanaf de positie die wordt bepaald door een specifiek volgnummer.

AT_TIMESTAMP

De gegevens worden gelezen vanaf een positie die wordt aangeduid met een specifiek tijdstempel.

TRIM_HORIZON

De gegevens worden gelezen vanaf de oudste gegevensrecord.

LATEST

De gegevens worden gelezen vanaf de meest recente gegevensrecord.

Een Kinesis UI-bron ondersteunt momenteel alleen TRIM_HORIZON , terwijl de API zowel TRIM_HORIZON als LATEST as-modi ondersteunt om gegevens op te halen. De standaardwaarde van de iterator die Experience Platform gebruikt voor de Kinesis -bron is TRIM_HORIZON .

Voor meer informatie over iteratortypes, zie het volgende Kinesis document.

Verbinden Amazon Kinesis met Experience Platform

NOTE

Nadat u een streaming gegevensstroom hebt gemaakt of bijgewerkt, moet u de gegevensinvoer kort na vijf minuten pauzeren om te voorkomen dat gegevens verloren gaan of dat gegevens verloren gaan.

In de onderstaande documentatie vindt u informatie over het tot stand brengen van een verbinding tussen Amazon Kinesis en Experience Platform via API's of de gebruikersinterface:

API's gebruiken

UI gebruiken

recommendation-more-help

337b99bb-92fb-42ae-b6b7-c7042161d089