Utiliser le déclencheur de message Kafka et le consommateur de script pour utiliser des messages

Rversion finale: Zurich

Mis à jour 31 juil. 2025

4 minutes de lecture

Récupérez les messages d’Hermes avec le déclencheur Studio de workflow de message Kafka et le consommateur de script.

Avant de commencer

Rôle requis : integration_hub_admin
Cette page fait partie de la section Connexion au flux Guide de démarrage rapide.
Ce document vous montre comment utiliser des messages via votre connexion à Hermes. Pour configurer et tester votre connexion, consultez Établissez une connexion sécurisée au Service de messagerie Hermes et Test de la connexion à Hermes via la passerelle ADCv2.
La première partie de cette page vous montre comment utiliser le déclencheur de message Kafka pour Studio de workflow consommer des messages. Pour en savoir plus sur le déclencheur, reportez-vous à la section Create a flow with a Kafka Message trigger. Pour plus d’informations sur Studio de workflow les flux et leur configuration, reportez-vous à la section Workflow Studio.
La deuxième partie de cette page vous montre comment utiliser le consommateur de script pour consommer des messages. Pour plus d'informations, consultez Configurer un consommateur de script.

Procédure

Créez une rubrique pour utiliser des messages.
1. Utilisez la commande suivante pour créer une rubrique dans Hermes.
```
bin/kafka-topics.sh --create --command-config config/bootcamp.properties  --bootstrap-server <instance name>.service-now.com:4000,<instance name>.service-now.com:4001,<instance name>.service-now.com:4002, <instance name>.service-now.com:4003 --topic snc.<instance name>.topic1
```
  Assurez-vous de remplacer <nom d’instance> par le nom de votre instance.
2. Pour afficher la rubrique, connectez-vous à l’instance et accédez à Tous > Centre d'intégration > Connexion au flux > Rubriques.
  
  Remarque :
  La création d’une rubrique prend environ 10 minutes.
Créez un déclencheur de flux pour utiliser les messages de la rubrique.
1. Accédez à la Tous > Automatisation des processus > Concepteur de flux.
2. Sélectionner Créer > Flux.
3. Dans le formulaire Propriétés du flux, saisissez un nom pour votre flux, puis entrez Soumettre.
  Cet exemple utilise le nom Consommateur de rubrique 1.
4. Dans la section Déclencheur, sélectionnez Ajouter un déclencheur, puis sélectionnez Message Kafka comme type de déclencheur.
5. Sélectionnez la rubrique 1.
  
  Vous pouvez utiliser l’icône de loupe pour afficher la liste des rubriques disponibles.
6. Dans la section Actions du flux, accédez à Ajouter une action, une logique de flux ou un flux secondaire > Logique de flux > Pour chaque.
7. Faites glisser la pastille de données Messages vers le champ Éléments , puis sélectionnez Terminé.
8. Dans la section Actions du flux, accédez à Ajouter une action, une logique de flux ou un flux secondaire > Action > Cœur de ServiceNow > Journal.
9. Faites glisser la pastille de données de charge utile vers le champ Message , puis sélectionnez Terminé.
10. Enregistrez le déclencheur de flux.
11. Accédez à la table Paramètres [sys_flow_execution_setting] pour activer la génération de rapports pour ce flux.
12. Créez une nouvelle entrée et activez la génération de rapports sur le flux créé ci-dessus.
13. Revenez à votre flux et sélectionnez Activer.
14. Pour afficher votre abonnement à la rubrique, accédez à Tous > Concentrateur d'intégration > Connexion au flux > Abonnements.
Publiez des messages dans la rubrique à l’aide de l’outil de ligne de commande Kafka.
1. Exécutez la commande suivante pour publier des messages dans la rubrique.
```
bin/kafka-console-producer.sh --topic snc.<instance name>.topic1  --producer.config  config/bootcamp.properties  --bootstrap-server <instance name>.service-now.com:4000,<instance name>.service-now.com:4001,<instance name>.service-now.com:4002,<instance name>.service-now.com:4003
```
  Assurez-vous de remplacer <nom d’instance> par le nom de votre instance.
  Cette commande vous invite à entrer des messages. Ajoutez quelques exemples de messages. Cet exemple utilise les messages suivants.
  - Message de test 1
  - Message de test 2
  - Message de test 3
  Vous devriez recevoir les messages dans environ une minute.
2. Revenez au flux et sélectionnez Exécutions.
3. Ouvrez l’exécution du flux.
4. Pour afficher les statistiques de cet abonnement, accédez à Tous > Concentrateur d'intégration > Connexion au flux > Abonnements, ouvrez l’abonnement et accédez à la vue des statistiques.
Créez un consommateur de script pour utiliser les messages de la rubrique.
1. Accédez à la Centre d'intégration > Consommateurs > Consommateurs de script.
2. Sélectionnez Nouveau.
3. Dans le champ Nom , saisissez un nom pour votre consommateur de script.
  Cet exemple utilise Consommateur de rubrique 1.
4. Définissez le script pour consigner le message en ajoutant la logique suivante dans la zone de script.
```
for (var i = 0; i < messages.length; i++) {
      gs.info('Received message ' + JSON.stringify(messages[i].message));
 }
```
5. Enregistrez le formulaire.
6. Dans la section Liens connexes, sélectionnez Nouveau pour ajouter un flux Kafka afin de consommer les messages.
7. Sur le formulaire Flux Kafka, définissez les valeurs de champ suivantes.
  - Nom vers le flux de rubrique 1.
  - Rubrique de la rubrique créée précédemment, rubrique1.
  - Concurrence max. à 1.
  - Commencez à consommer pour Tous les messages stockés dans la rubrique. Cette option vous permet de lire les messages déjà publiés dans cette rubrique.
  - Gestion des messages à optimiser automatiquement.
8. Sélectionnez le lien Activer sous Liens connexes.
  Vous devriez pouvoir voir l’abonnement activé.
9. Pour afficher les messages, accédez à Tous > Journaux système > Journal système et filtrer les messages commençant par le message reçu.
10. Vous devriez voir tous les messages après 1 minute.

Que faire ensuite

Utiliser les consommateurs ETL et de carte de transformation pour importer des données.