Créer un connecteur à l'aide d'Ingest
Dans cette leçon, vous créez un connecteur à l'aide d'Ingest.
Avant de commencer cette étape, vous devez effectuer l'étape prérequise sur Charger la liste des prix de revient.
Création d'un connecteur dans NiFi pour l'environnement d'exécution
Note:
- Cette leçon crée un connecteur nommé "custom.auth". Veillez à remplacer le nom "custom.auth" par le nom de connecteur requis.
- Si vous vous connectez à la base de données pour l'environnement de production ou opérationnel, remplacez "AUTH" par "LIVE" dans le code.
Pour créer un connecteur dans le service Ingest, utilisez l'API suivante : http://ElasticSearchHostname/IP:30800/swagger-ui/index.html?url=/v3/api-docs&validatorUrl=#/Connector%20Configuration/createConnector
Pour créer le connecteur dans l'environnement d'exécution, procédez comme suit :
- Depuis l'interface utilisateur de Swagger, allez à API.
- Cliquez sur Essayer.
- Pour le corps de l'API, utilisez le code fourni.
- Cliquez sur Exécuter.
{ "name":"custom.auth", "description":"This is the connector for the custom processing", "pipes":[ { "name":"ProfitMarginSchemaUpdateConnector" }, { "name":"ProfitMarginDatabaseConnectorPipe", "properties":[ { "name":"Database Driver Location(s)", "value":"${AUTH_JDBC_DRIVER_LOCATION}", "scope":{ "name":"Database Connection Pool", "type":"CONTROLLER_SERVICE" } }, { "name":"Database Driver Class Name ", "value":"${AUTH_JDBC_DRIVER_CLASSNAME}", "scope":{ "name":"Database Connection Pool", "type":"CONTROLLER_SERVICE" } }, { "name":"Database Connection URL", "value":"${AUTH_JDBC_URL}", "scope":{ "name":"Database Connection Pool", "type":"CONTROLLER_SERVICE" } }, { "name":"Database User", "value":"${AUTH_JDBC_USER_NAME}", "scope":{ "name":"Database Connection Pool", "type":"CONTROLLER_SERVICE" } }, { "name":"Password", "value":"${AUTH_JDBC_USER_PASSWORD}", "scope":{ "name":"Database Connection Pool", "type":"CONTROLLER_SERVICE" } } ] } ] }