Intégration de votre connecteur personnalisé à un pipeline existant dans NiFi

Dans la dernière étape du tutoriel, vous intégrez votre nouveau connecteur personnalisé à un pipeline NiFi existant.

Procedure

Associez le connecteur personnalisé à votre auth.reindex ou live.reindex après leur auth.reindex - Product Stage 1a (Main Document) et le auth.reindex - WaitLink - Product Stage 1a suivant. Pour plus d'informations, voir Configurer le connecteur dans NiFi. https://help.hcltechsw.com/commerce/9.1.0/tutorials/tutorial/tsd_connectorconfigure_elastic.html)
Dans la mesure du possible, utilisez un canal Lien de fractionnement pour appeler votre connecteur personnalisé à partir d'un connecteur par défaut existant, tel que auth.reindex ou live.reindex. Pour plus d'informations, voir Lien de fractionnement. Voici un fragment de code qui peut être utilisé pour être ajouté au connecteur par défaut existant afin de lancer votre connecteur personnalisé :
```
{ "name": "SplitLink", "label": "SplitLink - Custom Connector", "properties": [ { "name": "split.connector.name", "value": "auth.xfields", "scope": { "name": "Launch Connector", "type": "PROCESS_GROUP" } } ] }
```
Assurez-vous de démarrer tous les groupes de processus. Dans la vue de niveau supérieur de tous les pipelines ("Flux NiFi") de l'interface utilisateur de NiFi, vous pouvez cliquer sur le bouton de lecture dans la zone Opération sur le côté gauche de la zone de conception de l'espace de travail NiFi pour démarrer tous les groupes de processus de pipeline.
Générer votre index
```
POST: https://CommerceServerName:ts-app-port/wcs/resources/admin/index/dataImport/build?connectorId=auth.reindex&storeId=1
```
Pour plus d'informations, voir Générer un index et vérifier que la zone de marge bénéficiaire est indexée.

Results

Votre connecteur SQL personnalisé fait désormais partie du pipeline NiFi et importe des données à partir des zones personnalisées que vous avez spécifiées.

What to do next

Une fois l'indexation terminée, vérifiez et assurez-vous que vos zones se trouvent maintenant dans l'index.

Pour répertorier tous les index :

http://ElasticSearchServerName/IP:30200/_cat/indices?v

Pour afficher votre index mis à jour :

http://ElasticSearchServerName/IP:30200/auth.storeId.product/_search?q=id.product=catentryId

Vérifiez que vos zones sont renvoyées à l'aide de l'API REST du service Query.