Flux

Utilisez la page Flux pour gérer les tâches que vous souhaitez exécuter en continu. Lorsqu'un travail s'exécute en tant que flux, il redémarre automatiquement, que le travail se soit terminé avec succès, ait échoué ou que le serveur soit tombé en panne ou ait été arrêté.

WorkspaceLes flux alimentés par des flux ont généralement une file d'attente d'événements ou un courtier de messages comme source. Les messages sont gérés par des transformateurs tels que AzureQueueStorageConnector ou KafkaConnector, qui peuvent s'exécuter dansMode:Flux. Le flux vous permet d’intégrer et d’analyser les données en temps réel au fur et à mesure de leur production. Avec le mode flux, il n'y a pas de surcharge pour démarrer et arrêter les tâches, ce qui signifie qu'un volume très élevé de données peut être traité avec une faible latence.

Les flux offrent les avantages supplémentaires suivants par rapport à l'exécution continue de tâches via d'autres interfaces :

• Lorsque vous créez un flux, leMoteurs FME vous attribuez l'exécution de ses tâches dédiées à ce flux.
• Vous pouvez faire évoluer le débit de traitement en exécutant des tâches à partir du mêmeworkspace simultanément par plusieurs moteurs. Le nombre de tâches exécutées par un flux est égal au nombre de moteurs attribués au flux.
NoteSi les moteurs FME que vous spécifiez pour le flux appartiennent à unfiles d'attente, ils sont supprimés de ces files d'attente afin qu'ils soient dédiés au flux.
• Vous pouvez configurer un flux puis le mettre en pause.
• La page Flux vous montre toutes les tâches que vous exécutez en continu, afin que vous puissiez les gérer dans un seul endroit pratique.

Premiers pas avec Streams

Pour créer un flux, sélectionnezFlux>Créer un flux. Ou sélectionnezFlux>Gérer les flux et cliquezCréer.

1. Remplissez les champs suivants :
• Nom:Fournissez un nom pour le flux.
• Description: (Facultatif) Fournissez une description significative du flux, telle queworkspace il fonctionne et pourquoi vous voulez qu'il fonctionne en continu. Utilisez les outils Markdown comme vous le souhaitez.
• Journal de débogage: Lorsqu'il est activé, enregistre des informations supplémentaires surJournaux de travail FME. Ce paramètre est mieux utilisé lorsqu'une erreur s'est déjà produite et que vous recherchez des informations supplémentaires.
NoteJournal de débogage peut entraîner des performances plus lentes de l'espace de travail et des fichiers journaux de grande taille.
• Remote Stream: To run the stream on the engines of a Remote Engines Service, toggle this field and specify the Remote Engines Service.
  NoteWhen running streams on a Remote Engines Service, keep in mind the following:

  • A stream that is created on FME Flow version 2025.1 or later will not run on an installation of Remote Engines Services version 2024.* or earlier.
  • If a stream runs on a Remote Engines Service and the primary FME Flow shuts down, the Remote Engine Service shuts down 24 hours later. Once the primary FME Flow restarts and connects to the Remote Engines Service, the stream restarts.
  • If a stream runs on a Remote Engines Service that is reconfigured (for example, with a different database server), the stream continues to run on the reconfigured service as long as the settings of the stream that are configured here still apply.
