DocumentaçãoExperience PlatformGuia dos conectores de origem

Crie uma execução de fluxo para assimilação sob demanda usando a API Flow Service

Last update: Thu Oct 30 2025 00:00:00 GMT+0000 (Coordinated Universal Time)
  • Tópicos:

Criado para:

  • Desenvolvedor

As execuções de fluxo representam uma instância da execução de fluxo. Por exemplo, se um fluxo estiver agendado para ser executado por hora às 9h00, 10h10 e 11h20, você terá três instâncias de um fluxo em execução. :00:00:00 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.

TIP
A repetição de uma execução de fluxo processará somente arquivos com carimbos de data e hora que se enquadrem na faixa da execução original.

Introdução

NOTE
Para criar uma execução de fluxo, primeiro você deve ter a ID de fluxo de um fluxo de dados programado para assimilação única.

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 Experience Platform.
  • Sandboxes: Experience Platform fornece sandboxes virtuais que particionam uma única instância do Experience Platform em ambientes virtuais separados para ajudar a desenvolver aplicativos de experiência digital.

Uso de APIs do Experience Platform

Para obter informações sobre como fazer chamadas para APIs do Experience Platform com êxito, consulte o manual sobre introdução às APIs do Experience 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 você deseja criar a execução, bem como valores para a coluna de hora de início, hora de término e delta.

TIP
As fontes baseadas em tabela incluem as seguintes categorias de fonte: publicidade, análises, consentimento e preferências, CRMs, sucesso do cliente, banco de dados, automação de marketing, pagamentos e protocolos.

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.

NOTE
Você só precisa fornecer o 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"
          }
      }
  }'
Parâmetro
Descrição
flowId
A ID do fluxo no qual a execução do fluxo será criada.
params.startTime
O horário agendado para o início da execução do fluxo por demanda. Esse valor é representado no horário unix.
params.windowStartTime
A data e a hora a partir das quais os dados serão recuperados. Esse valor é representado no horário unix.
params.windowEndTime
A data e a hora em que os dados serão recuperados. Esse valor é representado no horário unix.
params.deltaColumn
A coluna delta é necessária para particionar os dados e separar os dados recém-assimilados dos dados históricos. Observação: deltaColumn é necessário somente ao criar sua primeira execução de fluxo.
params.deltaColumn.name
O nome da coluna delta.

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\""
        }
    ]
}
Propriedade
Descrição
id
A ID da execução do fluxo recém-criado. Consulte o guia em recuperando especificações de fluxo para obter mais informações sobre especificações de execução baseadas em tabela.
etag
A versão do recurso da execução do fluxo.

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.

TIP
As fontes baseadas em arquivo incluem todas as fontes de armazenamento na nuvem.

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"
      }
  }'
Parâmetro
Descrição
flowId
A ID do fluxo no qual a execução do fluxo será criada.
params.startTime
O horário agendado para o início da execução do fluxo por demanda. Esse valor é representado no horário unix.
params.windowStartTime
A data e a hora a partir das quais os dados serão recuperados. Esse valor é representado no horário unix.
params.windowEndTime
A data e a hora em que os dados serão recuperados. Esse valor é representado no horário unix.

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\""
        }
    ]
}
Propriedade
Descrição
id
A ID da execução do fluxo recém-criado. Consulte o guia em recuperando especificações de fluxo para obter mais informações sobre especificações de execução baseadas em tabela.
etag
A versão do recurso da execução do fluxo.

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 Experience Platform, consulte o manual sobre fluxos de dados de fontes de monitoramento usando o painel de monitoramento.

recommendation-more-help
337b99bb-92fb-42ae-b6b7-c7042161d089