{"id":758,"date":"2018-12-05T21:42:30","date_gmt":"2018-12-05T20:42:30","guid":{"rendered":"http:\/\/louis.hatier.me\/blog\/?p=758"},"modified":"2019-11-21T15:36:09","modified_gmt":"2019-11-21T14:36:09","slug":"symfony-connecter-avec-mongodb-et-elasticsearch","status":"publish","type":"post","link":"https:\/\/louis.hatier.me\/blog\/symfony-connecter-avec-mongodb-et-elasticsearch\/","title":{"rendered":"Symfony : connecter avec MongoDB et Elasticsearch"},"content":{"rendered":"

\"symfony-mongodb-elasticsearch\"<\/a>Symfony permet \u00e0 l\u2019aide de bundle, de s\u2019impl\u00e9menter facilement avec MongoDB<\/strong> et Elasticsearch<\/strong>.<\/p>\n

Le principe dans l\u2019exemple qui suit, est une application web Symfony qui fonctionne avec une base ma\u00eetre MongoDB.
\nCette base MongoDB synchronise r\u00e9guli\u00e8rement certaines de ses donn\u00e9es dans Elasticsearch qui sera responsable de la recherche.<\/p>\n

Symfony interroge ensuite Elasticsearch afin d\u2019obtenir des r\u00e9sultats de recherche, qui lui renvoie les id<\/code> des objets MongoDB afin d\u2019aller chercher l\u2019information brute dans la base ma\u00eetre.<\/p>\n

<\/p>\n

Elasticsearch<\/h2>\n

Installer Elasticsearch \u00e0 l\u2019aide de la documentation officielle<\/a>.<\/span><\/p>\n

Une fois install\u00e9 et lanc\u00e9, on peut v\u00e9rifier si Elasticsearch est bien en route \u00e0 l\u2019aide de cette commande :<\/span><\/p>\n

curl -X GET \"localhost:9200\/\"\n<\/code><\/pre>\n
R\u00e9sultat :<\/p>\n
{\n  \"name\" : \"_5_5A27\",\n  \"cluster_name\" : \"elasticsearch\",\n  \"cluster_uuid\" : \"RLlBm2geTvqkfesixGotTg\",\n  \"version\" : {\n    \"number\" : \"6.5.1\",\n    \"build_flavor\" : \"default\",\n    \"build_type\" : \"deb\",\n    \"build_hash\" : \"8c58350\",\n    \"build_date\" : \"2018-11-16T02:22:42.182257Z\",\n    \"build_snapshot\" : false,\n    \"lucene_version\" : \"7.5.0\",\n    \"minimum_wire_compatibility_version\" : \"5.6.0\",\n    \"minimum_index_compatibility_version\" : \"5.0.0\"\n  },\n  \"tagline\" : \"You Know, for Search\"\n}\n<\/code><\/pre>\n
On peut cr\u00e9er un premier index de cette fa\u00e7on :<\/p>\n
curl -X PUT \"localhost:9200\/customer?pretty\"\ncurl -X GET \"localhost:9200\/_cat\/indices?v\"\n<\/code><\/pre>\n
ElasticHQ<\/a> est un outil int\u00e9ressant \u00e0 installer, et gratuit, qui permet de suivre la sant\u00e9 du noeud Elasticsearch et les index qui s’y trouvent.
\nUne fois r\u00e9cup\u00e9rer, on lance l\u2019interface avec Python :<\/p>\n
python3 manage.py runserver\n<\/code><\/pre>\n
L\u2019interface sera disponible \u00e0 l\u2019URL suivant : http:\/\/localhost:5000<\/p>\n
\"elastichq\"<\/a>
Interface d’ElasticHQ<\/p><\/div>\n
Pour s\u2019interfacer avec Symfony on va utiliser le bundle FOSElastica<\/a> ainsi qu’un serializer.<\/p>\n
composer require friendsofsymfony\/elastica-bundle\ncomposer require jms\/serializer-bundle\n<\/code><\/pre>\n
MongoDB<\/h2>\n
L\u2019installation se fait depuis le site officiel<\/a>.<\/p>\n
On lance l\u2019instance de MongoDB :<\/p>\n
sudo service mongod start\n<\/code><\/pre>\n
L\u2019outil MongoBooster (d\u00e9sormais NoSQLBooster) est pratique pour visualiser les collections de documents, bien que certaines fonctionnalit\u00e9s deviennent payantes au fil du temps (autocompletion par exemple).<\/p>\n
On installe le connecteur PHP :<\/p>\n
sudo apt install php-mongodb\n<\/code><\/pre>\n
Une petite commande est n\u00e9cessaire pour faire fonctionner Doctrine MongoDB ODM avec PHP7 :<\/p>\n
composer config \"platform.ext-mongo\" \"1.6.16\" && composer require \"alcaeus\/mongo-php-adapter\"\n<\/code><\/pre>\n
Puis les librairies qui vont bien :<\/p>\n
composer require alcaeus\/mongo-php-adapter\ncomposer require doctrine\/mongodb-odm\ncomposer require doctrine\/mongodb-odm-bundle\n<\/code><\/pre>\n
Symfony<\/h2>\n
Un peu de config pour faire fonctionner les bundles (disponible sur les documentations respectives)<\/p>\n
app\/config\/parameters.yml<\/code><\/p>\n
parameters:\n    mongodb_server: \"mongodb:\/\/localhost:27017\"\n<\/code><\/pre>\n
app\/config\/config.yml<\/code><\/p>\n
doctrine_mongodb:\n    connections:\n        default:\n            server: \"%mongodb_server%\"\n            options: {}\n    default_database: test\n    document_managers:\n        default:\n            auto_mapping: true\n\nfos_elastica:\n    default_manager: mongodb\n    serializer:\n        serializer: jms_serializer\n    clients:\n        default: { host: localhost, port: 9200 }\n    indexes:\n        app:\n            types:\n                contacts:\n                    properties:\n                        name: ~\n                        lastName: ~\n                    persistence:\n                        # the driver can be orm, mongodb or phpcr\n                        driver: mongodb\n                        model: AppBundle\\Document\\Contacts\n                        provider: ~\n                        finder: ~\n<\/code><\/pre>\n
src\/AppBundle\/Document\/Contacts.php<\/code><\/p>\n
namespace AppBundle\\Document;\n\nuse Doctrine\\ODM\\MongoDB\\Mapping\\Annotations as MongoDB;\n\n\/**\n * @MongoDB\\Document\n *\/\nclass Contacts\n{\n    \/**\n     * @MongoDB\\Id\n     *\/\n    protected $id;\n\n    \/**\n     * @MongoDB\\Field(type=\"string\")\n     *\/\n    protected $name;\n\n    \/**\n     * @MongoDB\\Field(type=\"string\")\n     *\/\n    protected $last_name;\n<\/code><\/pre>\n
On configure Doctrine avec le MongoDB install\u00e9 en local, idem avec Elasticsearch.
\nOn peut pr\u00e9ciser \u00e0 Elasticsearch d\u2019indexer les contacts (qui est un Document plut\u00f4t qu\u2019une Entity), via listener, lancement manuel ou scheduler avec la commande suivante :<\/p>\n
php bin\/console fos:elastica:populate\n<\/code><\/pre>\n
Pour cr\u00e9er et lire des documents dans MongoDB, on utilise Doctrine de mani\u00e8re habituelle.<\/p>\n
$contact = new Contacts();\n$contact\n    ->setName('John')\n    ->setLastName('Doe')\n;\n\n$dm = $this->get('doctrine_mongodb')->getManager();\n$dm->persist($contact);\n$dm->flush();\n\n\/*\n......\n*\/\n\n$contacts = $this->get('doctrine_mongodb')\n    ->getRepository(Contacts::class)\n    ->findAll()\n;\n<\/code><\/pre>\n
\"mongobooster\"<\/a>
Aper\u00e7u dans MongoBooster<\/p><\/div>\n
Une fois Elasticsearch index\u00e9, il est possible de r\u00e9cup\u00e9rer nos documents via une recherche elastic plus ou moins complexe (voir documentation<\/a>)<\/p>\n
$finder = $this->container->get('fos_elastica.finder.app.contacts');\n$results = $finder->find('John');\n<\/code><\/pre>\n
\"Share<\/a>