DokumentationExperience PlatformAnleitung zu Quell-Connectoren

Erstellen einer Flussausführung für die On-Demand-Aufnahme mithilfe der Flow Service-API

Last update: Mon Dec 30 2024 00:00:00 GMT+0000 (Coordinated Universal Time)
  • Themen:

Erstellt für:

  • Entwickler

Flussausführungen stellen eine Instanz der Flussausführung dar. Beispiel: Wenn ein Fluss so geplant ist, dass er stündlich um 9:00 Uhr, um 10:00 Uhr und um 11:00 Uhr ausgeführt wird, gibt es drei Instanzen eines Flussdurchgangs. Flussausführungen sind spezifisch für Ihre bestimmte Organisation.

Die On-Demand-Aufnahme bietet Ihnen die Möglichkeit, eine Flussausführung für einen bestimmten Datenfluss zu erstellen. Auf diese Weise können Ihre Benutzerinnen und Benutzer ohne Service-Token eine Flussausführung erstellen, die auf bestimmten Parametern basiert, und einen Aufnahmezyklus erstellen. Die On-Demand-Aufnahme wird nur für Batch-Quellen unterstützt.

In diesem Tutorial werden die Schritte zur Verwendung der On-Demand-Aufnahme und zur Erstellung einer Flussausführung mithilfe der Flow Service API beschrieben.

Erste Schritte

NOTE
Um eine Flussausführung zu erstellen, müssen Sie zunächst über die Fluss-ID eines Datenflusses verfügen, der für die einmalige Aufnahme geplant ist.

Dieses Tutorial setzt ein Grundverständnis der folgenden Komponenten von Adobe Experience Platform voraus:

  • Quellen: Experience Platform ermöglicht die Aufnahme von Daten aus verschiedenen Quellen und bietet Ihnen die Möglichkeit, die eingehenden Daten mithilfe von Platform-Services zu strukturieren, zu kennzeichnen und anzureichern.
  • Sandboxes: Experience Platform bietet virtuelle Sandboxes, die eine einzelne Platform-Instanz in separate virtuelle Umgebungen unterteilen, damit Sie Programme für digitale Erlebnisse entwickeln und weiterentwickeln können.

Verwenden von Platform-APIs

Informationen darüber, wie Sie Platform-APIs erfolgreich aufrufen können, finden Sie im Handbuch unter Erste Schritte mit Platform-APIs.

Erstellen einer Flussausführung für eine tabellenbasierte Quelle

Um einen Fluss für eine tabellenbasierte POST zu erstellen, stellen Sie eine Flussanfrage an die Flow Service-API. Geben Sie dabei die ID des Flusses an, für den Sie die Ausführung erstellen möchten, sowie Werte für Startzeit, Endzeit und Deltaspalte.

TIP
Zu den tabellenbasierten Quellen gehören die folgenden Quellkategorien: Werbung, Analysen, Einverständnis und Voreinstellungen, CRMs, Kundenerfolg, Datenbank, Marketing-Automatisierung, Zahlungen und Protokolle.

API-Format

POST /runs/

Anfrage

Die folgende Anfrage erstellt eine Flussausführung für die Fluss-ID 3abea21c-7e36-4be1-bec1-d3bad0e3e0de.

NOTE
Sie müssen die deltaColumn nur beim Erstellen Ihrer ersten Flussausführung angeben. Danach werden deltaColumn als Teil copy Transformation im Fluss gepatcht und als Quelle der Wahrheit behandelt. Jeder Versuch, den deltaColumn über die Flussausführungsparameter zu ändern, führt zu einem Fehler.
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"
          }
      }
  }'
Parameter
Beschreibung
flowId
Die ID des Flusses, für den die Flussausführung erstellt wird.
params.startTime
Der geplante Zeitpunkt, zu dem die Ausführung des On-Demand-Flusses beginnt. Dieser Wert wird in Unix-Zeit dargestellt.
params.windowStartTime
Das früheste Datum und die früheste Uhrzeit, von dem/der die Daten abgerufen werden. Dieser Wert wird in Unix-Zeit dargestellt.
params.windowEndTime
Datum und Uhrzeit, zu der die Daten abgerufen werden. Dieser Wert wird in Unix-Zeit dargestellt.
params.deltaColumn
Die Delta-Spalte ist erforderlich, um die Daten zu unterteilen und neu aufgenommene Daten von historischen Daten zu trennen. Hinweis: Die deltaColumn wird nur beim Erstellen der ersten Flussausführung benötigt.
params.deltaColumn.name
Der Name der Delta-Spalte.

Antwort

Eine erfolgreiche Antwort gibt die Details der neu erstellten Flussausführung zurück, einschließlich der eindeutigen id.

{
    "items": [
        {
            "id": "3fb0418e-1804-45d6-8d56-dd51f05c0baf",
            "etag": "\"1100c53e-0000-0200-0000-627138980000\""
        }
    ]
}
Eigenschaft
Beschreibung
id
Die ID der neu erstellten Flussausführung. Weitere Informationen zu tabellenbasierten finden SieHandbuch unter Abrufen von Flussspezifikationen .
etag
Die Ressourcenversion der Flussausführung.

Erstellen einer Flussausführung für eine dateibasierte Quelle

Um einen Fluss für eine dateibasierte POST zu erstellen, stellen Sie eine Flussanfrage an die Flow Service-API. Geben Sie dabei die ID des Flusses an, für den Sie den Durchlauf erstellen möchten, sowie die Werte für Startzeit und Endzeit.

TIP
Dateibasierte Quellen umfassen alle Cloud-Speicherquellen.

API-Format

POST /runs/

Anfrage

Die folgende Anfrage erstellt eine Flussausführung für die Fluss-ID 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"
      }
  }'
Parameter
Beschreibung
flowId
Die ID des Flusses, für den die Flussausführung erstellt wird.
params.startTime
Der geplante Zeitpunkt, zu dem die Ausführung des On-Demand-Flusses beginnt. Dieser Wert wird in Unix-Zeit dargestellt.
params.windowStartTime
Das früheste Datum und die früheste Uhrzeit, von dem/der die Daten abgerufen werden. Dieser Wert wird in Unix-Zeit dargestellt.
params.windowEndTime
Datum und Uhrzeit, zu der die Daten abgerufen werden. Dieser Wert wird in Unix-Zeit dargestellt.

Antwort

Eine erfolgreiche Antwort gibt die Details der neu erstellten Flussausführung zurück, einschließlich der eindeutigen id.

{
    "items": [
        {
            "id": "3fb0418e-1804-45d6-8d56-dd51f05c0baf",
            "etag": "\"1100c53e-0000-0200-0000-627138980000\""
        }
    ]
}
Eigenschaft
Beschreibung
id
Die ID der neu erstellten Flussausführung. Weitere Informationen zu tabellenbasierten finden SieHandbuch unter Abrufen von Flussspezifikationen .
etag
Die Ressourcenversion der Flussausführung.

Überwachen von Flussausführungen

Nachdem Ihr Flussvorgang erstellt wurde, können Sie die Daten überwachen, die darin aufgenommen werden, um Informationen zu Flussausführungen, Abschlussstatus und Fehlern anzuzeigen. Informationen zum Überwachen Ihrer Datenflüsse mithilfe der API finden Sie im Tutorial Überwachen von Datenflüssen in der API. Informationen zum Überwachen Ihrer Flussausführungen mit der Platform-Benutzeroberfläche finden Sie im Handbuch Überwachen von Quelldatenflüssen mithilfe des Überwachungs-Dashboards.

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