Configurer un consommateur de script

  • Rversion finale: Washingtondc
  • Mis à jour 1 févr. 2024
  • 1 minute de lecture

    • Utilisez un script pour importer et traiter des données à partir de votre environnement Kafka.

    Avant de commencer

    • Rôle requis : integration_hub_admin
    • Ce consommateur fait partie de Connexion au flux pour Apache Kafka ce qui nécessite un Connexion au flux pour Apache Kafka abonnement. Pour plus d'informations, consultez https://www.servicenow.com/products/automation-engine.html.
    • Les modules d’extension suivants sont requis.
      • Le module d’extension ServiceNow IntegrationHub Kafka Consumer (com.glide.hub.kafka_consumer).
      • Le module d’extension ServiceNow IntegrationHub ETL Consumer - Kafka (com.glide.hub.etl_consumer.kafka).

    Pourquoi et quand exécuter cette tâche

    Pour configurer un consommateur, vous devez créer deux enregistrements.
    1. L’enregistrement consommateur, qui spécifie la manière d’importer et de traiter les données.
    2. Un enregistrement pour le flux Kafka, qui définit le flux de données vers votre consommateur.
    Cette tâche couvre la création du consommateur. Pour obtenir des instructions sur la création d’un flux Kafka, consultez Créer un flux Kafka.

    Procédure

    1. Accédez à la Tout > Centre d'intégration > Consommateurs > Consommateur de script.
    2. Sélectionnez Nouveau.
    3. Renseignez les champs du formulaire.
      Tableau 1. Consommateur de script Kafka
      Champ Description
      Nom Nom du consommateur de script.
      Garantie de livraison En cas de défaillance d’un nœud, option permettant de spécifier la garantie de remise des messages entrants. Sélectionnez l'une des options suivantes :
      • Pas de perte mais des doublons : garantit que tous les messages sont remis au moins une fois. Certains messages peuvent être remis plus d’une fois.
      • Une fois ou pas du tout : garantit qu’un message n’est pas remis plus d’une fois. Certains messages peuvent ne pas être livrés du tout.
      Consommateur d’événement Script à utiliser pour utiliser les messages reçus de la rubrique Kafka.
      Application Périmètre de l’application pour le consommateur de carte de transformation.
    4. Sélectionnez Enregistrer.

    Exemple

    Cet exemple montre un exemple de script pour le traitement des messages.
    (function process(messages) {
 // Add your code here to consume kafka messages 
 // sample message [ { 'key' : 'message_key' , 'message' : 'message' , 'headers' : [ { 'key' : 'header_key' , 'value' : 'header_value' } ] } ] 

 for (var i = 0; i < messages.length; i++) {
     var message = JSON.parse(messages[i].message);
     gs.info('Number ' + message.number + ', short description ' + message.short_description +
         ', headers ' + JSON.stringify(messages[i].headers));
 }
})(messages);

    Que faire ensuite

    Créer un flux Kafka pour ce consommateur. Une fois le flux activé, vous pouvez commencer à recevoir des messages de votre environnement Kafka.