Warteschlangensteuerung

Bedenken Sie, dass Sie alleworkspaces im RepositoryProbenauf zwei bestimmten FME-Engines.

Erstellen Sie zunächst eineWarteschlange, benanntSamples_Queue , das die an die angegebenen Engines weitergeleiteten Jobs enthält. Erstellen Sie als Nächstes eineJob-Routing-Regel die Jobs von derProbenRepository zu Samples_Queue:

• Typ:Archiv,
• Repositorien:Proben
• Warteschlange:Samples_Queue

Erstellen Sie abschließend eineEngine-Zuordnungsregel die Engines zur Ausführung von Jobs zuweist, die anSamples_Queue:

• Typ:Name
• Motoren: Wählen Sie die beiden FME-Engines aus, die Sie der Warteschlange zuweisen möchtenSamples_Queue.
• Warteschlangen:Samples_Queue

Bedenken Sie, dass Sie Ihre verarbeitungsintensivsten Jobs auf FME-Engines auslagern möchten, die auf einem separaten Server mit dem Namen „FMEFlow2“ installiert sind. Auf derWorkspaceS Seite, in einzelnen Repositories, können Sie einige nützliche Leistungsstatistiken sehen fürworkspaces, die bis heute oder seit der Aktualisierung der Statistiken Jobs ausgeführt haben. Sie entscheiden sich für die Auslagerung von Jobs auf diesen Server basierend auf einer Kombination ausDurchschnittlicher CPU-Prozentsatz >80Und Durchschnittliche CPU-Zeit >1 Stunde.

Zuerst erstellen Sie eine separateWarteschlange, benannt Warteschlange_FMEFlow2, das die Jobs enthält, die an die Engines auf FMEFlow2 weitergeleitet werden.

Als nächstes erstellen Sie eineJob-Routing-Regel das Folgendes angibt: 1) Ihre Job-Routing-Kriterien – in diesem Fall%CPU > 80 % UND CPU-Zeit > 1 Stunde; und 2) Jobs, die diese Kriterien erfüllen, werden zugewiesen anWarteschlange_FMEFlow2. (Beachten Sie, dass Sie eine Job-Routing-Regel nur einer Warteschlange zuweisen können. Einer Warteschlange können jedoch mehrere Job-Routing-Regeln zugewiesen werden.)

Schließlich erstellen Sie eineEngine-Zuordnungsregel das angibt, welche Engines Jobs ausführen, die weitergeleitet werden anWarteschlange_FMEFlow2. Sie können die Motoren nach Namen angeben. Eine bessere Option besteht jedoch darin, die Engines basierend auf einer gemeinsamen Systemeigenschaft anzugeben, die allen auf dem Server FMEFlow2 installierten Engines zugewiesen ist. Auf derMotoren Auf der Registerkarte „Systemeigenschaften“ können Sie sehen, dass eine der Ihren FME-Engines zugewiesenen Systemeigenschaften der Name des Servers ist, auf dem sie installiert sind. In diesem Fall wird einigen Ihrer Engines die EigenschaftFMEFlow2. Wenn Sie auf diese Weise weitere Engines zu FMEFlow2 hinzufügen, können diese auch Jobs in der Warteschlange ausführen, ohne sie explizit zu dieser Regel hinzuzufügen. (Beachten Sie, dass einer Engine-Zuweisungsregel mehr als eine Warteschlange zugewiesen werden kann.)

1. Registerkarte „Warteschlangen“: Erstellen Sie eine Warteschlange

1. Auf derWarteschlangenaufErstellen.
2. Geben Sie einenNameUndBeschreibung(optional) für die Warteschlange.
3. Weisen Sie einenPriorität. Die höchste Priorität ist 10 und die niedrigste Priorität ist 1. Warteschlangen mit höherer Priorität übermitteln Jobanforderungen je nach Zeitpunkt vor Warteschlangen mit niedrigerer Priorität.
4. KlickenOK.

