Deprecated feature

Associer les groupes de processus personnalisés au connecteur

Dans cette leçon, vous associez les groupes de processus personnalisés à votre connecteur.

About this task

Utilisez le lien suivant pour NiFi : http://ElasticSearchHostname:30600/nifi/

Note: Cette leçon utilise le nom du connecteur "custom". Veillez à remplacer "custom" par le nom du connecteur que vous avez créé à l'étape précédente.

Procedure

Pour associer le connecteur personnalisé à la base de données, suivre la procédure ci-après. Joignez le connecteur personnalisé à votre fichier auth.reindex après le PriceStage respectif. Vous pouvez utiliser l'une des options suivantes.
  • Option 1 : Copiez manuellement les groupes de processus personnalisés et joignez-les à la fois pour le kit d'outils et les environnements d'exécution.
    1. Sélectionnez les groupes de processus "custom.auth – ProfitMarginSchemaUpdateConnector" et "custom.auth – ProfitMarginDatabaseConnectorPipe".
    2. Cliquez avec le bouton droit de la souris sur l'un des groupes de processus sélectionnés, puis cliquez sur Copier.

    3. Pour joindre les groupes de processus à votre auth.reindex ou live.reindex, recherchez le PriceStage respectif.

      HCL Commerce Version 9.1.9.0 or laterDans cet exemple, les connecteurs PriceStage sont "auth.reindex - Price Stage 1b (Rechercher les prix du groupement)" suivis de "auth.reindex - WaitLink - Price Stage 1a".

      HCL Commerce Version 9.1.11.0 or laterDans cet exemple, les groupes de processus PriceStage sont "auth.reindex - Price Stage 1a (Rechercher les prix du produit)" suivis de "auth.reindex - WaitLink - Price Stage 1a".

      9.1.9+9.1.11+
    4. Collez les groupes de processus que vous avez copiés à l'étape 2 devant "auth.reindex - WaitLink - Price Stage 1a".
      9.1.9+9.1.11+
    5. Pour établir une connexion entre les groupes de processus personnalisés et le pipeline existant, arrêtez tous les groupes de processus avec lesquels la connexion doit être établie. Pour arrêter les groupes de processus, sélectionnez tous les groupes de processus requis en appuyant sur la touche Maj et en cliquant sur tous les groupes de processus. Cliquez avec le bouton droit sur l'un d'eux, puis sur Arrêter.

      HCL Commerce Version 9.1.9.0 or laterDans cet exemple, vous devez arrêter "auth.reindex - WaitLink - Price Stage 1a" et "auth.reindex - CopyLink - Price (Copier vers le produit)".

      HCL Commerce Version 9.1.11.0 or laterDans cet exemple, vous devez arrêter "auth.reindex - WaitLink - Price Stage 1a" et "auth.reindex - Price Stage 1b (Rechercher des prix du groupement)".

      9.1.9+9.1.11+
    6. Supprimez toutes les connexions existantes entre les groupes de processus.
      Table 1.
      9.1.9+9.1.11+

      Après la suppression de la connexion, les groupes de processus apparaissent comme suit :

      Table 2.
      9.1.9+9.1.11+
    7. Déplacez le pointeur de la souris sur "auth.reindex - WaitLink - Price Stage 1a" et faites glisser la flèche vers un groupe de processus pour établir une connexion. La fenêtre Créer une connexion s'ouvre.

      Dans cet exemple, établissez une connexion depuis "auth.reindex - WaitLink - Price Stage 1a" vers "custom.auth - ProfitMarginSchemaUpdateConnector".

    8. Dans la fenêtre Créer une connexion, conservez toutes les valeurs par défaut et cliquez sur Ajouter.

      Une connexion entre WaitLink et le groupe de processus est maintenant établie.

      Table 3.
      9.1.9+9.1.11+
    9. Répétez les étapes 7 et 8 pour établir des connexions entre tous les groupes de processus :
      HCL Commerce Version 9.1.9.0 or later
      • Entre custom.auth – ProfitMarginSchemaUpdateConnector et custom.auth - ProfitMarginDatabaseConnectorPipe.

      • Entre custom.auth - ProfitMarginDatabaseConnectorPipe et auth.reindex - CopyLink - Price (Copier vers le produit).

      HCL Commerce Version 9.1.11.0 or later
      • Entre custom.auth – ProfitMarginSchemaUpdateConnector et custom.auth - ProfitMarginDatabaseConnectorPipe.

      •  Entre custom.auth - ProfitMarginDatabaseConnectorPipe et auth.reindex - Price Stage 1b (Rechercher les prix des groupements).

    10. Une fois toutes les connexions terminées, démarrez les groupes de processus. Pour démarrer les groupes de processus, sélectionnez tous les groupes de processus requis en appuyant sur la touche Maj et en cliquant sur tous les groupes de processus. Cliquez avec le bouton droit de la souris sur l'un d'entre eux, puis cliquez sur Démarrer.
      9.1.9+9.1.11+

      Les groupes de processus sont maintenant démarrés.

      9.1.9+9.1.11+
    11. Après avoir copié et joint manuellement le groupe de processus, assurez-vous qu'il pointe vers la base de données correcte.
      1. Cliquez avec le bouton droit de la souris sur "custom.auth - ProfitMarginDatabaseConnectorPipe" puis cliquez sur Configurer.
      2. Allez dans l'onglet Services du contrôleur.

      3. Si le service du contrôleur est activé, désactivez Pool de connexions de base de données en cliquant sur le bouton "d'éclair avec une barre oblique".

      4. Cliquez sur Configurer (icône d'engrenage).
      5. Accédez à NiFi Flow » custom.auth - ProfitMarginDatabaseConnectorPipe > Canal du connecteur personnalisé > Exécuter le SQL et démarrez Exécuter le SQL et Diviser en fichier JSON unique, si nécessaire.

        • Mettez à jour les propriétés suivantes en remplaçant “AUTH” ou “LIVE” selon les besoins :
          • URL de connexion à la base de données
          • Emplacement(s) du pilote de base de données
          • Utilisateur de base de données
          • Emplacement(s) du pilote de base de données
      6. Définissez la valeur de la propriété Mot de passe et cliquez sur Appliquer.
      7. Activez Pool de connexions de base de données (bouton en forme d'éclair). Assurez-vous qu'il n'y a pas d'erreur lorsque les services du contrôleur sont activés. Si une icône rouge s'affiche dans la première colonne du service du contrôleur, vous devrez peut-être examiner et corriger les erreurs.
      8. Dans l'onglet Services du contrôleur, activez Json Record Set Writer et Json Tree Reader.
      Après cette étape, les connexions entre le connecteur personnalisé sont les suivantes :
      9.1.9+9.1.11+
  • Option 2 : Mettre à niveau le descripteur de connecteur du connecteur existant à l'aide de l'API Ingest, comme décrit dans Mettre à niveau le descripteur de connecteur du connecteur existant.
    Après cette étape, les connexions entre le connecteur personnalisé sont les suivantes pour l'environnement d'exécution.
    9.1.9+9.1.11+

Results

A présent, les groupes de processus personnalisés sont ajoutés au connecteur.