DocumentaciónExperience PlatformGuía de conectores de origen

Cree una ejecución de flujo para la ingesta bajo demanda utilizando la API Flow Service

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

Creado para:

  • Desarrollador

Las ejecuciones de flujo representan una instancia de ejecución de flujo. Por ejemplo, si un flujo está programado para ejecutarse cada hora a las 9:00, las 10:00 y las 11:00 a.m., tendrá tres instancias de ejecución de flujo. Las ejecuciones de flujo son específicas de su organización particular.

La ingesta bajo demanda permite crear una ejecución de flujo con un flujo de datos determinado. Esto permite a los usuarios crear una ejecución de flujo basada en parámetros determinados y un ciclo de ingesta sin tokens de servicio. La compatibilidad con la ingesta bajo demanda solo está disponible para orígenes por lotes.

Este tutorial explica los pasos para usar la ingesta bajo demanda y crear una ejecución de flujo con la Flow Service API.

TIP
Al reintentar una ejecución de flujo, solo se procesarán los archivos con marcas de tiempo que estén dentro del intervalo de la ejecución original.

Introducción

NOTE
Para crear una ejecución de flujo, primero debe tener el ID de flujo de un flujo de datos programado para una ingesta única.

Este tutorial requiere una comprensión práctica de los siguientes componentes de Adobe Experience Platform:

  • Fuentes: Experience Platform permite la ingesta de datos de varias fuentes al tiempo que le ofrece la capacidad de estructurar, etiquetar y mejorar los datos entrantes mediante los servicios de Experience Platform.
  • Zonas protegidas: Experience Platform proporciona zonas protegidas virtuales que dividen una sola instancia de Experience Platform en entornos virtuales independientes para ayudar a desarrollar y evolucionar aplicaciones de experiencia digital.

Uso de API de Experience Platform

Para obtener información sobre cómo realizar llamadas correctamente a las API de Experience Platform, consulte la guía sobre introducción a las API de Experience Platform.

Crear una ejecución de flujo para un origen basado en tablas

Para crear un flujo para un origen basado en tablas, realice una petición POST a la API Flow Service proporcionando al mismo tiempo el ID del flujo con el que desea crear la ejecución, así como los valores de las columnas hora de inicio, hora de finalización y delta.

TIP
Las fuentes basadas en tablas incluyen las siguientes categorías de fuentes: publicidad, análisis, consentimiento y preferencias, CRM, éxito del cliente, base de datos, automatización de marketing, pagos y protocolos.

Formato de API

POST /runs/

Solicitud

La siguiente solicitud crea una ejecución de flujo para el id. de flujo 3abea21c-7e36-4be1-bec1-d3bad0e3e0de.

NOTE
Solo debe proporcionar deltaColumn al crear la primera ejecución de flujo. Después de eso, deltaColumn será parcheado como parte de la transformación copy en el flujo y será tratado como la fuente de verdad. Cualquier intento de cambiar el valor deltaColumn a través de los parámetros de ejecución de flujo producirá un error.
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
Descripción
flowId
El ID del flujo con el que se creará la ejecución del flujo.
params.startTime
Hora programada en la que comenzará la ejecución del flujo bajo demanda. Este valor se representa en tiempo Unix.
params.windowStartTime
La primera fecha y hora desde la que se recuperarán los datos. Este valor se representa en tiempo Unix.
params.windowEndTime
La fecha y hora en que se recuperarán los datos hasta. Este valor se representa en tiempo Unix.
params.deltaColumn
La columna delta es necesaria para dividir los datos y separar los datos recién ingeridos de los datos históricos. Nota: deltaColumn solo es necesario al crear su primera ejecución de flujo.
params.deltaColumn.name
Nombre de la columna delta.

Respuesta

Una respuesta correcta devuelve los detalles de la ejecución de flujo recién creada, incluida su ejecución única id.

{
    "items": [
        {
            "id": "3fb0418e-1804-45d6-8d56-dd51f05c0baf",
            "etag": "\"1100c53e-0000-0200-0000-627138980000\""
        }
    ]
}
Propiedad
Descripción
id
El ID de la ejecución del flujo recién creada. Consulte la guía de recuperación de especificaciones de flujo para obtener más información sobre las especificaciones de ejecución basadas en tablas.
etag
La versión de recurso de la ejecución de flujo.

Crear una ejecución de flujo para un origen basado en archivos

Para crear un flujo para un origen basado en archivos, realice una petición POST a la API Flow Service y proporcione el ID del flujo con el que desea crear la ejecución y los valores para la hora de inicio y la hora de finalización.

TIP
Las fuentes basadas en archivos incluyen todas las fuentes de almacenamiento en la nube.

Formato de API

POST /runs/

Solicitud

La siguiente solicitud crea una ejecución de flujo para el id. de flujo 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
Descripción
flowId
El ID del flujo con el que se creará la ejecución del flujo.
params.startTime
Hora programada en la que comenzará la ejecución del flujo bajo demanda. Este valor se representa en tiempo Unix.
params.windowStartTime
La primera fecha y hora desde la que se recuperarán los datos. Este valor se representa en tiempo Unix.
params.windowEndTime
La fecha y hora en que se recuperarán los datos hasta. Este valor se representa en tiempo Unix.

Respuesta

Una respuesta correcta devuelve los detalles de la ejecución de flujo recién creada, incluida su ejecución única id.

{
    "items": [
        {
            "id": "3fb0418e-1804-45d6-8d56-dd51f05c0baf",
            "etag": "\"1100c53e-0000-0200-0000-627138980000\""
        }
    ]
}
Propiedad
Descripción
id
El ID de la ejecución del flujo recién creada. Consulte la guía de recuperación de especificaciones de flujo para obtener más información sobre las especificaciones de ejecución basadas en tablas.
etag
La versión de recurso de la ejecución de flujo.

Monitorice las ejecuciones de flujo

Una vez creada la ejecución de flujo, puede monitorizar los datos que se están introduciendo a través de ella para ver información sobre las ejecuciones de flujo, el estado de finalización y los errores. Para supervisar las ejecuciones de flujo mediante la API, consulte el tutorial sobre supervisión de flujos de datos en la API. Para supervisar las ejecuciones de flujo mediante la interfaz de usuario de Experience Platform, consulte la guía sobre supervisión de orígenes y flujos de datos mediante el panel de supervisión.

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