FME Flow: 2025.0

Streams

Verwenden Sie die Seite "Streams", um Jobs zu verwalten, die kontinuierlich ausgeführt werden sollen. Wenn ein Job als Stream ausgeführt wird, wird er automatisch neu gestartet, unabhängig davon, ob der Job erfolgreich abgeschlossen wurde, fehlgeschlagen ist oder der Server abgestürzt ist oder heruntergefahren wurde.

Von Streams betriebene Workspaces verfügen normalerweise über eine Ereigniswarteschlange oder einen Nachrichtenbroker als Quelle. Nachrichten werden von Transformern wie AzureQueueStorageConnector oder KafkaConnector verarbeitet, die im Modus: Stream ausgeführt werden können. Der Stream ermöglicht Ihnen die Integration und Analyse von Daten in Echtzeit, während sie produziert werden. Im Stream-Modus gibt es keinen Overhead für das Starten und Stoppen von Jobs, was bedeutet, dass eine sehr hohe Datenmenge mit geringer Latenz verarbeitet werden kann.

Hinweis  Es gibt keine Beschränkung für den Typ des Workspaces, den Sie als Stream ausführen können, aber Streams sind für die Verwendung eines Workspaces vorgesehen, der einen auf Modus: Stream eingestellten Transformer enthält, wie AzureQueueStorageConnector oder KafkaConnector. Die Verwendung eines Workspaces, der keinen solchen Transformer enthält, kann zu unerwartetem Verhalten führen, einschließlich einer übermäßigen Protokollierung, die zu Speicherproblemen führt, da der Job nach jedem Ende erneut übermittelt wird.

Streams bieten die folgenden zusätzlichen Vorteile gegenüber der kontinuierlichen Ausführung von Jobs über andere Schnittstellen:

  • Wenn Sie einen Stream erstellen, werden die FME Engines, die Sie zur Ausführung seiner Jobs zuweisen, diesem Stream zugeordnet.
  • Sie können den Verarbeitungsdurchsatz skalieren, indem Sie Jobs aus demselben Workspace gleichzeitig von mehreren Engines ausführen. Die Anzahl der Jobs, die ein Stream ausführt, entspricht der Anzahl der dem Stream zugewiesenen Engines.
    • Hinweis  Wenn die FME Engines, die Sie für den Stream angeben, zu irgendwelchen Warteschlangen gehören, werden sie aus diesen Warteschlangen entfernt, so dass sie dem Stream zugeordnet sind.
  • Sie können einen Stream konfigurieren und ihn dann anhalten.
  • Auf der Seite "Streams" werden alle kontinuierlich ausgeführten Jobs angezeigt, so dass Sie diese bequem an einem Ort verwalten können.

Erste Schritte mit Streams

