HCL Commerce Version 9.1.10.0 or later

Configurer le connecteur dans NiFi

Dans cette leçon, vous configurez le connecteur que vous avez créé à l'étape précédente à l'aide de NiFi.

About this task

Utilisez le lien suivant pour NiFi : http://hostname/IP: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.
  • Si vous êtes sur la page d'accueil de NiFi où vous pouvez afficher tous les processeurs, vous devrez peut-être faire défiler l'écran vers la droite du pipeline et effectuer un zoom avant pour trouver les processeurs requis.

Procedure

Pour configurer le connecteur dans NiFi, procédez comme suit.
  1. Mettez à jour les propriétés du processeur custom-_Template-Schema.
    1. Allez au nouveau pipeline "custom" et cliquez deux fois sur custom-_Template-Schema.
    2. Cliquez deux fois sur le groupe de processus Mise à jour du schéma.
    3. Recherchez le groupe de processus Configurer le schéma d'index Elasticsearch.
    4. Recherchez et cliquez avec le bouton droit de la souris sur Spécifier le schéma à mettre à jour et arrêtez le processeur.
    5. Cliquez deux fois sur le processeur pour modifier les paramètres.
    6. Allez dans l'onglet Propriétés et mettez à jour la propriété param.schema avec la valeur product.
    7. Cliquez sur Appliquer.
    8. Démarrez le processeur en cliquant avec le bouton droit de la souris et en sélectionnant Démarrer.
  2. Mettez à jour le processeur Renseigner le schéma d'index.
    1. Arrêtez le processeur.
    2. Cliquez deux fois sur le processeur pour modifier les paramètres.
    3. Mettez à jour la propriété Valeur de remplacement avec la valeur suivante : 
       { "properties":{ "custom":{ "properties":{ "x_profitMargin":{ "type":"float", "coerce":"true", "doc_values":"true", "ignore_malformed":"false", "index":"true", "store":"true" } } } } }
    4. Démarrez le processeur.
  3. Mettez à jour le processeur Définir le SQL personnalisé et le nom d'index.
    Note: Assurez-vous que les données de prix de revient sont disponibles dans votre base de données. Ce connecteur ne vérifie pas si le SQL renvoie des résultats. Si les données de prix de revient ne sont pas disponibles dans la base de données, les données renvoyées pour le SQL sont vides et entraînent des erreurs. Pour vérifier que les données de prix de revient sont présentes dans la base de données, vérifiez le connecteur d'indexation via auth.reindex > DatabasePriceStage1 > Rechercher des prix > Exécuter SQL avec vérification préalable.

    1. Accédez au nouveau pipeline custom et double-cliquez sur custom -_Template -DatabaseETL.
    2. Allez dans Canal du connecteur personnalisé > Exécuter SQL.
    3. Dans le groupe Exécuter un processus SQL, recherchez le processus Définir un SQL personnalisé.
    4. Faites un clic droit sur Définir un SQL personnalisé et arrêtez le processeur.
    5. Cliquez deux fois sur le processeur pour modifier les paramètres.
    6. Mettez à jour la propriété ingest.database.sql avec la valeur suivante : 
      SELECT OP.CATENTRY_ID, CASE WHEN OP.PRICE <> 0 THEN (OP.PRICE - CP.PRICE) / OP.PRICE * 100 ELSE NULL END AS PROFIT_MARGIN FROM (SELECT O.CATENTRY_ID CATENTRY_ID, P.PRICE PRICE FROM OFFER O INNER JOIN OFFERPRICE P ON (O.OFFER_ID = P.OFFER_ID AND P.CURRENCY = 'USD') INNER JOIN TRADEPOSCN ON (O.TRADEPOSCN_ID = TRADEPOSCN.TRADEPOSCN_ID AND TRADEPOSCN.NAME = 'Extended Sites Catalog Asset Store') WHERE (O.STARTDATE IS NULL OR CURRENT_TIMESTAMP > O.STARTDATE) AND (O.ENDDATE IS NULL OR O.ENDDATE > CURRENT_TIMESTAMP) AND O.PUBLISHED = 1 ) OP LEFT OUTER JOIN (SELECT OFFER.CATENTRY_ID CATENTRY_ID, OFFERPRICE.PRICE PRICE FROM OFFER INNER JOIN OFFERPRICE ON (OFFER.OFFER_ID = OFFERPRICE.OFFER_ID AND OFFERPRICE.CURRENCY = 'USD') INNER JOIN TRADEPOSCN ON (OFFER.TRADEPOSCN_ID = TRADEPOSCN.TRADEPOSCN_ID AND TRADEPOSCN.NAME = 'My Company Cost Price List' )) CP ON (CP.CATENTRY_ID = CP.CATENTRY_ID) INNER JOIN CATENTRY C ON C.CATENTRY_ID = CP.CATENTRY_ID WHERE OP.CATENTRY_ID = CP.CATENTRY_ID ${extCatentryAndSQL}
    7. Cliquez sur Appliquer.
    8. Cliquez avec le bouton droit de la souris et sélectionnez Démarrer dans le menu contextuel pour démarrer le processeur.
  4. Mettez à jour le processeur Transformer le document - Mapper les champs d'index à partir de la base de données.
    1. Accédez à custom -_Template -DatabaseETL > Pipeline de connecteur personnalisé > Mapper les champs d'index à partir de la base de données.
    2. Faites un clic droit sur le processeur et arrêtez-le.
    3. Double-cliquez sur le processeur pour modifier ses paramètres. La fenêtre Configurer les processeurs s'ouvre.
    4. Sous l'onglet Propriétés de la fenêtre Configurer les processeurs, mettez à jour la propriété Identifiant d'entrée avec la valeur ${param.storeId}-${param.langId }-${param.catalogId}-[id.catentry].
    5. Ajoutez une nouvelle propriété nommée PROFIT_MARGIN et attribuez-lui la valeur custom.x_profitMargin.
      Votre fenêtre Configurer les processeurs ressemblera à ce qui suit :

    6. Cliquez sur Appliquer.
    7. Ouvrez la fenêtre Détails du processeur, supprimez les propriétés FIELD1 et FIELD2 de l'onglet Propriétés. Cliquez sur OK.
  5. Créer une version pour custom-_Template-Schema.
    1. Cliquez avec le bouton droit de la souris sur custom-_Template-Schema.
    2. Cliquez sur Version > Arrêter le contrôle des versions > Déconnecter.
    3. Cliquez avec le bouton droit de la souris sur custom-_Template-Schema.
    4. Cliquez sur Version > > Démarrer le contrôle des versions.
    5. Ajoutez le Flow Name requis et enregistrez.
      Dans ce tutoriel, le Flow Name = ProfitMarginSchemaUpdateConnector.
  6. Créez une nouvelle version pour le custom-_Template-DatabaseETL.
    1. Cliquez avec le bouton droit de la souris sur le groupe de processus custom-_Template-DatabaseETL.
    2. Cliquez sur Version > Arrêter le contrôle des versions > Déconnecter.
    3. Cliquez avec le bouton droit de la souris sur le groupe de processus custom-_Template-DatabaseETL.
    4. Cliquez sur Version > > Démarrer le contrôle des versions.
    5. Ajoutez le Flow Name requis et enregistrez.
      Dans ce tutoriel, le Flow Name = ProfitMarginDatabaseConnectorPipe.
  7. Joignez le connecteur personnalisé à votre auth.postindex ou live.postindex en procédant comme suit :
    1. A l'aide de l'interface utilisateur Swagger, accédez à Configuration du connecteur > POST: /upgrade API.
    2. Cliquez sur Essayez-le.
    3. Saisissez comme id la valeur auth.postindex.
    4. Pour le corps de l'API, utilisez le code suivant. 
      { "Licensed Materials": "Property of HCL Technologies Limited. (c) Copyright HCL Technologies Limited 1996, 2023.", "_name": "Post re-indexing connector descriptor for HCL Commerce Ingest service to be used with the Authoring environment", "_usage": { "// This is the connector descriptor of a post reindexing connector to be used with HCL Commerce Ingest service.": "", "// It is designed for performing a list of post indexing operations after the main part of a full re-indexing is completed.": "" }, "name": "auth.postindex", "environment": [ "auth", "data", "toolkit", "live" ], "description": "This is the connector for customization to perform a post re-indexing operation.", "pipes": [ { "// ": "------------- Preparation Stage -------------", "// Preparing database specific settings for this indexing pipeline": "", "name": "ReindexLink", "label": "ReindexLink" }, { "name": "ProfitMarginSchemaUpdateConnector", "label": "ReindexLink-ProfitMarginSchemaUpdateConnector" }, { "name": "ProfitMarginDatabaseConnectorPipe", "label": "ReindexLink-ProfitMarginDatabaseConnectorPipe" }, { "// ": "------------- End of dataflow -------------", "// The connector dataflow terminates here by generating a log summary through the Logging Service": "", "name": "Terminal", "label": "Terminal" } ] }
    5. Cliquez sur Exécuter.
  8. Extraye le connecteur par version.
    1. Exécutez les commandes suivantes :
      Note: Le nom du conteneur Docker utilisé dans cet exemple est commerce_registry_1. Remplacez-le par le nom réel du conteneur Docker.
      1. docker exec -it commerce_registry_1 bash
      2. /opt/nifi-registry/scripts/export_flow.sh ProfitMarginSchemaUpdateConnector>/opt/nifi-registry/flows/ProfitMarginSchemaUpdateConnector.json
      3. /opt/nifi-registry/scripts/export_flow.sh ProfitMarginDatabaseConnectorPipe>/opt/nifi-registry/flows/ProfitMarginDatabaseConnectorPipe.json
      4. exit
      5. docker cp commerce_registry_1:/opt/nifi-registry/flows/ProfitMarginDatabaseConnectorPipe.json ./ProfitMarginDatabaseConnectorPipe.json
      6. docker cp commerce_registry_1:/opt/nifi-registry/flows/ProfitMarginSchemaUpdateConnector.json ./ProfitMarginSchemaUpdateConnector.json
      Vous pouvez également extraire le canal du connecteur via l'interface NiFi Registry.
      1. Lancez l'interface NiFi Registry et localisez le nom de flux que vous souhaitez exporter, par exemple ProfitMarginSchemaUpdateConnector ou ProfitMarginDatabaseConnectorPipe.
      2. Cliquez sur le bouton Action et sélectionnez Exporter la version.
      3. Sélectionnez la version la plus récente et cliquez sur Exporter.
    2. Copiez ProfitMarginSchemaUpdateConnector.json et ProfitMarginDatabaseConnectorPipe.json dans votre environnement d'exécution.