• Dépôt: Spécifiez le référentiel qui contient leworkspace vous voulez courir en continu.
• Workspace: Specify the workspace you want to run continuously.
NoteLeworkspace devrait contenir un ensemble de transformateurs pourMode:Flux, tels que AzureQueueStorageConnector ou KafkaConnector.
• Paramètres publiés: Si leworkspace a des paramètres publiés, spécifiez-les ici.
2. Cliquez sur OK .
3. Une page s’ouvre qui résume les propriétés du flux que vous avez créé. Le flux est prêt à être exécuté dès que vous affectez des moteurs FME pour exécuter les tâches. If you do not want the stream to run immediately, click Stop.
4. Pour affecter des moteurs FME afin d'exécuter les tâches associées au flux, cliquez surGérer sous Moteurs assignés. Lorsque vous attribuez des moteurs à un flux, gardez à l’esprit les points suivants :
• L'attribution de plusieurs moteurs signifie que vous pouvez augmenter le débit de traitement en exécutant le même travail simultanément. Le nombre de tâches exécutées par un flux est égal au nombre de moteurs attribués au flux.
• Vous ne pouvez attribuer que des moteurs qui ne sont pas déjà dédiés à d'autres flux.
• Si les moteurs FME que vous spécifiez pour le flux appartiennent à unfiles d'attente, ils sont supprimés de ces files d'attente afin qu'ils soient dédiés au flux.
• Si un moteur se déconnecte deFME Flow (par exemple, une machine qui héberge un moteur FME distinct tombe en panne), tout travail en cours d'exécution revient à un état « en file d'attente » et est renvoyé au moteur lorsqu'il devient disponible.
5. Dans la boîte de dialogue Gérer la règle du moteur, spécifiez :
   • Taper:Comment vous souhaitez attribuer les moteurs FME au flux :
     • Nom: Les moteurs sont attribués au flux par nom de moteur
     • Propriété:Les moteurs sont attribués au flux en fonction de leurs propriétés.
   • Moteurs: SiTaperestNom, sélectionnez un ou plusieurs moteurs par nom à attribuer au flux.
   • Règle: SiTaperestPropriété, utilisez la logique booléenne pour spécifier les propriétés qui déterminent la manière dont les moteurs sont attribués au flux.

   Les propriétés suivantes peuvent être sélectionnées sans saisie manuelle :

   Développer pour les propriétés
   • Dynamique:Moteurs FME le type de licence est Dynamique (Utilisation du processeur).
   • Standard:Moteurs FME le type de licence est Standard.
   • Mémoire physique de l'hôte du moteur: Quantité de RAM sur la machine hébergeant un moteur FME.
   • Nombre de processeurs de l'hôte du moteur:Calculé comme suit : (nombre de CPU) x (nombre de cœurs) x (nombre d'hyperthreads) sur la machine hébergeant un moteur FME.

   Pour ajouter l'une de ces propriétés, cliquez sur+ Règle et sélectionnez-le.

   De plus, vous pouvez ajouter d'autres propriétés du moteur telles qu'elles apparaissent sur leMoteurs onglet, tel que le nom ou le système d'exploitation de la machine hôte. Pour ajouter d'autres propriétés à laRèglemenu déroulant, cliquez+ Créer une propriété. À côté deTaper, préciserCoutume, et entrez unPropriétéexactement comme il apparaît sur leMoteurs languette.

   Dès que vous spécifiez une propriété, la règle apparaît sous laRègledérouler. Pour ajouter plus de propriétés, cliquez sur+ Règle. Pour imbriquer des propriétés dans la règle, cliquez sur+ Ensemble de règles.

   Par exemple, pour spécifier un moteur dynamique sur le serveur WHISTLER (unCoutumepropriété), précisezDynamique ET WHISTLER.

   Une fois terminé, cliquez surD'ACCORD.

6. Une fois que vous avez attribué des moteurs à un flux, celui-ci commence à fonctionner, sauf si vous l'avez arrêté précédemment. Lorsque vous êtes prêt à exécuter le flux, cliquez surCommencer; ou à partir de la page Gérer les flux, sélectionnez le flux et cliquez surActes> Commencer.

Gestion des flux

SélectionnerFlux>Gérer les flux.

Pour démarrer, arrêter ou supprimer des flux

Sélectionnez les flux, cliquez surActes, et sélectionnezCommencer, Arrêt, ouRetirer, respectivement.

Lorsqu'un flux est arrêté, le flux associéworkspace ne soumet aucun travail au flux. Tous les travaux en file d'attente ou en cours d'exécution sont annulés.

Pour afficher les tâches en cours d'exécution ou en file d'attente via un flux

Cliquez sur le flux pour l’ouvrir et faites défiler jusqu’à Emplois. Cliquez sur un travail pour l'ouvrir dans leEmplois page.

Pour afficher tous les moteurs attribués aux flux

Vous pouvez afficher tous les moteurs attribués aux flux sur leMoteurs page.

Pour modifier les moteurs attribués à un flux

Cliquez sur le flux pour l'ouvrir. Sous Moteurs attribués, cliquez surGérer pour attribuer des moteurs. Les moteurs nouvellement attribués exécutent des tâches peu de temps après leur attribution.