2. Registerkarte „Job Routing Rules“: Weisen Sie der Warteschlange eine Regel zu

So weisen Sie einer vorhandenen Regel eine Warteschlange zu:

1. Öffnen Sie dasJob-Routing-Regeln und klicken Sie auf eine Regel, um sie zu öffnen.
2. ImWarteschlangeAktualisieren Sie im Feld die Warteschlange, für die diese Regel gilt.
3. KlickenOK.

So weisen Sie einer Warteschlange eine neue Regel zu:

1. Öffnen Sie dasJob-Routing-Regeln und klicken Sie aufErstellen.
2. Geben Sie auf der Seite „Auftragsroutingregel erstellen“ Folgendes an:
   • ANamefür die Regel.
   • Typ:
     • Eigenschaften: Die Warteschlange verarbeitet Aufträge, die die Anforderungen der angegebenenKennzahlen zur Arbeitsleistung oder andere Eigenschaften, einschließlich einer oder mehrerer der folgenden:
       Für Eigenschaften erweitern

       • % CPU: Jobs, derenDurchschnittlicher CPU-Prozentsatz die in der Regel festgelegten Anforderungen erfüllt.
       • CPU-Zeit: Jobs, derenDurchschnittliche CPU-Zeit die in der Regel festgelegten Anforderungen erfüllt.
       • Verstrichene Zeit: Jobs, derenDurchschnittlich verstrichene Zeit die in der Regel festgelegten Anforderungen erfüllt.
       • Maximale Speicherauslastung: Jobs, derenDurchschnittliche maximale Speichernutzung die in der Regel festgelegten Anforderungen erfüllt.
       • Archiv: Jobs, die ausworkspaces in einem oder mehreren angegebenenRepositorien.
       • Workspace: Aufträge von einem oder mehreren angegebenenworkspaceS. Geben Sie das Repository an, undworkspace.
       • Quellentyp: Jobs, die von einem oder mehreren angegebenenFME Flow Mechanismen.
       • Quellenname: Jobs, die von einem oder mehreren benanntenFME Flow Elemente, beispielsweise der Name eines Zeitplans.
       • Benutzername: Jobs, die unter der angegebenenBenutzername. Weitere Informationen zurBenutzernameEigentum, sieheJobs (Abgeschlossen, In der Warteschlange oder Wird ausgeführt).
       • Benutzerrolle: Jobs, die unter einem beliebigenBenutzernameZugehörigkeit zu einem oder mehreren bestimmtenRollen. Weitere Informationen zurBenutzernameEigentum, sieheJobs (Abgeschlossen, In der Warteschlange oder Wird ausgeführt).

       Geben Sie mit Boolescher Logik die Parameter desRegel. Um der Regel Parameter hinzuzufügen, klicken Sie auf+ Regel. Um Parameter in der Regel zu verschachteln, klicken Sie auf+ Regelwerk.

       Kombinieren Sie zum BeispielDurchschnittlicher CPU-Prozentsatz > 80 und Durchschnittliche CPU-Zeit > 1 Stunde, bitte angeben% CPU > 80 % UND CPU-Zeit > 1 Stunde.

     NotizDamit eine metrikbasierte Job-Routing-Regel wirksam wird, muss dieworkspace muss seit der ersten Erfassung oder Zurücksetzung der Statistiken oft genug ausgeführt worden sein, um eine statistisch signifikante Stichprobe zu generieren. Die erforderliche Mindestanzahl an Jobs, die für eine aussagekräftige Stichprobe ausgeführt werden müssen, kann je nach Variabilität der Daten und dem von der Regel geforderten Genauigkeitsgrad (z. B. Minuten oder Sekunden) zwischen 30 und 100 variieren. Je variabler die Eingabedaten sind und je höher der Grad an Genauigkeit dieser Daten sein muss, desto größer muss die Stichprobengröße sein. Wenn eine Job-Routing-Regel nicht auf eine statistisch signifikante Stichprobe ausgeführter Jobs verweist, wird die nächste anwendbare Regel entsprechend der Priorität wirksam oder der Job wird an die Standardwarteschlange weitergeleitet.
     • Archiv: Die Warteschlange verarbeitet Aufträge, die ausworkspaces in einem oder mehreren angegebenenRepositorien.
     NotizUm das Repository mit anderen Kriterien zu kombinieren, geben Sie anTyp:Eigenschaften,Regel : Archiv, geben Sie ein Repository an und fügen Sie dann weitere hinzu Eigenschaften.
   • Warteschlange: Wenden Sie diese Regel auf eine Warteschlange an.
   • Ermöglicht: Standardmäßig ist die Regel aktiviert. Dies bedeutet, dass nachfolgende Jobs, die die Anforderungen der Regel erfüllen, an die angegebene Adresse weitergeleitet werden.Warteschlange. Wenn diese Option deaktiviert ist, werden Jobs, die ansonsten basierend auf dieser Regel an diese Warteschlange weitergeleitet würden, stattdessen nach Priorität an die nächste anwendbare Regel weitergeleitet (siehePriorisierung von Job-Routing-Regeln, unten). Wenn keine anderen Regeln gelten, werden Jobs an die Standardwarteschlange weitergeleitet.
