Créez une exécution de flux pour l’ingestion à la demande à l’aide du Flow Service API

Les exécutions de flux représentent une instance d’exécution de flux. Par exemple, si un flux est planifié pour s’exécuter toutes les heures à 9 h, 10 h et 11 h, il y a trois instances d’un flux. Les exécutions de flux sont spécifiques à votre organisation.

L’ingestion à la demande vous permet de créer un flux exécuté sur un flux donné. Cela permet à vos utilisateurs de créer une exécution de flux, en fonction de paramètres donnés, et de créer un cycle d’ingestion, sans jetons de service. La prise en charge de l’ingestion sur demande est disponible uniquement pour les sources par lots.

Ce tutoriel décrit les étapes à suivre pour utiliser l’ingestion à la demande et créer une exécution de flux à l’aide de la fonction Flow Service API.

Prise en main

Ce tutoriel nécessite une compréhension du fonctionnement des composants suivants d’Adobe Experience Platform :

Utiliser les API Platform

Pour plus d’informations sur la manière d’effectuer des appels vers les API Platform, consultez le guide Prise en main des API Platform.

Création d’une exécution de flux pour une source basée sur un tableau

Pour créer un flux pour une source basée sur un tableau, envoyez une requête de POST au Flow Service API tout en fournissant l’identifiant du flux sur lequel vous souhaitez créer l’exécution, ainsi que les valeurs des colonnes heure de début, heure de fin et delta.

Format d’API

POST /runs/

Requête

La requête suivante crée une exécution de flux pour l’ID de flux. 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",
          "deltaColumn": {
              "name": "DOB"
          }
      }
  }'

Réponse

Une réponse réussie renvoie les détails de l’exécution de flux nouvellement créée, y compris son exécution unique. id.

{
    "items": [
        {
            "id": "3fb0418e-1804-45d6-8d56-dd51f05c0baf",
            "etag": "\"1100c53e-0000-0200-0000-627138980000\""
        }
    ]
}

Création d’une exécution de flux pour une source basée sur des fichiers

Pour créer un flux pour une source basée sur un fichier, envoyez une requête de POST au Flow Service API tout en fournissant l’identifiant du flux sur lequel vous souhaitez créer l’exécution et les valeurs pour l’heure de début et l’heure de fin.

Format d’API

POST /runs/

Requête

La requête suivante crée une exécution de flux pour l’ID de flux. 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"
      }
  }'

Réponse

Une réponse réussie renvoie les détails de l’exécution de flux nouvellement créée, y compris son exécution unique. id.

{
    "items": [
        {
            "id": "3fb0418e-1804-45d6-8d56-dd51f05c0baf",
            "etag": "\"1100c53e-0000-0200-0000-627138980000\""
        }
    ]
}

Surveillance des exécutions de flux

Une fois l’exécution de flux créée, vous pouvez surveiller les données qui sont ingérées par celle-ci pour afficher des informations sur les exécutions de flux, l’état d’achèvement et les erreurs. Pour surveiller les exécutions de flux à l’aide de l’API, consultez le tutoriel sur surveillance des flux de données dans l’API. Pour surveiller les exécutions de flux à l’aide de l’interface utilisateur de Platform, consultez le guide sur surveillance des flux de données des sources à l’aide du tableau de bord de surveillance.