Créer un connecteur personnalisé à l'aide d'Ingest

Cette leçon crée un connecteur nommé custom. Renommez custom avec le nom de connecteur requis.

About this task

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=#/Create%20Connector%20Configuration/createConnector

Note: Si vous vous connectez à la base de données pour l'environnement de production ou opérationnel, remplacez AUTH par LIVE dans le code.

Procedure

Dans l'interface utilisateur de Swagger, sélectionnez Configuration du connecteur > POST : /connecteurs API.
Cliquez sur Essayer.

Pour le corps de l'API, utilisez le code suivant.

{

    "name": "custom.cas",
    "description": "This is the connector for the custom processing using CAS Index Model",
    "pipes": [
        {
            "name": "_Template-Schema-CAS"
        },
        {
            "name": "_Template-DatabaseETL-CAS",
            "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"
                    }
                }
            ]
        },
        {
            "name": "Terminal"
        }
    ] 

}

Cliquez sur Exécuter.

Results

La réponse de Swagger ressemblera à ce qui suit :