Amazon Kinesis bron

Last update: Mon Nov 13 2023 00:00:00 GMT+0000 (Coordinated Universal Time)

Onderwerpen:

Gemaakt voor:

Ontwikkelaar

IMPORTANT

De Amazon Kinesis De bron is in de broncatalogus beschikbaar voor gebruikers die Real-time Customer Data Platform Ultimate hebben aangeschaft.

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

Opslagbronnen in de cloud kunnen uw eigen gegevens in Platform zonder dat het downloaden, opmaken of uploaden nodig is. Ingebedde gegevens kunnen worden opgemaakt als XDM JSON, XDM Parquet, of afgebakend. Elke stap van het proces is geïntegreerd in het Bronwerkschema. Platform stelt u in staat gegevens over te brengen van Amazon Kinesis in real time.

NOTE

De schaalfactor voor Kinesis moet worden verhoogd als u gegevens met een hoog volume moet innemen. Het maximale gegevensvolume dat u van uw Kinesis account aan Platform is 4000 records per seconde. Neem contact op met uw Adobe als u de schaal wilt verhogen en meer gegevens over het volume wilt invoeren.

Vereisten

In het volgende gedeelte vindt u meer informatie over de vereiste configuratie voordat u een Kinesis bronverbinding.

Toegangsbeleid instellen

A Kinesis voor het maken van een bronverbinding zijn de volgende machtigingen vereist:

GetShardIterator
GetRecords
DescribeStream
ListStreams

Deze machtigingen worden via de Kinesis -console en worden gecontroleerd door 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.

{
    "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 over het beheren van toegang voor Kinesis gegevensstromen, zie het volgende Kinesis document.

Type iterator configureren

Kinesis De volgende iteratortypen worden ondersteund, zodat 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.

A Kinesis UI-bron momenteel alleen ondersteund TRIM_HORIZON, terwijl de API beide ondersteunt TRIM_HORIZON en LATEST als modi om gegevens op te halen. De standaarditeratorwaarde die Platform gebruikt voor de Kinesis bron is TRIM_HORIZON.

Raadpleeg de volgende secties voor meer informatie over iteratortypen Kinesis document.

Verbinden Amazon Kinesis tot Platform

In de onderstaande documentatie vindt u informatie over de verbinding Amazon Kinesis tot Platform API's of de gebruikersinterface gebruiken:

API's gebruiken

UI gebruiken

recommendation-more-help

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