Crie uma execução de fluxo para assimilação sob demanda usando a API Flow Service
As execuções de fluxo representam uma instância da execução de fluxo. Por exemplo, se um fluxo estiver programado para ser executado por hora às 9h, 10h e 11h, você terá três instâncias de um fluxo em execução. As execuções de fluxo são específicas para sua organização específica.
A assimilação sob demanda oferece a capacidade de criar uma execução de fluxo em relação a um determinado fluxo de dados. Isso permite que seus usuários criem uma execução de fluxo, com base em determinados parâmetros, e criem um ciclo de assimilação, sem tokens de serviço. O suporte para assimilação sob demanda está disponível somente para origens em lote.
Este tutorial aborda as etapas sobre como usar a assimilação sob demanda e criar uma execução de fluxo usando a Flow Service API.
Introdução
Este tutorial requer que você tenha uma compreensão funcional dos seguintes componentes do Adobe Experience Platform:
- Fontes: Experience Platform permite que os dados sejam assimilados de várias fontes e fornece a capacidade de estruturar, rotular e aprimorar os dados recebidos usando os serviços do Platform.
- Sandboxes: Experience Platform fornece sandboxes virtuais que particionam uma única instância do Platform em ambientes virtuais separados para ajudar a desenvolver aplicativos de experiência digital.
Uso de APIs da plataforma
Para obter informações sobre como fazer chamadas para APIs da Platform com êxito, consulte o manual sobre introdução às APIs da Platform.
Criar uma execução de fluxo para uma origem baseada em tabela
Para criar um fluxo para uma origem baseada em tabela, faça uma solicitação POST para a API Flow Service enquanto fornece a ID do fluxo para o qual deseja criar a execução, bem como valores para a coluna de hora de início, hora de término e delta.
Formato da API
POST /runs/
Solicitação
A solicitação a seguir cria uma execução de fluxo para a ID de fluxo 3abea21c-7e36-4be1-bec1-d3bad0e3e0de
.
deltaColumn
ao criar sua primeira execução de fluxo. Depois disso, deltaColumn
será corrigido como parte da transformação de copy
no fluxo e será tratado como a fonte da verdade. Qualquer tentativa de alterar o valor deltaColumn
por meio dos parâmetros de execução de fluxo resultará em um erro.curl -X POST \
'https://platform.adobe.io/data/foundation/flowservice/runs' \
-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 '{
"flowId": "3abea21c-7e36-4be1-bec1-d3bad0e3e0de",
"params": {
"startTime": "1663735590",
"windowStartTime": "1651584991",
"windowEndTime": "16515859567",
"deltaColumn": {
"name": "DOB"
}
}
}'
flowId
params.startTime
params.windowStartTime
params.windowEndTime
params.deltaColumn
deltaColumn
é necessário somente ao criar sua primeira execução de fluxo.params.deltaColumn.name
Resposta
Uma resposta bem-sucedida retorna os detalhes da execução de fluxo recém-criada, incluindo sua execução exclusiva id
.
{
"items": [
{
"id": "3fb0418e-1804-45d6-8d56-dd51f05c0baf",
"etag": "\"1100c53e-0000-0200-0000-627138980000\""
}
]
}
id
etag
Criar uma execução de fluxo para uma origem baseada em arquivo
Para criar um fluxo para uma origem baseada em arquivo, faça uma solicitação POST para a API Flow Service enquanto fornece a ID do fluxo com a qual você deseja criar a execução e os valores para a hora de início e de término.
Formato da API
POST /runs/
Solicitação
A solicitação a seguir cria uma execução de fluxo para a ID de fluxo 3abea21c-7e36-4be1-bec1-d3bad0e3e0de
.
curl -X POST \
'https://platform.adobe.io/data/foundation/flowservice/runs' \
-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 '{
"flowId": "3abea21c-7e36-4be1-bec1-d3bad0e3e0de",
"params": {
"startTime": "1663735590",
"windowStartTime": "1651584991",
"windowEndTime": "16515859567"
}
}'
flowId
params.startTime
params.windowStartTime
params.windowEndTime
Resposta
Uma resposta bem-sucedida retorna os detalhes da execução de fluxo recém-criada, incluindo sua execução exclusiva id
.
{
"items": [
{
"id": "3fb0418e-1804-45d6-8d56-dd51f05c0baf",
"etag": "\"1100c53e-0000-0200-0000-627138980000\""
}
]
}
id
etag
Monitore as execuções de fluxo
Após a criação da execução do fluxo, é possível monitorar os dados que estão sendo assimilados por meio dela para ver informações sobre execuções de fluxo, status de conclusão e erros. Para monitorar suas execuções de fluxo usando a API, consulte o tutorial sobre monitoramento de fluxos de dados na API. Para monitorar suas execuções de fluxo usando a interface do usuário da Platform, consulte o manual sobre fluxos de dados de fontes de monitoramento usando o painel de monitoramento.