Um einen Stream zu erstellen, wählen Sie Streams > Stream erstellen. Oder wählen Sie Streams > Streams verwalten und klicken Sie auf Erstellen.

  1. Füllen Sie die folgenden Felder aus:
    • Name: Geben Sie einen Namen für den Stream an.
    • Beschreibung: (Optional) Geben Sie eine aussagekräftige Beschreibung des Streams an, z. B. den Workspace, den er ausführt, und warum er kontinuierlich laufen soll. Verwenden Sie bei Bedarf die Markdown-Werkzeuge.
    • Debugging protokollieren: Wenn aktiviert, werden zusätzliche Informationen in den FME Job Protokolle aufgezeichnet. Diese Einstellung wird am besten verwendet, wenn zuvor ein Fehler aufgetreten ist und Sie weitere Informationen wünschen.
      • Hinweis  Die Option Debugging protokollieren kann das Laufzeitverhalten des Workspaces beeinträchtigen und zu großen Protokolldateien führen.
    • Remote-Stream: Um den Stream auf den Engines eines Remote Engines Service auszuführen, aktivieren Sie dieses Feld und geben Sie den Remote Engines Service an.
      Hinweis  Wenn Sie Streams auf einem Remote Engines Service ausführen, sollten Sie Folgendes beachten:
      • Ein Stream, der mit der FME Flow-Version 2025.0 oder höher erstellt wurde, läuft nicht auf einer Installation von Remote Engines Services-Version 2024.* oder früher.
      • Wenn ein Stream auf einem Remote Engines Service läuft und die primäre FME Flow-Instanz heruntergefahren wird, wird der Remote Engine Service 24 Stunden später heruntergefahren. Sobald die primäre FME Flow-Instanz neu startet und sich mit dem Remote Engines Service verbindet, wird der Stream neu gestartet.
      • Wenn ein Stream auf einem Remote Engines Service läuft, der neu konfiguriert wird (z. B. mit einem anderen Datenbankserver), wird der Stream weiterhin auf dem neu konfigurierten Dienst ausgeführt, solange die hier konfigurierten Einstellungen des Streams weiterhin gelten.
    • Repository: Geben Sie das Repository an, das den Workspace enthält, den Sie kontinuierlich ausführen möchten.
    • Workspace: Geben Sie den Workspace an, der kontinuierlich ausgeführt werden soll.
      • Hinweis  Der Workspace sollte einen auf Modus: Stream eingestellten Transformer enthalten, beispielsweise AzureQueueStorageConnector oder KafkaConnector.
    • Offengelegte Parameter: Wenn der Workspace über offengelegte Parameter verfügt, geben Sie diese hier an.
  2. Click OK.
  3. Es wird eine Seite geöffnet, die die Eigenschaften des von Ihnen erstellten Streams zusammenfasst. Der Stream ist bereit zur Ausführung, sobald Sie FME Engines zur Ausführung der Jobs zuweisen. Wenn Sie nicht wollen, dass der Stream sofort ausgeführt wird, klicken Sie auf Anhalten.
  4. Um FME Engines zur Ausführung der mit dem Stream verbundenen Jobs zuzuweisen, klicken Sie unter "Zugewiesene Engines" auf Verwalten. Wenn Sie einem Stream Engines zuweisen, sollten Sie Folgendes beachten:
    • Durch das Zuweisen mehrerer Engines können Sie den Verarbeitungsdurchsatz skalieren, indem Sie denselben Job gleichzeitig ausführen. Die Anzahl der Jobs, die ein Stream ausführt, entspricht der Anzahl der dem Stream zugewiesenen Engines.
    • Sie können nur Engines zuweisen, die nicht bereits anderen Streams zugewiesen sind.
    • Wenn die FME Engines, die Sie für den Stream angeben, zu irgendwelchen Warteschlangen gehören, werden sie aus diesen Warteschlangen entfernt, so dass sie dem Stream zugeordnet sind.
    • Wenn eine Engine von FME Flow getrennt wird (z.B. wenn ein Rechner, der eine separate FME Engine hostet, abstürzt), geht jeder laufende Job in einen Warteschlangen-Zustand über und wird an die Engine zurückgegeben, sobald sie wieder verfügbar ist.
  5. Geben Sie im Dialogfeld "Engine-Regel verwalten" Folgendes an:
    • Typ : Gibt an, wie dem Stream FME Engines zugewiesen werden:
      • Name: Die Engines werden dem Stream über den Engine-Namen zugewiesen.
      • Eigenschaft: Engines werden dem Stream basierend auf ihren Eigenschaften zugewiesen.
    • Engines: Wenn Typ auf Name gesetzt ist, wählen Sie eine oder mehrere Engines nach Namen aus, um sie dem Stream zuzuweisen.
    • Regel: Wenn Typ auf Eigenschaft gesetzt ist, verwenden Sie boolesche Logik, um die Eigenschaften anzugeben, die bestimmen, wie Engines dem Stream zugewiesen werden.

      • Die folgenden Eigenschaften sind ohne manuelle Eingabe auswählbar:

      • Dynamisch: FME Engines-Lizenztyp ist Dynamisch.
      • Standard: FME Engines-Lizenztyp ist Standard.
      • Physischer Speicher des Engine-Hosts: Menge an RAM auf dem Rechner, der eine FME Engine hostet.
      • Prozessoranzahl des Engine-Hosts: Berechnet als: (Anzahl der CPUs) x (Anzahl der Kerne) x (Anzahl der Hyperthreads) auf dem Rechner, der eine FME Engine hostet.

      Um eine dieser Eigenschaften hinzuzufügen, klicken Sie auf + Regel und wählen Sie sie aus.

      Darüber hinaus können Sie auf der Registerkarte Engines weitere Engine-Eigenschaften hinzufügen, z. B. den Namen oder das Betriebssystem des Host-Rechners. Um der Dropdown-Liste Regel weitere Eigenschaften hinzuzufügen, klicken Sie auf + Eigenschaft erstellen. Geben Sie neben Typ die Option Benutzerdefiniert an und geben Sie eine Eigenschaft genau so ein, wie sie auf der Registerkarte Engines erscheint.

      Sobald Sie eine Eigenschaft angeben, wird die Regel unter dem Dropdown-Menü Regel angezeigt. Um weitere Eigenschaften hinzuzufügen, klicken Sie auf + Regel. Um Eigenschaften in der Regel zu verschachteln, klicken Sie auf + Regelsatz.

      Um beispielsweise eine beliebige Dynamische Engine auf dem Server WHISTLER (eine benutzerdefinierte Eigenschaft) anzugeben, geben Sie Dynamic AND WHISTLER an.

      Klicken Sie abschließend auf OK.

  6. Sobald Sie einem Stream Engines zuweisen, beginnt er zu laufen, sofern Sie ihn nicht vorher angehalten haben. Wenn Sie bereit sind, den Stream auszuführen, klicken Sie auf Start; oder wählen Sie auf der Seite "Streams verwalten" den Stream aus und klicken Sie auf Aktionen > Starten.

Verwalten von Streams

Wählen Sie Streams > Streams verwalten.

So starten, stoppen oder entfernen Sie Streams

Wählen Sie die Streams aus, klicken Sie auf Aktionen, und wählen Sie Starten, Anhalten, bzw. Entfernen.

Wenn ein Stream gestoppt wird, sendet der zugehörige Workspace keine Jobs an den Stream. Alle Jobs, die sich in der Warteschlange befinden oder ausgeführt werden, werden abgebrochen.

So zeigen Sie die laufenden oder in der Warteschlange befindlichen Jobs über einen Stream an

Klicken Sie auf den Stream, um ihn zu öffnen, und scrollen Sie zu Jobs. Klicken Sie auf einen Job, um ihn auf der Seite Jobs zu öffnen.

Tipp Verwenden Sie die Dropdown-Liste Status, um die angezeigten Jobs wie folgt zu filtern:
  • Alle: In der Warteschlange und In Bearbeitung befindliche Jobs.
  • In Bearbeitung: Jobs, die derzeit von einer Engine ausgeführt werden.
  • In der Warteschlange: Jobs, die gesendet, aber noch nicht von einer Engine zur Ausführung abgeholt wurden.

So zeigen Sie alle Engines an, die Streams zugewiesen sind

Sie können alle Engines, die Streams zugewiesen sind, auf der Seite Engines anzeigen.

So ändern Sie die einem Stream zugewiesenen Engines

Klicken Sie auf den Stream, um ihn zu öffnen. Klicken Sie unter "Zugewiesene Engines" auf Verwalten, um Engines zuzuweisen. Neu zugewiesene Engines führen Jobs kurz nach der Zuweisung aus.