A variável Amazon Kinesis origem está disponível no catálogo de origens para usuários que compraram o Real-time Customer Data Platform Ultimate.
Este tutorial guiará você pelas etapas para se conectar Amazon Kinesis (a seguir designado por "Kinesis") para Experience Platform, usando o Flow Service API.
Este guia requer uma compreensão funcional dos seguintes componentes do Adobe Experience Platform:
As seções a seguir fornecem informações adicionais que você precisará saber para se conectar com êxito Kinesis para a Platform usando o Flow Service API.
A fim de Flow Service para se conectar com o seu Amazon Kinesis você deve fornecer valores para as seguintes propriedades de conexão:
Credencial | Descrição |
---|---|
accessKeyId |
A ID da chave de acesso é metade do par de chaves de acesso usado para autenticar seu Kinesis para a Platform. |
secretKey |
A chave de acesso secreta é a outra metade do par de chaves de acesso usado para autenticar sua Kinesis para a Platform. |
region |
A região de seu Kinesis conta. Consulte o guia sobre adicionar endereços IP à lista de permissões para obter mais informações sobre regiões. |
connectionSpec.id |
A especificação de conexão retorna as propriedades do conector de uma origem, incluindo especificações de autenticação relacionadas à criação das conexões de base e de origem. A variável Kinesis A ID da especificação de conexão é: 86043421-563b-46ec-8e6c-e23184711bf6 . |
Para obter mais informações sobre Kinesis e como gerá-las, consulte esta seção AWS guia sobre gerenciamento de chaves de acesso para usuários do IAM.
Para obter informações sobre como fazer chamadas para APIs da Platform com êxito, consulte o manual em introdução às APIs da Platform.
A primeira etapa na criação de uma conexão de origem é autenticar seu Kinesis origem e gere uma ID de conexão básica. Uma ID de conexão básica permite explorar e navegar pelos arquivos de dentro da origem e identificar itens específicos que você deseja assimilar, incluindo informações sobre os tipos de dados e formatos.
Para criar um ID de conexão base, faça uma solicitação POST ao /connections
ao fornecer sua Kinesis credenciais de autenticação como parte dos parâmetros de solicitação.
Formato da API
POST /connections
Solicitação
curl -X POST \
'https://platform.adobe.io/data/foundation/flowservice/connections' \
-H 'Authorization: Bearer {ACCESS_TOKEN}' \
-H 'x-api-key: {API_KEY}' \
-H 'x-gw-ims-org-id: {ORG_ID}' \
-H 'x-sandbox-name: {SANDBOX_NAME}' \
-H 'Content-Type: application/json' \
-d '{
"name": "Amazon Kinesis connection",
"description": "Connector for Amazon Kinesis",
"providerId": "521eee4d-8cbe-4906-bb48-fb6bd4450033",
"auth": {
"specName": "Aws Kinesis authentication credentials",
"params": {
"accessKeyId": "{ACCESS_KEY_ID}",
"secretKey": "{SECRET_KEY}",
"region": "{REGION}"
}
},
"connectionSpec": {
"id": "86043421-563b-46ec-8e6c-e23184711bf6",
"version": "1.0"
}
}'
Propriedade | Descrição |
---|---|
auth.params.accessKeyId |
A ID da chave de acesso do Kinesis conta. |
auth.params.secretKey |
A chave de acesso secreta para seu Kinesis conta. |
auth.params.region |
A região de seu Kinesis conta. |
connectionSpec.id |
A variável Kinesis ID da especificação de conexão: 86043421-563b-46ec-8e6c-e23184711bf6 |
Resposta
Uma resposta bem-sucedida retorna detalhes da conexão base recém-criada, incluindo seu identificador exclusivo (id
). Essa ID é necessária na próxima etapa para criar uma conexão de origem.
{
"id": "4cb0c374-d3bb-4557-b139-5712880adc55",
"etag": "\"6507cfd8-0000-0200-0000-5e18fc600000\""
}
Uma conexão de origem cria e gerencia a conexão com a origem externa de onde os dados são assimilados. Uma conexão de origem consiste em informações como fonte de dados, formato de dados e a ID da conexão de origem necessária para criar um fluxo de dados. Uma instância de conexão de origem é específica para um locatário e uma organização.
Para criar uma conexão de origem, faça uma solicitação POST ao /sourceConnections
endpoint do Flow Service API.
Formato da API
POST /sourceConnections
Solicitação
curl -X POST \
'https://platform.adobe.io/data/foundation/flowservice/sourceConnections' \
-H 'Authorization: Bearer {ACCESS_TOKEN}' \
-H 'x-api-key: {API_KEY}' \
-H 'x-gw-ims-org-id: {ORG_ID}' \
-H 'x-sandbox-name: {SANDBOX_NAME}' \
-H 'Content-Type: application/json' \
-d '{
"name": "AWS Kinesis source connection",
"description": "A source connection for AWS Kinesis",
"baseConnectionId": "4cb0c374-d3bb-4557-b139-5712880adc55",
"connectionSpec": {
"id": "86043421-563b-46ec-8e6c-e23184711bf6",
"version": "1.0"
},
"data": {
"format": "json"
},
"params": {
"stream": "{STREAM}",
"dataType": "raw",
"reset": "latest"
}
}'
Propriedade | Descrição |
---|---|
name |
O nome da sua conexão de origem. Certifique-se de que o nome da conexão de origem seja descritivo, pois você pode usá-lo para pesquisar informações sobre a conexão de origem. |
description |
Um valor opcional que pode ser fornecido para incluir mais informações sobre a conexão de origem. |
baseConnectionId |
A ID de conexão básica de seu Kinesis que foi gerado na etapa anterior. |
connectionSpec.id |
A ID de especificação de conexão fixa para Kinesis. Essa ID é: 86043421-563b-46ec-8e6c-e23184711bf6 |
data.format |
O formato do Kinesis dados que você deseja assimilar. No momento, o único formato de dados compatível é json . |
params.stream |
O nome do fluxo de dados do qual extrair registros. |
params.dataType |
Esse parâmetro define o tipo de dados que está sendo assimilado. Os tipos de dados compatíveis incluem: raw e xdm . |
params.reset |
Esse parâmetro define como os dados serão lidos. Uso latest para começar a ler os dados mais recentes e use earliest para começar a ler os primeiros dados disponíveis no fluxo. |
Resposta
Uma resposta bem-sucedida retorna o identificador exclusivo (id
) da conexão de origem recém-criada. Essa ID é necessária no próximo tutorial para criar um fluxo de dados.
{
"id": "e96d6135-4b50-446e-922c-6dd66672b6b2",
"etag": "\"66013508-0000-0200-0000-5f6e2ae70000\""
}
Ao seguir este tutorial, você criou um Kinesis conexão de origem usando o Flow Service API. Você pode usar essa ID de conexão de origem no próximo tutorial para crie um fluxo de dados de transmissão usando o Flow Service API.