3. KlickenOK.

3. Registerkarte „Engine-Zuweisungsregeln“: Geben Sie an, wie Engines Warteschlangen zugewiesen werden

Eine Reihe von Engine-Zuweisungsregeln bestimmt, wie Engines Warteschlangen zugewiesen werden. Sie können Warteschlangen bestimmten Engines nach Namen oder basierend auf den Eigenschaften von Engines und Warteschlangen zuweisen.

So fügen Sie einer vorhandenen Engine-Zuweisungsregel eine Warteschlange hinzu:

1. Öffnen Sie dasRegeln für die Engine-Zuweisung Tab.
2. Klicken Sie auf die Regel, zu der Sie die Warteschlange hinzufügen möchten.
3. Fügen Sie auf der Seite „Editing Engine Assignment Rule“ die Warteschlange zurWarteschlangenFeld.
4. KlickenOK.

So fügen Sie einer neuen Regel eine Warteschlange hinzu

1. Öffnen Sie dasRegeln für die Engine-Zuweisung und klicken Sie aufErstellen.
2. Geben Sie auf der Seite „Engine-Zuweisungsregel erstellen“ Folgendes an:
   • ANamefür die Regel.
   • Typ:
     • Eigentum: Engines werden basierend auf den Eigenschaften von Engines und Warteschlangen Warteschlangen zugewiesen.
       • Regel: Geben Sie mithilfe der Booleschen Logik die Eigenschaften an, die bestimmen, wie Engines den angegebenen Warteschlangen zugewiesen werden.

       Sie können eine oder mehrere der folgenden Eigenschaften angeben:

       Für Eigenschaften erweitern
       • Dynamisch:FME-Motoren Der Lizenztyp ist dynamisch.
       • Standard:FME-Motoren Lizenztyp ist Standard.
       • Brauch: Zusätzlich zuDynamischUndStandardkönnen Sie andere Engine-Eigenschaften angeben, wie sie auf derMotoren Registerkarte, beispielsweise den Namen oder das Betriebssystem des Hostcomputers.
       • Physischer Speicher des Engine-Hosts: RAM-Menge auf dem Computer, auf dem eine FME-Engine gehostet wird.
       • Prozessoranzahl des Engine-Hosts: Berechnet als: (Anzahl der CPUs) x (Anzahl der Kerne) x (Anzahl der Hyperthreads) auf dem Computer, auf dem eine FME-Engine gehostet wird.
       • Anzahl der in die Warteschlange gestellten Aufträge: Die Anzahl der Jobs, die sich derzeit in einer angegebenen Warteschlange befinden.
       • Längste Wartezeit für in die Warteschlange gestellte Jobs: Die Zeit des Jobs, der in einer angegebenen Warteschlange am längsten gewartet hat.
       • Zeit bis zur Fertigstellung aller in die Warteschlange gestellten Aufträge: Die Zeit, die für die Fertigstellung aller Jobs in einer angegebenen Warteschlange benötigt wird, basierend auf historischen Daten.
       • CPU für die Fertigstellung aller in die Warteschlange gestellten Aufträge: Die CPU-Zeit für die Fertigstellung aller Jobs in einer angegebenen Warteschlange basierend auf historischen Daten.
       • Anzahl der Motoren: Die Anzahl der Engines, die einer bestimmten Warteschlange zugewiesen sind. Wenn Sie sich über die Engine-Auslastung einer bestimmten Warteschlange auf Grundlage der aktuellen Leistungsmetriken der Job-Routing-Regeln der Warteschlange Sorgen machen, verwenden Sie diese Eigenschaft, um Jobs in die Warteschlangen auszulagern, die Sie unten unterWarteschlangen. Wenn der Warteschlange „MyQueue1“ beispielsweise basierend auf den aktuellen Leistungsmetriken bereits 5 Engines zugewiesen sind, verwenden Sie diese Eigenschaft, um Jobs auf andere Engines auszulagern.

       DerRegelDas Dropdown-Menü ist bereits mit einigen Eigenschaften ausgefüllt, aus denen Sie auswählen können. Um weitere Eigenschaften zur Dropdown-Liste hinzuzufügen, klicken Sie aufEigenschaft erstellen. NebenTyp, geben Sie eine Eigenschaftskategorie an, entwederBrauch,Motor , oderWarteschlange. WennBrauchangegeben ist, geben Sie einenEigentumgenau wie es auf demMotoren Tab. WennWarteschlangeangegeben ist, wählen Sie eine WarteschlangeEigentumund geben Sie eine Warteschlange an, auf die die Eigenschaft angewendet werden soll. WennMotorangegeben ist, wählen Sie einen Engine-HostEigentum.

       NotizFür Kubernetes-Bereitstellungen von FME Engines geben Sie anBrauchund dieNameEigenschaft der jeweiligen Engine-Bereitstellung. Weitere Informationen finden Sie unterDefinieren von FME-Engines, Warteschlangensteuerung und Streams für eine Kubernetes-Bereitstellung.

       Die Regel erscheint unter demRegelDropdown-Menü, während Sie Eigenschaften auswählen. Um Regeln hinzuzufügen, klicken Sie auf+ Regel. Um Eigenschaften in der Regel zu verschachteln, klicken Sie auf+ Regelwerk.

       Um beispielsweise eine beliebige dynamische Engine auf dem Server WHISTLER anzugeben (einBrauchEigenschaft), geben SieDynamisch UND WHISTLER.

     • Name: Engines werden den Warteschlangen nach Engine-Namen zugewiesen.
       NotizFür containerisierte Bereitstellungen vonFME Flow, wie Kubernetes, empfehlen wir dringend, den Engine-Namen über dasEigentumEinstellung stattdessen (siehe oben).
       • Motoren: Geben Sie die Engine-Namen an, die Sie der/den Warteschlange(n) zuweisen möchten.
       NotizSie können keine Engines angeben, die zugeordnet sind zuStreams.
   • Warteschlangen: Geben Sie eine oder mehrere Warteschlangen an, um Jobs an die in dieser Regel angegebenen Engines weiterzuleiten.
   • Ermöglicht: Standardmäßig ist die Regel aktiviert. Wenn diese Option deaktiviert ist, werden Jobs, die ansonsten basierend auf dieser Regel an Engines weitergeleitet würden, stattdessen an die Standardwarteschlange weitergeleitet.
   • Aktive Perioden: Geben Sie dieAktive Perioden während der die Engine-Zuweisungsregel gilt. WennKeiner, die Regel gilt immer.
3. KlickenOK.